ICanBoogie
  • Documentation
  • API Reference
  • MessageBus master
Namespaces
  • ICanBoogie
    • MessageBus
Classes
  • SimpleMessageBus
  • SimpleMessageHandlerProvider
Interfaces
  • Exception
  • MessageBus
  • MessageHandler
  • MessageHandlerProvider
  • MessagePusher
  • ShouldBePushed
Exceptions
  • NoHandlerForMessage
  • NoPusherForMessage

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 dispatch( object $message ) : mixed

Parameters

$message

Returns

mixed

Implementation of

ICanBoogie\MessageBus\MessageBus::dispatch()
protected push( object $message ) : mixed

Parameters

$message

Returns

mixed
protected handle( object $message ) : mixed

Parameters

$message

Returns

mixed
protected resolve_handler( object $message ) : ICanBoogie\MessageBus\MessageHandler|callable

Parameters

$message

Returns

ICanBoogie\MessageBus\MessageHandler|callable

Throws

ICanBoogie\MessageBus\NoHandlerForMessage
MessageBus master – Check on GitHub – API documentation generated by ApiGen