Skip to content

Instantly share code, notes, and snippets.

@garcia-jj

garcia-jj/PrinterReceiverAsync.java

Created September 18, 2015 18:51
Show Gist options
  • Save garcia-jj/a3dfa1f25ef0ef36cc11 to your computer and use it in GitHub Desktop.
Save garcia-jj/a3dfa1f25ef0ef36cc11 to your computer and use it in GitHub Desktop.
Download ZIP
JMS sample
Raw
PrinterReceiverAsync.java
package ot.jms;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "java:/global/jms/queue/printerQueue"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})
public class PrinterReceiverAsync implements MessageListener {
private final transient Logger logger = LoggerFactory.getLogger(PrinterReceiverAsync.class);
@Override
public void onMessage(Message message) {
try {
String content = message.getBody(String.class);
logger.debug("Message received (async): {}", content);
} catch (JMSException e) {
logger.warn("An error occurs when process message", e);
}
}
}
Raw
PrinterSender.java
package ot.jms;
import javax.annotation.Resource;
import javax.ejb.Schedule;
import javax.ejb.Stateless;
import javax.inject.Inject;
import javax.jms.JMSContext;
import javax.jms.Queue;
@Stateless
public class PrinterSender {
@Inject
private JMSContext context;
@Resource(lookup = "java:/global/jms/queue/printerQueue")
private Queue queue;
@Schedule(second = "*/5", minute = "*", hour = "*")
public void fire() {
for (int i = 0; i < 100; i++) {
context.createProducer().send(queue, "the lazy dog jumps over the quick brown fox");
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment