Java Reference
In-Depth Information
package
com.packtpub.as7development.chapter7.service;
import javax.annotation.Resource;
import
javax.enterprise.context.ApplicationScoped;
import javax.jms.*;
import java.util.logging.Logger;
@ApplicationScoped
public class JMSService {
@Inject
private Logger logger;
@Resource(mappedName = "java:/
ConnectionFactory")
private ConnectionFactory cf; [1]
@Resource(mappedName = "java:jboss/jms/queue/
ticketQueue")
private Queue queueExample; [2]
private Connection connection;
public void sendMessage(String txt) {
try {
connection = cf.createConnection();
Session session =
connection.createSession(false, Session.AUTO_
ACKNOWLEDGE);
MessageProducer publisher =
session.createProducer(queueExample);
connection.start();
Search WWH ::




Custom Search