JMS Clustering by Example

public class JMSClusteredClient extends HttpServlet {
	private static final long serialVersionUID = 1L;
   
	/**
	 * @see HttpServlet#service(HttpServletRequest request, HttpServletResponse response)
	 */
	protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		 PrintWriter out = response.getWriter();
		 
		 String topicqueue = request.getParameter("topicqueue");
		 String message = request.getParameter("message");
		 String server = request.getParameter("server");
		 String messageType = request.getParameter("messageType");
		 String times = request.getParameter("times");
		 
		 int intTimes = Integer.parseInt(times);
		 
		 JMSDispatcher dispatcher = new JMSDispatcher();
		 dispatcher.setTopicQueueName(topicqueue);
		 dispatcher.setServer(server);
		 dispatcher.setMessageType(messageType);
				 
		 try {
		    
			for(int count =1; count <= intTimes;count++){
				dispatcher.sendMessage( count + " of " + times + " " + message);
			}
			out.println("Message [" + message + "] sent successfully to [" + topic + "] to the [" + server + "] server " + times + " times.");
		} catch (JMSException e) {			
			e.printStackTrace();
			out.println("Error:" + e.getMessage());
		} catch (NamingException e) {			
			out.println("Error:" + e.getMessage());
			e.printStackTrace();
		} finally{
			out.close();
		}
	}

}

public class JMSDispatcher {

	/**
	 * 
	 */
	private static final long serialVersionUID = 7105145023422143880L;
	private static Logger log = Logger.getLogger(JMSDispatcher.class);


	private final String CONNECTION_FACTORY_CLUSTERED = "ClusteredConnectionFactory";
	private final String CONNECTION_FACTORY 		  = "ConnectionFactory";
	
	private final String TOPIC = "TOPIC";
	private final String QUEUE = "QUEUE";
		
	private String topicQueueName;
	private String server;
	private String messageType;
	
	
	public void setTopicQueueName(String value){
		this.topicQueueName = value;
	}
	
	public void setServer(String value){
		this.server = value;
	}
	
	public void setMessageType(String value){
		this.messageType = value;
	}
	
	public void sendMessage(Object objectMessage) throws JMSException, NamingException{
		log.debug("##### Setting up a Queue/Topic Message: #####");
		if (TOPIC.equals(messageType)){
			sendTopicMessage(objectMessage);
		} else if (QUEUE.equals(messageType)){
			sendQueueMessage(objectMessage);
		}
		log.debug("##### Publishing Message: Done #####");
	}
		
	
	private void sendQueueMessage(Object objectMessage) throws JMSException, NamingException{
		try{
			
			InitialContext initialContext = getInitialContext();
			
			QueueConnectionFactory qcf = (QueueConnectionFactory) initialContext.lookup(CONNECTION_FACTORY_CLUSTERED);
			QueueConnection queueConn = qcf.createQueueConnection();
			Queue queue = (Queue) initialContext.lookup(topicQueueName);		
			QueueSession queueSession = queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);       
			queueConn.start();
			
			QueueSender send = queueSession.createSender(queue);
			ObjectMessage om = queueSession.createObjectMessage((Serializable)objectMessage);
			setMessageProperties(om);
			log.debug("##### Publishing Message to a Queue: " +  queueName  + "#####");
			send.send(om);			
			send.close();		
			
			queueConn.stop();
		    queueSession.close();
		    queueConn.close();
		}catch(MessageFormatException ex){
			log.error("##### The MESSAGE is not Serializable ####");
			throw ex;
		}catch(MessageNotWriteableException ex){
			log.error("##### The MESSAGE is not Readable ####");
			throw ex;
		}catch(JMSException ex){
			log.error("##### JMS provider fails to set the object due to some internal error. ####");
			throw ex;
		}

	}
	
	private void sendTopicMessage(Object objectMessage) throws JMSException, NamingException{
		
		try{			
			InitialContext initialContext = getInitialContext();
		
			TopicConnectionFactory tcf = (TopicConnectionFactory)initialContext.lookup(CONNECTION_FACTORY_CLUSTERED);		
			TopicConnection topicConn = tcf.createTopicConnection();
			Topic topic = (Topic) initialContext.lookup(topicQueueName);
			TopicSession topicSession = topicConn.createTopicSession(false,TopicSession.AUTO_ACKNOWLEDGE);
			topicConn.start();
					
			TopicPublisher send = topicSession.createPublisher(topic);	
					
			ObjectMessage om = topicSession.createObjectMessage();
			om.setObject((Serializable)objectMessage);
			setMessageProperties(om);
			log.debug("##### Publishing Message to a Topic: " +  topicName  + "#####");
			send.publish(om);
			send.close();	
				
			topicConn.stop();
			topicSession.close();
			topicConn.close();
			
		}catch(MessageFormatException ex){
			log.error("##### The MESSAGE is not Serializable ####");
			throw ex;
		}catch(MessageNotWriteableException ex){
			log.error("##### The MESSAGE is not Readable ####");
			throw ex;
		}catch(JMSException ex){
			log.error("##### JMS provider fails to set the object due to some internal error. ####");
			throw ex;
		}
	}
	
	private InitialContext getInitialContext() throws NamingException{
		Properties jboss = new Properties();	
		jboss.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
		jboss.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
		jboss.put("java.naming.provider.url", server);	
		return new InitialContext(jboss);
	
	}
}

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
  <display-name>JMSWeb</display-name>
  <welcome-file-list>   
    <welcome-file>index.jsp</welcome-file>  
  </welcome-file-list>
  
  <servlet>
    <description></description>
    <display-name>JMSClusteredClient</display-name>
    <servlet-name>JMSClusteredClient</servlet-name>
    <servlet-class>com.blogspot.felipeg48.jms.web.JMSClusteredClient</servlet-class>
  </servlet>
  <servlet-mapping>
    <servlet-name>JMSClusteredClient</servlet-name>
    <url-pattern>/JMSClusteredClient</url-pattern>
  </servlet-mapping>
</web-app>