Class TestDriver

Method Summary

• __construct() public

  Constructor

• createClientMessage() public

• createQueue() public

• createRouteQueue() public

• createRouterTopic() protected

• createTransportMessage() public

• createTransportQueueName() protected

• createTransportRouterTopicName() protected

• doCreateQueue() protected

• doCreateTopic() protected

• doSendToProcessor() protected

• doSendToRouter() protected

• getConfig() public

• getContext() public

• getPriorityMap() protected

  [client message priority => transport message priority].

• getRouteCollection() public

• sendToProcessor() public

• sendToRouter() public

• setupBroker() public

  Prepare broker for work. Creates all required queues, exchanges, topics, bindings etc.

__construct(Context $context, Config $config, Enqueue\Client\RouteCollection $routes)

createClientMessage(InteropMessage $message): Message

createQueue(string $queueName, bool $prefix = true): InteropQueue

createRouteQueue(Route $route): InteropQueue

createRouterTopic(): Destination

createTransportMessage(Message $message): InteropMessage

createTransportQueueName(string $name, bool $prefix): string

createTransportRouterTopicName(string $name, bool $prefix): string

doCreateQueue(string $transportQueueName): InteropQueue

doCreateTopic(string $transportTopicName): InteropTopic

doSendToProcessor(InteropProducer $producer, InteropQueue $queue, InteropMessage $transportMessage): void

doSendToRouter(InteropProducer $producer, Destination $topic, InteropMessage $transportMessage): void

getConfig(): Config

getContext(): Context

getPriorityMap(): int[]

getRouteCollection(): RouteCollection

sendToProcessor(Message $message): DriverSendResult

sendToRouter(Message $message): DriverSendResult

setupBroker(?LoggerInterface $logger = null): void