Function OpenSubscription

pubsub/rabbitpubsub/rabbit.go:579–581

OpenSubscription returns a *pubsub.Subscription corresponding to the named queue. See the package documentation for an example. The queue must have been previously created (for instance, by using amqp.Channel.QueueDeclare) and bound to an exchange. OpenSubscription uses the supplied amqp.Connectio

(conn *amqp.Connection, name string, opts *SubscriptionOptions)

// The documentation of the amqp package recommends using separate connections for
// publishing and subscribing.
func OpenSubscription(conn *amqp.Connection, name string, opts *SubscriptionOptions) *pubsub.Subscription {
	return pubsub.NewSubscription(newSubscription(&connection{conn}, name, opts), nil, nil)
}

type subscription struct {
	conn     amqpConnection