@Stateless()
@WebService(serviceName = "Dev-test")
public class MessageSender {
    
    // BEGIN // JMS Block //
    
    @Resource(lookup = "ConnectionFactory")
    private ConnectionFactory connectionFactory;
    
    @Resource(lookup = "ServerQueue")
    private Destination serverQueue;
    
    Connection connection = null;
    
//    @PostConstruct
//    public void makeConnection() {
//        try {
//            connection = connectionFactory.createConnection();
//        } catch (Throwable t) {
//        }
//    }
//
//    @PreDestroy
//    public void endConnection() throws RuntimeException {
//        if (connection != null) {
//            try {
//                connection.close();
//            } catch (Exception e) {
//            }
//        }
//    }
    
    private String sendMessage(String message, String messageType) {
        String response = null;
        try {
            connection = connectionFactory.createConnection();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageProducer requestProducer = (MessageProducer) session.createProducer(serverQueue);
            TemporaryQueue replyQueue = session.createTemporaryQueue();
            MessageConsumer replyConsumer = session.createConsumer(replyQueue);
            
            connection.start();
        
            // Create message for sending
            TextMessage textMessage = session.createTextMessage();
            textMessage.setJMSType(messageType);
            textMessage.setText(message);
            textMessage.setJMSReplyTo(replyQueue);
            
            requestProducer.send(textMessage);
            
            Message messageFromReplyQueue = replyConsumer.receive();
            TextMessage textMessageFromReplyQueue = (TextMessage) messageFromReplyQueue;
            response = textMessageFromReplyQueue.getText();
        } catch (JMSException ex) { 
            
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (Exception e) {
            }
        }
        return response;
    }
}

@MessageDriven(mappedName = "ServerQueue")
public class SAMMessageConsumer implements MessageListener {
    @Resource(name = "ConnectionFactory")
    private ConnectionFactory connectionFactory;

    @Override
    public void onMessage(Message message) {
        //....
    }
}

@WebServlet(name = "MessageSender", urlPatterns = {"/MessageSender"})
public class MessageSender extends HttpServlet implements MessageListener {
    
    private Session session;
    private MessageProducer requestProducer;
    private MessageConsumer replyConsumer;
    
    @Resource(name = "ConnectionFactory")
    private ConnectionFactory connectionFactory;
    
    @Resource(name = "ServerQueue")
    private Destination serverQueue;
    
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {
        String log = this.sendMessage(request.getParameter("message"));
        PrintWriter printWriter = response.getWriter();
        printWriter.print(log);
        printWriter.flush();
    }
    
    private String sendMessage (String message) {
        Connection connection = null;
        try {            
            connection = connectionFactory.createConnection();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            
            requestProducer = (MessageProducer) session.createProducer(serverQueue);
                        
            TemporaryQueue replyQueue = session.createTemporaryQueue();
            replyConsumer = session.createConsumer(replyQueue);
            
            connection.start();
            
            // Create message for sending
            TextMessage textMessage = session.createTextMessage();
            textMessage.setJMSType(MessageType.GET_KEYS.toString());
            textMessage.setText(message);
            textMessage.setJMSReplyTo(replyQueue);
            
            requestProducer.send(textMessage);
                        
            Message messageFromReplyQueue = replyConsumer.receive();
            TextMessage textMessageFromReplyQueue = (TextMessage) messageFromReplyQueue;
                        
        } catch (JMSException ex) {
            Logger.getLogger(MessageSender.class.getName()).log(Level.SEVERE, null, ex);
        } finally {
            
        }
        return textMessageFromReplyQueue.getText();        
    }

    @Override
    public void onMessage(Message message) {
        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
    }
}

@Override
    public void onMessage(Message message) {
        //....
    }

...
            //requestProducer.send(textMessage);
            this.send(requestProducer, textMessage);
...

    private void send (MessageProducer mp, TextMessage tm) {
        try {
            mp.send(tm);
        } catch (JMSException ex) {
            Logger.getLogger(Authorization.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
...