in message_flow/commands/consumer/command_dispatcher.py [0:0]
def message_handler(self, message: IMessage) -> None:
_logger.debug(
"Got command %s, with payload %s.",
message.get_required_header(CommandMessageHeaders.COMMAND_TYPE),
message.payload,
) # noqa: WPS323
command_handler: Optional[
CommandHandler
] = self._command_handlers.find_target_method(message)
if command_handler is None:
_logger.debug(
"Command %s doesn't have a handler.",
message.get_required_header(CommandMessageHeaders.COMMAND_TYPE),
) # noqa: WPS323
return
command_handler_params = CommandHandlerParams(message)
command_message = CommandMessage(
message.get_id(),
self._deserializer.deserialize(
command_handler.command_class, message.payload
),
command_handler_params.correlation_headers,
message,
)
replies: CommandResult = self._invoke(command_handler, command_message)
if replies is None:
return
self._send_replies(replies, command_handler_params)
_logger.info(
"Command %s, with payload %s processed.",
message.get_required_header(CommandMessageHeaders.COMMAND_TYPE),
message.payload,
) # noqa: WPS323