                 queue.subscribe(listener)
                     .addCallback((ok) =>
                         ctag = ok.consumerTag
-                        @_remember_subscription(event, listener, {queue, auto_purge, ctag})
+                        @_remember_subscription(event, listener, {queue, ctag})
                     )
                 @emit('bound', {queue})
 


        # Combine options ordered by scope
        sub_options = _.extend({}, @options, event_options, options)
        auto_purge = sub_options.auto_purge and not sub_options.group?
        sub_options.group ?= uuid.v4()

        logger.trace("subscribe to topic", {options})

        queue_deferred = Q.defer()
        logger.trace("create queue instance", {queue_name, queue_opts})
        connection.queue queue_name, queue_opts, (queue) =>
            queue_deferred.resolve(queue)

        queue_deferred.promise
