             p = when_.all(steps)
             logger.debug('Preapred promise: ', {p})
             p
+
+    # Different actions options parsing
+    # ---------------------------------
 
     _parse_event: (event) ->
         assert _.isString(event), "event string required"

        options.group ?= uuid.v4()

        @_create_subscription_channel(options, listener)
            .then(() ->
                logger.info('Subscription created', {options})
            , (err) ->
                logger.error({err}, 'Error when opening new subscription', {options})

        It is subject to _.memoize, so it will be called only once per connection
        ###
        url = @_get_connection_url()
        amqp.connect(url).then (conn) =>
            logger.debug('Created new amqp connection', {conn})
            conn.on 'error', (err) ->
                    logger.error({err}, "Connection error", {url})
                    @emit('error', err)
                    process.exit(1)
                    @_reset_connection()
                .on 'close', ->
                    logger.info('Connection closed', {url})
                    if not @_connect.has()
