Refactor Message-Queue Client

[wagnert]

The Message-Queue Client actually needs a bit complicated initialisation process:

// load the application name
$applicationName = $this->getApplication()->getName();

// initialize the connection and the session
$queue = MessageQueue::createQueue('pms/importChunk');
$connection = QueueConnectionFactory::createQueueConnection($applicationName);
$session = $connection->createQueueSession();
$sender = $session->createSender($queue);

UAC:

• Using the Message-Queue Client MUST be similar to using the Persistence Container Client (wrapped by the InitialContext)
• It MUST be possible that the initialised Client can bin injected like a Bean

[wagnert]

Queue-Sender instances can not be injected like Managers

class MyServlet extends HttpServlet

    /**
     * The queue session to send a message with.
     *
     * @var \AppserverIo\MessageQueueClient\QueueSession
     * @Resource(name="pms/createASingleActionTimer")
     */
    protected $queueSender;

    /**
     * Handles a HTTP POST request.
     *
     * @param \AppserverIo\Psr\Servlet\Http\HttpServletRequest  $servletRequest  The request instance
     * @param \AppserverIo\Psr\Servlet\Http\HttpServletResponse $servletResponse The response instance
     *
     * @return void
     * @throws \AppserverIo\Psr\Servlet\ServletException Is thrown if the request method is not implemented
     * @see \AppserverIo\Psr\Servlet\Http\HttpServlet::doGet()
     */
    public function doPost(HttpServletRequest $servletRequest, HttpServletResponse $servletResponse)
    {
        $this->queueSender->send(new IntegerMessage($this->duration));
    }
}