Created

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist

JMS 2.0 annotation suggestion

View gist:3750788
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22
package sample;
 
// imports
 
@MessageDriven(mappedName = "jms/queue0")
public class MessageSelectorBean implements MessageListener {
 
@Resource(lookup = "jms/connectionFactory")
ConnectionFactory connectionFactory;
 
@MessageSelector("(StockSector = 'Technology')")
public void onMessage(Message message) {
try (JMSContext context = connectionFactory.createContext()) {
String request = ((TextMessage)message).getText();
Destination replyDestination = message.getJMSReplyTo();
TextMessage replyMessage = context.createTextMessage("Reply to: "+request);
context.createProducer().send(replyDestination, replyMessage);
} catch (JMSException ex) {
// log an error here
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.