src/ProcessingPlugin/MessageFlowLogger.php
private function tryLogMessage($message)
    {
        $messageId = null;

        if ($message instanceof RemoteMessage) $messageId = $message->header()->uuid();
        elseif ($message instanceof ProcessingMessage) $messageId = $message->uuid();

        if (! $messageId) return;

        $entry = $this->messageLogger->getEntryForMessageId($messageId);

        if ($entry) return;

        $this->messageLogger->logIncomingMessage($message);
    }
private function tryLogMessage($message)
    {
        $messageId = null;

        if ($message instanceof RemoteMessage) $messageId = $message->header()->uuid();
        elseif ($message instanceof ProcessingMessage) $messageId = $message->uuid();

        if (! $messageId) return;

        $entry = $this->messageLogger->getEntryForMessageId($messageId);

        if ($entry) return;

        $this->messageLogger->logIncomingMessage($message);
    }
private function tryLogMessage ( $ message ) { $ messageId = null ; if ( $ message instanceof RemoteMessage ) $ messageId = $ message -> header ( ) -> uuid ( ) ; elseif ( $ message instanceof ProcessingMessage ) $ messageId = $ message -> uuid ( ) ; if ( ! $ messageId ) return ; $ entry = $ this -> messageLogger -> getEntryForMessageId ( $ messageId ) ; if ( $ entry ) return ; $ this -> messageLogger -> logIncomingMessage ( $ message ) ; }
Message is only logged if it is has a valid type and is not logged already
otherwise it is ignored.

@param $message
Message is only logged if it is has a valid type and is not logged already otherwise it is ignored .