Package org.apache.axis.transport.jms
Class SimpleJMSListener
- java.lang.Object
-
- org.apache.axis.transport.jms.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)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static java.util.HashMap
createCFMap(Options options)
static java.util.HashMap
createConnectorMap(Options options)
protected static AxisServer
getAxisServer()
protected JMSConnector
getConnector()
static void
main(java.lang.String[] args)
void
onMessage(javax.jms.Message message)
This method is called asynchronously whenever a message arrives.static void
printUsage()
void
shutdown()
void
start()
-
-
-
Method Detail
-
getAxisServer
protected static AxisServer getAxisServer()
-
getConnector
protected JMSConnector getConnector()
-
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()
-
-