         @conn_count = 0
         @_queues = {}
         @_exchanges = {}
-        @_auto_purge = []
         @_subscribed_queues = {}
-
-        process.on 'SIGINT', @_cleanup
-
-    _cleanup: =>
-        logger.info('cleaning up purges queues', @_auto_purge.length)
-        for item in @_auto_purge
-            logger.info('destroying queue', item?.name)
-            item?.destroy()
 
     publish: (event, payload, options, cb) ->
         """

        queue_deferred = Q.defer()
        logger.trace("create queue instance", {queue_name, queue_opts})
        connection.queue queue_name, queue_opts, (queue) =>
            if options.auto_purge
                logger.debug('list queue for auto_purge', queue.name)
                @_auto_purge.push(queue)
            queue_deferred.resolve(queue)

        queue_deferred.promise

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

