electric.server.jms
Class JMSDispatcher

java.lang.Object
  electric.server.jms.JMSDispatcher

All Implemented Interfaces:

IEXMLLoggingConstants, IGLUELoggingConstants, IJMSConstants, ILoggingConstants, javax.jms.MessageListener

public class JMSDispatcher

extends java.lang.Object

implements javax.jms.MessageListener, IJMSConstants, IGLUELoggingConstants

JMSDispatcher is a jms message processing facility. It runs on both client and server sides of the platform and is responsible for dispatching jms messages (requests) to either their targets (web services) or returning responses to the clients

Author:

webMethods

Field Summary

Fields inherited from interface electric.server.jms.IJMSConstants

DEFAULT_CONNECTION_FACTORY, DEFAULT_QUEUE, GLUE_OPTIMIZATIONS, JMS_QUEUE, JMS_QUEUE_CONNECTION_FACTORY, JMS_RESPONSE_QUEUE, JMS_REUSE_QUEUE_CONNECTIONS, JNDI_PROPERTIES, RELATED_MESSAGE, ROOT, SERVICE_URN, TOTAL_MESSAGE_PARTS, WSDL_NOT_FOUND, WSDL_REQUEST

Fields inherited from interface electric.glue.IGLUELoggingConstants

CLUSTER_DEBUG_EVENT, CLUSTER_EVENT, CONSOLE_DEBUG_EVENT, DEPLOY_EVENT, DETECTORS_EVENT, HTTP_EVENT, JMS_EVENT, REBINDING_EVENT, SECURITY_DEBUG_EVENT, SECURITY_DETAIL_EVENT, SERVLET_EVENT, SOAP_EVENT

Fields inherited from interface electric.xml.IEXMLLoggingConstants

MAPPING_EVENT, SCHEMA_EVENT

Fields inherited from interface electric.util.log.ILoggingConstants

CLASSLOADER_EVENT, COMMAND_EVENT, COMMENT_EVENT, CONFIG_EVENT, DEBUG_EVENT, ELECTRIC_LOGGING_PROPERTY, ERROR_EVENT, EXCEPTION_EVENT, FILE_EVENT, LICENSE_EVENT, RESOURCES_EVENT, SECURITY_EVENT, SHUTDOWN_EVENT, SOURCE_EVENT, SQL_EVENT, STARTUP_EVENT, WARNING_EVENT

Constructor Summary

JMSDispatcher()

Method Summary

static ThreadPool	getThreadPool() Returns the thread pool used by the dispatcher.
void	onMessage(javax.jms.Message message) This method is called by the JMS provider when a message is available on one of the operating queues.
static void	setThreadPool(ThreadPool threadPool) Sets the thread pool used by the dispatcher.
void	startDispatch(JMSContext context) Starts the reception of the messages for the queue specified by the given jms context.
static void	stopDispatch(JMSContext context) Stops the message dispatch for the given context.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSDispatcher

public JMSDispatcher()

Method Detail

setThreadPool

public static void setThreadPool(ThreadPool threadPool)

Sets the thread pool used by the dispatcher. For every request received over one of the operating queues, the dispatcher assigns a thread from the thread pool.

Parameters:

threadPool -

getThreadPool

public static ThreadPool getThreadPool()

Returns the thread pool used by the dispatcher.

startDispatch

public void startDispatch(JMSContext context)
                   throws javax.jms.JMSException

Starts the reception of the messages for the queue specified by the given jms context. Once the dispatch is started, the wsdl and invocation requests are delivered to the services located at the path specified by the context.

Parameters:

context - the context to start the dispatch for

Throws:

javax.jms.JMSException

stopDispatch

public static void stopDispatch(JMSContext context)
                         throws javax.jms.JMSException

Stops the message dispatch for the given context.

Parameters:

context - the context to stop the dispatch for

Throws:

javax.jms.JMSException

onMessage

public void onMessage(javax.jms.Message message)

This method is called by the JMS provider when a message is available on one of the operating queues.

Specified by:

onMessage in interface javax.jms.MessageListener

Parameters:

message - the arrived message