Components/DB/DBConfigurableConsumer.php
protected function onConsume(EndpointInterface $endpoint, MessageInterface $message)
    {
        $options = $endpoint->getOptions();
        $method = $options[NoSQLConfigurableProtocol::OPTION_METHOD];
        $config = $this->methodsConfiguration[$method];
        $steps = $config[ConfigurableConsumerInterface::CONFIG_ON_CONSUME];

        $context = $this->getConfHelper()->createContext($options, $message);

        $this->configurableStepsProvider->executeSteps($steps, $options, $context);
    }
protected function onConsume(EndpointInterface $endpoint, MessageInterface $message)
    {
        $options = $endpoint->getOptions();
        $method = $options[NoSQLConfigurableProtocol::OPTION_METHOD];
        $config = $this->methodsConfiguration[$method];
        $steps = $config[ConfigurableConsumerInterface::CONFIG_ON_CONSUME];

        $context = $this->getConfHelper()->createContext($options, $message);

        $this->configurableStepsProvider->executeSteps($steps, $options, $context);
    }
protected function onConsume ( EndpointInterface $ endpoint , MessageInterface $ message ) { $ options = $ endpoint -> getOptions ( ) ; $ method = $ options [ NoSQLConfigurableProtocol :: OPTION_METHOD ] ; $ config = $ this -> methodsConfiguration [ $ method ] ; $ steps = $ config [ ConfigurableConsumerInterface :: CONFIG_ON_CONSUME ] ; $ context = $ this -> getConfHelper ( ) -> createContext ( $ options , $ message ) ; $ this -> configurableStepsProvider -> executeSteps ( $ steps , $ options , $ context ) ; }
Executes the necessary actions after the message has been consumed.

@param EndpointInterface $endpoint
@param MessageInterface  $message
Executes the necessary actions after the message has been consumed .