DbBroker implements BrokerInterface
FinalYes
Table of Contents
Interfaces
- BrokerInterface
Constants
- TYPE_CODE = 'db'
Methods
- __construct() : mixed
- ack() : void
- get() : iterable<string|int, mixed>
- getOne() : MessageBox|null
- reject() : void
- send() : void
Constants
TYPE_CODE
public
mixed
TYPE_CODE
= 'db'
Methods
__construct()
public
__construct(Entity $tableEntity[, RetryStrategyInterface $retryStrategy = new MultiplierRetryStrategy() ]) : mixed
Parameters
- $tableEntity : Entity
- $retryStrategy : RetryStrategyInterface = new MultiplierRetryStrategy()
ack()
public
ack(MessageBox $message) : void
Parameters
- $message : MessageBox
Tags
get()
public
get(string $queueId[, int $limit = 50 ]) : iterable<string|int, mixed>
Parameters
- $queueId : string
- $limit : int = 50
Return values
iterable<string|int, mixed>getOne()
public
getOne(string $queueId) : MessageBox|null
Parameters
- $queueId : string
Return values
MessageBox|nullreject()
public
reject(MessageBox $message) : void
Parameters
- $message : MessageBox
Tags
send()
public
send(MessageInterface $message, string $queueId[, array<string|int, ProcessingParamInterface> $params = [] ]) : void
Parameters
- $message : MessageInterface
- $queueId : string
- $params : array<string|int, ProcessingParamInterface> = []