\Mine\AmqpDelayProducer

Summary

Methods
Properties
Constants
produce()
No public properties found
No constants found
No protected methods found
$eventDispatcher
N/A
produceMessage()
injectMessageProperty()
No private properties found
N/A

Properties

$eventDispatcher

$eventDispatcher : \Psr\EventDispatcher\EventDispatcherInterface

Db

Type

\Psr\EventDispatcher\EventDispatcherInterface

Methods

produce()

produce(\Hyperf\Amqp\Message\ProducerMessageInterface  $producerMessage, \Mine\Amqp\bool  $confirm = false, \Mine\Amqp\int  $timeout = 5,   $delayTime) 

Parameters

\Hyperf\Amqp\Message\ProducerMessageInterface $producerMessage
\Mine\Amqp\bool $confirm
\Mine\Amqp\int $timeout
$delayTime

Throws

\Psr\Container\ContainerExceptionInterface
\Throwable
\Psr\Container\NotFoundExceptionInterface

produceMessage()

produceMessage(\Hyperf\Amqp\Message\ProducerMessageInterface  $producerMessage, boolean  $confirm = false, integer  $timeout = 5, integer  $delayTime) : boolean

生产消息

Parameters

\Hyperf\Amqp\Message\ProducerMessageInterface $producerMessage
boolean $confirm
integer $timeout
integer $delayTime

Throws

\Throwable

Returns

boolean

injectMessageProperty()

injectMessageProperty(\Hyperf\Amqp\Message\ProducerMessageInterface  $producerMessage) 

Parameters

\Hyperf\Amqp\Message\ProducerMessageInterface $producerMessage