public class PriorityMessageHandler extends Object implements org.springframework.jms.listener.SessionAwareMessageListener
| Constructor and Description | 
|---|
| PriorityMessageHandler(int scaleout) | 
| Modifier and Type | Method and Description | 
|---|---|
| BlockingQueue<org.apache.uima.aae.message.MessageWrapper> | getQueue() | 
| void | onMessage(javax.jms.Message message,
         javax.jms.Session session)Wraps an incoming message in a protocol neutral envelope and adds priority
 value to enable sorting in a Priority Queue. | 
public BlockingQueue<org.apache.uima.aae.message.MessageWrapper> getQueue()
public void onMessage(javax.jms.Message message,
                      javax.jms.Session session)
               throws javax.jms.JMSException
onMessage in interface org.springframework.jms.listener.SessionAwareMessageListenerjavax.jms.JMSExceptionCopyright © 2006–2018 The Apache Software Foundation. All rights reserved.