if ($this->autoSetupExchange
) { $this->
setupExchangeAndQueues(); // also setup normal exchange for delayed messages so delay queue can DLX messages to it
} if (0 !==
$delayInMs) { $this->
publishWithDelay($body,
$headers,
$delayInMs,
$amqpStamp);
return;
} $this->
publishOnExchange( $this->
exchange(),
$body,
$this->
getRoutingKeyForMessage($amqpStamp),
$headers,
$amqpStamp );
} /**
* Returns an approximate count of the messages in defined queues.
*/