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.SessionAwareMessageListener
javax.jms.JMSException
Copyright © 2006–2018 The Apache Software Foundation. All rights reserved.