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 )


				
				 public 
				
				

				dispatch( object $message )
				

				: mixed


				
				 protected 
				
				

				push( object $message )
				

				: mixed


				
				 protected 
				
				

				handle( object $message )
				

				: mixed


				
				 protected 
				
				

				resolve_handler( object $message )
				

				: ICanBoogie\MessageBus\MessageHandler|callable