Function newSubscription

pubsub/rabbitpubsub/rabbit.go:600–612

atomic

(conn amqpConnection, name string, opts *SubscriptionOptions)

var nextConsumer int64 // atomic

func newSubscription(conn amqpConnection, name string, opts *SubscriptionOptions) *subscription {
	if opts == nil {
		opts = &SubscriptionOptions{}
	}

	return &subscription{
		conn:             conn,
		queue:            name,
		consumer:         fmt.Sprintf("c%d", atomic.AddInt64(&nextConsumer, 1)),
		opts:             opts,
		receiveBatchHook: func() {},
	}
}

// Must be called with s.mu held.
func (s *subscription) establishChannel(ctx context.Context) error {