package mybeans;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;
@MessageDriven(mappedName = "jms/helloserver", activationConfig = {
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue")
})
public class msgbean1 implements MessageListener {
public msgbean1() {
}
@Override
public void onMessage(Message message)
{
try{
System.out.println("HELLO "+ message.getStringProperty("name"));
}catch(Exception e){}
}
}
--------------------
//msgclient.java
import javax.annotation.Resource;
import javax.jms.*;
public class msgclient
{
@Resource(mappedName = "jms/helloserver")
private static Queue helloserver;
@Resource(mappedName = "jms/helloserverFactory")
private static ConnectionFactory helloserverFactory;
public static void main(String[] args) throws JMSException
{
Connection connection = helloserverFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer messageProducer = session.createProducer(helloserver);
Message message=session.createTextMessage();
message.setStringProperty("name","Students");
messageProducer.send(message);
System.exit(0);
}
}