org.apache.axis2.transport.jms
Class JMSMessageReceiver

java.lang.Object
  org.apache.axis2.transport.jms.JMSMessageReceiver

All Implemented Interfaces:

javax.jms.MessageListener

public class JMSMessageReceiver
extends java.lang.Object
implements javax.jms.MessageListener

This is the actual receiver which listens for and accepts JMS messages, and hands them over to be processed by a worker thread. An instance of this class is created for each JMSConnectionFactory, but all instances may and will share the same worker thread pool.

Method Summary

ConfigurationContext	getAxisConf() Return the Axis configuration
void	onMessage(javax.jms.Message message) The entry point on the recepit of each JMS message
void	setWorkerPool(edu.emory.mathcs.backport.java.util.concurrent.Executor workerPool) Set the worker thread pool

Methods inherited from class java.lang.Object

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

Method Detail

getAxisConf

public ConfigurationContext getAxisConf()

Return the Axis configuration

Returns:

the Axis configuration

setWorkerPool

public void setWorkerPool(edu.emory.mathcs.backport.java.util.concurrent.Executor workerPool)

Set the worker thread pool

Parameters:

workerPool - the worker thead pool

onMessage

public void onMessage(javax.jms.Message message)

The entry point on the recepit of each JMS message

Specified by:

onMessage in interface javax.jms.MessageListener

Parameters:

message - the JMS message received