Package org.apache.axis.transport.jms

Class SimpleJMSListener

  • public class SimpleJMSListener
extends java.lang.Object
    SimpleJMSListener implements the javax.jms.MessageListener interface. Its basic purpose is listen asynchronously for messages and to pass them off to SimpleJMSWorker for processing. Note: This is a simple JMS listener that does not pool worker threads and is not otherwise tuned for performance. As such, its intended use is not for production code, but for demos, debugging, and performance profiling.
    Author:
    Jaime Meritt (jmeritt@sonicsoftware.com), Richard Chung (rchung@sonicsoftware.com), Dave Chappell (chappell@sonicsoftware.com)

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected static org.apache.commons.logging.Log log  

    • Constructor Summary

      Constructors 
      Constructor Description
      SimpleJMSListener​(java.util.HashMap connectorMap, java.util.HashMap cfMap, java.lang.String destination, java.lang.String username, java.lang.String password, boolean doThreads)  

    • Field Detail

      • log

        protected static org.apache.commons.logging.Log log

    • Constructor Detail

      • SimpleJMSListener

        public SimpleJMSListener​(java.util.HashMap connectorMap,
                         java.util.HashMap cfMap,
                         java.lang.String destination,
                         java.lang.String username,
                         java.lang.String password,
                         boolean doThreads)
                  throws java.lang.Exception
        Throws:
        java.lang.Exception

    • Method Detail

      • getAxisServer

        protected static AxisServer getAxisServer()

      • onMessage

        public void onMessage​(javax.jms.Message message)
        This method is called asynchronously whenever a message arrives.
        Parameters:
        message -

      • start

        public void start()
           throws java.lang.Exception
        Throws:
        java.lang.Exception

      • shutdown

        public void shutdown()
              throws java.lang.Exception
        Throws:
        java.lang.Exception

      • createConnectorMap

        public static final java.util.HashMap createConnectorMap​(Options options)

      • createCFMap

        public static final java.util.HashMap createCFMap​(Options options)
                                           throws java.io.IOException
        Throws:
        java.io.IOException

      • main

        public static void main​(java.lang.String[] args)
                 throws java.lang.Exception
        Throws:
        java.lang.Exception

      • printUsage

        public static void printUsage()