package com.redhat.training.messaging;
|
|
import javax.ejb.Singleton;
|
import javax.ejb.Startup;
|
import javax.annotation.Resource;
|
import javax.jms.Queue;
|
import javax.jms.JMSContext;
|
import javax.inject.Inject;
|
|
@Startup
|
@Singleton
|
public class JMSUtil {
|
|
@Resource(mappedName = "java:jboss/jms/queue/helloWorldQueue")
|
private Queue helloWorldQueue;
|
|
@Inject
|
JMSContext context;
|
|
public void sendMessage(String msg) {
|
try {
|
context.createProducer().send(helloWorldQueue, msg);
|
}
|
catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
