public function pushMessage($queueName, $message)
    {
        $amqpMessage = new AMQPMessage($message, $this->defaultMessageParams);
        $this->getChannel()->basic_publish($amqpMessage, $this->exchange, $queueName);
    }
public function pushMessage($queueName, $message)
    {
        $amqpMessage = new AMQPMessage($message, $this->defaultMessageParams);
        $this->getChannel()->basic_publish($amqpMessage, $this->exchange, $queueName);
    }
public function pushMessage ( $ queueName , $ message ) { $ amqpMessage = new AMQPMessage ( $ message , $ this -> defaultMessageParams ) ; $ this -> getChannel ( ) -> basic_publish ( $ amqpMessage , $ this -> exchange , $ queueName ) ; }
Insert a message at the top of the queue.

@param string $queueName
@param string $message
Insert a message at the top of the queue .