Developing Applications with JBoss JMS Provider - Java EE 7 Development with WildFly - page 223

package com.packtpub.wflydevelopment.chapter6.jms;
Import javax.annotation.Resource;
Import javax.enterprise.context.ApplicationScoped;
Import javax.jms.*;
Import java.util.logging.Logger;
@ApplicationScoped
public class BookingQueueProducer {
@Inject
private Logger logger;
@Resource(mappedName = "java:/ConnectionFactory")
private ConnectionFactorycf;
@Resource(mappedName =
BookingQueueDefinition.BOOKING_QUEUE)
private Queue queueExample;
public void sendMessage(String txt) {
try {
final Connection connection =
cf.createConnection();
Session session = connection
.createSession(false,
Session.AUTO_ACKNOWLEDGE);
final MessageProducer publisher =
session.createProducer(queueExample);
connection.start();
final TextMessage message =
session.createTextMessage(txt);
publisher.send(message);
}
catch (Exception exc) {
logger.error("Error ! "+exc);