Class SimpleMessageBus

A message bus that can handle messages right away or push them to a queue.

ICanBoogie\MessageBus\SimpleMessageBus implements ICanBoogie\MessageBus\MessageBus

Namespace: ICanBoogie\MessageBus
Located at SimpleMessageBus.php

Methods summary

`public`	# `__construct( callable $message_handler_provider, callable $message_pusher = null )` Parameters `$message_handler_provider` `$message_pusher`
`public mixed`	# `dispatch( ICanBoogie\MessageBus\Message $message )` Parameters `$message` Returns mixed Implementation of `ICanBoogie\MessageBus\MessageBus::dispatch()`
`protected mixed`	# `push( ICanBoogie\MessageBus\Message $message )` Parameters `$message` Returns mixed
`protected mixed`	# `handle( ICanBoogie\MessageBus\Message $message )` Parameters `$message` Returns mixed
`protected ICanBoogie\MessageBus\MessageHandler\|callable`	# `resolve_handler( ICanBoogie\MessageBus\Message $message )` Parameters `$message` Returns `ICanBoogie\MessageBus\MessageHandler`\|callable Throws `ICanBoogie\MessageBus\NoHandlerForMessage`