package mdb;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.EJBException;
import javax.ejb.MessageDriven;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
@MessageDriven(mappedName = "jms/t", activationConfig = {
      @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
      @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
      @ActivationConfigProperty(propertyName = "subscriptionDurability", propertyValue = "Durable"),
      @ActivationConfigProperty(propertyName = "clientId", propertyValue = "MsgDrvTest"),
@ActivationConfigProperty(propertyName = "subscriptionName", propertyValue = "MsgDrvTest") })
public class MsgDrvTest implements MessageListener,MessageDrivenBean {
      public void onMessage(Message message) {
            TextMessage tm = (TextMessage) message;
            try {
                  String text = tm.getText();
                  System.out.println("Received new message:"+text);
            } catch (JMSException e) {
                  e.printStackTrace();
            }
      }
      public void ejbRemove() throws EJBException {
            System.out.println("ejbRemove called");
      }
      public void setMessageDrivenContext(MessageDrivenContext ctx)
      throws EJBException {
            System.out.println("setMessageDrivenContext called");
      }
}

package topic;
import java.io.IOException;
import java.io.PrintWriter;
import javax.jms.DeliveryMode;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class TPublisher extends HttpServlet {
      private InitialContext ic;
      private Context initContext;
      private TopicConnectionFactory tcf;
      private TopicConnection tcon;
      private TopicSession tsession;
      private Topic topic;
      private TopicPublisher publisher;
      private TextMessage msg;
      public void doGet(HttpServletRequest request, HttpServletResponse response)
      throws ServletException, IOException {
            response.setContentType("text/html");
            PrintWriter out = response.getWriter();
            new TPublisher().publish();
            out.println("</HTML>");
            out.flush();
            out.close();
      }
      public void doPost(HttpServletRequest request, HttpServletResponse response)
      throws ServletException, IOException {
            this.doGet(request, response);
      }
      public void publish(){
            try {
                  ic =new InitialContext();
                  initContext = ic;
                  tcf = (TopicConnectionFactory) initContext.lookup("jms/cf");
                  tcon = tcf.createTopicConnection();
                  tsession = tcon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
                  topic = (Topic) initContext.lookup("jms/t");
                  initContext.close();
                  publisher = tsession.createPublisher(topic);
                  publisher.setDeliveryMode(DeliveryMode.PERSISTENT);
                  String messageText = null;
                  Integer i = 0;
                  while(true){
                        System.out.println("Enter message to send or 'quit':");
                        i++;
                        messageText = i.toString();
                        System.out.println(messageText);
                        if("quit".equals(messageText))
                        break;
                        msg = tsession.createTextMessage(messageText);
                        publisher.publish(msg);
                        Thread.sleep(10000);
                  }
                  System.out.println("Exiting...");
                  tcon.close();
                  System.out.println("GoodBye!");
            } catch (Exception e) {
                  e.printStackTrace();
                  System.exit(1);
            }
      }
}