package com.jboss.jms.client;

import java.util.Hashtable;
import java.util.UUID;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class Requestor {

 private String requestQueueName = "/queue/A";
 private String replyQueueName = "/queue/B";
 private MessageConsumer replyConsumer;
 Context ic = null;

 public void send() throws Exception {

 
  ConnectionFactory cf = null;
  Connection connection = null;

  try {
   // ic = new InitialContext();
   ic = getInitialContext();

   cf = (ConnectionFactory) ic.lookup("/ConnectionFactory");

   // Request Queue Setting
   Queue queue = (Queue) ic.lookup(requestQueueName);
   System.out.println("Queue " + requestQueueName + " exists");

   // ReplyQueue Lookup
   Destination replyQueue = (Destination) ic.lookup(replyQueueName);

   // Connect Create
   connection = cf.createConnection();
   connection.start();

   // Session Create
   Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
   MessageProducer sender = session.createProducer(queue);

   TextMessage message = session.createTextMessage("Choi Ji-Woong");

   // Message property setting for reply
   message.setJMSReplyTo(replyQueue);
   String uuid = (UUID.randomUUID()).toString();/*
                * generate a unique
                * id
                */
   message.setJMSCorrelationID(uuid);

   // Send message
   sender.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  // sender.setTimeToLive(10000);
   sender.send(message);
   System.out.println("The message was successfully sent to the "
     + queue.getQueueName() + " queue");

   System.out.println("Sent request");
   System.out.println("\tTime:       " + System.currentTimeMillis()
     + " ms");
   System.out.println("\tMessage ID: " + message.getJMSMessageID());
   System.out
     .println("\tCorrel. ID: " + message.getJMSCorrelationID());
   System.out.println("\tReply to:   " + message.getJMSReplyTo());
   System.out.println("\tContents:   " + message.getText());

   // Wait Reply Message from Reply Queue
   replyConsumer = session.createConsumer(replyQueue, "JMSCorrelationID = '" + uuid + "'");
   System.out.println("\tMessage Selector : " + replyConsumer.getMessageSelector());
   Message msg = replyConsumer.receive(10000); // wait reply message for 5 seconds

   if (msg instanceof TextMessage) {
    TextMessage replyMessage = (TextMessage) msg;
    System.out.println("Received reply ");
    System.out.println("\tTime:       "
      + System.currentTimeMillis() + " ms");
    System.out.println("\tMessage ID: "
      + replyMessage.getJMSMessageID());
    System.out.println("\tCorrel. ID: "
      + replyMessage.getJMSCorrelationID());
    System.out.println("\tReply to:   "
      + replyMessage.getJMSReplyTo());
    System.out.println("\tContents:   " + replyMessage.getText());
   }
  } finally {
   if (ic != null) {
    try {
     ic.close();
    } catch (Exception e) {
     throw e;
    }
   }

   // ALWAYS close your connection in a finally block to avoid leaks.
   // Closing connection also takes care of closing its related objects
   // e.g. sessions.
   closeConnection(connection);
  }
 }

 private Context getInitialContext() {
  try {
   Hashtable<Object, String> env = new Hashtable<Object, String>();

   env.put(Context.INITIAL_CONTEXT_FACTORY,
     "org.jnp.interfaces.NamingContextFactory");
   env.put(Context.PROVIDER_URL, "localhost:1199");

   Context ctx = new InitialContext(env);
   return ctx;
  } catch (Exception e) {
   e.printStackTrace();
  }
  return null;
 }

 private void closeConnection(Connection con) {
  try {
   if (con != null) {
    con.close();
   }
  } catch (JMSException jmse) {
   System.out.println("Could not close connection " + con
     + " exception was " + jmse);
  }
 }

 /**
  * @param args
  */
 public static void main(String[] args) throws Exception {
  // TODO Auto-generated method stub
  new Requestor().send();
 }
}

package com.jboss.jms.client;

import java.util.Hashtable;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;

public class Replier implements MessageListener {
 private String requestQueueName = "/queue/A";
 private Session session;
 private boolean quit = false;
 Context ic = null;

 public void waitMessage() throws Exception {

 
  ConnectionFactory cf = null;
  Connection connection = null;
 
  try {
   // ic = new InitialContext();
   ic = getInitialContext();

   cf = (ConnectionFactory) ic.lookup("/ConnectionFactory");
   // Connect Create
   connection = cf.createConnection();

   // Session Create
   session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

   // Request Queue Setting
   Queue queue = (Queue) ic.lookup(requestQueueName);
   System.out.println("Queue " + requestQueueName + " exists");

   MessageConsumer consumer = session.createConsumer(queue);
   consumer.setMessageListener(this);
   connection.start();

  } catch (Exception ex) {
   if (ic != null) {
    try {
     ic.close();
    } catch (Exception e) {
     throw e;
    }
   }

   // ALWAYS close your connection in a finally block to avoid leaks.
   // Closing connection also takes care of closing its related objects
   // e.g. sessions.
   closeConnection(connection);
  }
 }

 public void onMessage(Message message) {
  try {
   if ((message instanceof TextMessage)
     && (message.getJMSReplyTo() != null)) {
    TextMessage requestMessage = (TextMessage) message;

    System.out.println("Received request");
    System.out.println("\tTime:       "
      + System.currentTimeMillis() + " ms");
    System.out.println("\tMessage ID: "
      + requestMessage.getJMSMessageID());
    System.out.println("\tCorrel. ID: "
      + requestMessage.getJMSCorrelationID());
    System.out.println("\tReply to:   "
      + requestMessage.getJMSReplyTo());
    System.out.println("\tRecv Contents:   "
      + requestMessage.getText());

    String contents = requestMessage.getText() + ", Nice to meet you! ";
   
    Destination replyDestination = message.getJMSReplyTo();
    System.out.println("\tDestination : " + ((Queue)replyDestination).getQueueName());
   
    Queue replyQueue = (Queue) ic.lookup("/queue/B");
    MessageProducer replyProducer = session.createProducer(replyQueue);

    TextMessage replyMessage = session.createTextMessage();
    replyMessage.setText(contents);
    replyMessage.setJMSCorrelationID(requestMessage
      .getJMSCorrelationID());
    replyProducer.send(replyMessage);

    System.out.println("Sent reply");
    System.out.println("\tTime:       "
      + System.currentTimeMillis() + " ms");
    System.out.println("\tMessage ID: "
      + replyMessage.getJMSMessageID());
    System.out.println("\tCorrel. ID: "
      + replyMessage.getJMSCorrelationID());
    System.out.println("\tReply to:   "
      + replyMessage.getJMSReplyTo());
    System.out.println("\tContents:   " + replyMessage.getText());
   
    if (contents.equalsIgnoreCase("quit")) {
     synchronized (this) {
      quit = true;
      this.notifyAll(); // Notify main thread to quit
     }
    }
   }
   
  } catch (Exception e) {
   e.printStackTrace();
  }

 }

 private Context getInitialContext() {
  try {
   Hashtable<Object, String> env = new Hashtable<Object, String>();

   env.put(Context.INITIAL_CONTEXT_FACTORY,
     "org.jnp.interfaces.NamingContextFactory");
   env.put(Context.PROVIDER_URL, "localhost:1199");

   Context ctx = new InitialContext(env);
   return ctx;
  } catch (Exception e) {
   e.printStackTrace();
  }
  return null;
 }

 private void closeConnection(Connection con) {
  try {
   if (con != null) {
    con.close();
   }
  } catch (JMSException jmse) {
   System.out.println("Could not close connection " + con
     + " exception was " + jmse);
  }
 }

 /**
  * @param args
  */
 public static void main(String[] args) throws Exception {
  // TODO Auto-generated method stub
  Replier replier = new Replier();
  replier.waitMessage();
  System.out
    .println("JMS Ready To Receive Messages (To quit, send a \"quit\" message).");

  // Wait until a "quit" message has been received.
  synchronized (replier) {
   while (!replier.quit) {
    try {
     replier.wait();
    } catch (InterruptedException ie) {
    }
   }
  }

 }
}

Replier.java

Requestor.java

# Load mod_jk module
# Update this path to match your modules location
#LoadModule jk_module          modules/mod_jk-1.2.26-httpd-2.2.6.so
LoadModule jk_module          modules/mod_jk.so

# Where to find workers.properties
# Update this path to match your conf directory location (put workers.properties next to httpd.conf)
JkWorkersFile conf/workers.properties

# Where to put jk logs
# Update this path to match your logs directory location (put mod_jk.log next to access_log)
JkLogFile     logs/mod_jk.log

# Set the jk log level [debug/error/info]
#JkLogLevel    debug
JkLogLevel    info

# Select the log format
JkLogStampFormat "[%a %b %d %H:%M:%S %Y] "

# JkOptions indicate to send SSL KEY SIZE,
JkOptions     +ForwardKeySize +ForwardURICompat -ForwardDirectories +ForwardURICompatUnparsed

# JkRequestLogFormat set the request format
JkRequestLogFormat     "%w %V %T"

# Send everything for context /examples to worker named worker1 (ajp13)

JkMount  /hello/* loadbalancer
JkMount  /jkstatus* jkstatus

# Define load balancer worker using ajp13
worker.list=loadbalancer, sso, node1, node2, jkstatus

# Set properties for node1 (ajp13)
worker.node1.type=ajp13
worker.node1.maintain=60
worker.node1.host=10.64.160.179
worker.node1.port=8109
worker.node1.lbfactor=1
worker.node1.cachesize=50
worker.node1.cache_timeout=60000
worker.node1.socket_timeout=60
worker.node1.socket_keepalive=true
worker.node1.connect_timeout=10000  // AJPConnector의 connectionTimeout과 동일한 시간으로 설정하세요
worker.node1.recycle_timeout=3000
worker.node1.recovery_options=7
worker.node1.redirect=node2

# Set properties for node2 (ajp13)
worker.node2.type=ajp13
worker.node2.maintain=60
worker.node2.host=10.64.160.179
worker.node2.port=8209
worker.node2.lbfactor=1
worker.node2.cachesize=50
worker.node2.cache_timeout=60000
worker.node2.socket_timeout=60
worker.node2.socket_keepalive=true
worker.node2.connect_timeout=10000  // AJPConnector의 connectionTimeout과 동일한 시간으로 설정하세요
worker.node2.recycle_timeout=3000
worker.node2.recovery_options=7
worker.node2.redirect=node1

worker.loadbalancer.type=lb
worker.loadbalancer.balance_workers=node1, node2
worker.loadbalancer.method=Session
worker.loadbalancer.sticky_session=True
#worker.loadbalancer.sticky_session_force=True

worker.jkstatus.type=status