Skip to content

Instantly share code, notes, and snippets.

@milenkovicm
Created February 5, 2012 00:25
Show Gist options
  • Save milenkovicm/1741374 to your computer and use it in GitHub Desktop.
Save milenkovicm/1741374 to your computer and use it in GitHub Desktop.
send message using SLSB
package com.e.test.service.first.controller;
import javax.annotation.Resource;
import javax.ejb.Stateless;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import com.e.test.service.first.api.SendMessage;
@Stateless
public class SendMessageService implements SendMessage {
@Resource(mappedName = "java:/ConnectionFactory")
private ConnectionFactory connectionFactory;
@Resource(mappedName = "java:/queue/test")
private Queue queue;
@Override
public void sendMessage(String text) {
try {
Connection connection;
Session session;
MessageProducer messageProducer;
connection = this.connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
messageProducer = session.createProducer(this.queue);
TextMessage message = session.createTextMessage();
message.setText(text);
messageProducer.send(message);
messageProducer.close();
session.close();
connection.close();
System.out.println("----> W: "+text);
} catch (Exception e){
e.printStackTrace();
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment