code: public void onMessage(Message msg) {
  	        try {
                      LOG.debug("Queuing msg [" + msg.getJMSMessageID() + "]");
                  } catch (JMSException e) {
                  }
  		this.queue.offer(msg);
  	}
docs: <code>javax.jms.MessageListener</code> implementation.
  <p/>
  Stored the JMS message in an internal queue for processing
  by the <code>nextTuple()</code> method.