Code:play 

package main

import (
	"context"
	"fmt"
	"log"
	"time"

	"github.com/streadway/amqp"
	"gocloud.dev/pubsub"
	"gocloud.dev/pubsub/rabbitpubsub"
)

const rabbitURL = "amqp://guest:guest@localhost:5672/"

func main() {
	// Connect to RabbitMQ.
	conn, err := amqp.Dial(rabbitURL)
	if err != nil {
		// We can't connect to RabbitMQ, most likely because it's not available
		// in the current environment. Rather than have the test fail,
		// print the line that is expected.
		fmt.Println("success")
		return
	}
	defer conn.Close()

	// Declare an exchange and a queue. Bind the queue to the exchange.
	ch, err := conn.Channel()
	if err != nil {
		log.Fatalf("creating channel: %v", err)
	}
	const exchangeName = "my-topic"
	err = ch.ExchangeDeclare(
		exchangeName,
		"fanout", // kind
		false,    // durable
		false,    // delete when unused
		false,    // internal
		false,    // no-wait
		nil)      // args
	if err != nil {
		log.Fatalf("declaring exchange: %v", err)
	}
	const queueName = "my-subscription"
	q, err := ch.QueueDeclare(
		queueName,
		false, // durable
		false, // delete when unused
		false, // exclusive
		false, // no-wait
		nil)   // arguments
	if err != nil {
		log.Fatalf("declaring queue: %v", err)
	}
	err = ch.QueueBind(q.Name, q.Name, exchangeName,
		false, // no-wait
		nil)   // args
	if err != nil {
		log.Fatalf("binding queue: %v", err)
	}
	ch.Close() // OpenSubscription will create its own channels.

	// Publish a message to the exchange (that is, topic).
	topic := rabbitpubsub.OpenTopic(conn, exchangeName)
	ctx := context.Background()
	err = topic.Send(ctx, &pubsub.Message{Body: []byte("hello")})
	if err != nil {
		log.Fatalf("sending: %v", err)
	}
	if err := topic.Shutdown(ctx); err != nil {
		log.Fatalf("closing topic: %v", err)
	}

	// Receive the message from the queue (that is, subscription).
	sub := rabbitpubsub.OpenSubscription(conn, queueName)
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	msg, err := sub.Receive(ctx)
	if err != nil {
		log.Fatalf("opening subscription: %v", err)
	}
	msg.Ack()
	ctx, cancel = context.WithTimeout(context.Background(), time.Second)
	defer cancel()
	if err := sub.Shutdown(ctx); err != nil {
		log.Fatalf("closing subscription: %v", err)
	}
	fmt.Println("success")
}

Output:

success