Thursday, 12 February 2015

14. An EJB application that demonstrates MDB.


 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);  
    }  
   }  

No comments:

Post a Comment