|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.axis2.transport.jms.ServiceTaskManager
public class ServiceTaskManager
Each service will have one ServiceTaskManager instance that will create, manage and also destroy idle tasks created for it, for message receipt. This will also allow individual tasks to cache the Connection, Session or Consumer as necessary, considering the transactionality required and user preference. This also acts as the ExceptionListener for all JMS connections made on behalf of the service. Since the ExceptionListener is notified by a JMS provider on a "serious" error, we simply try to re-connect. Thus a connection failure for a single task, will re-initialize the state afresh for the service, by discarding all connections.
Constructor Summary | |
---|---|
ServiceTaskManager()
|
Method Summary | |
---|---|
void |
addJmsProperties(java.util.Map<java.lang.String,java.lang.String> jmsProperties)
|
int |
getActiveTaskCount()
|
int |
getCacheLevel()
|
int |
getConcurrentConsumers()
|
javax.jms.ConnectionFactory |
getConnectionFactory()
|
java.lang.String |
getConnFactoryJNDIName()
|
javax.naming.Context |
getContext()
|
java.lang.String |
getDestinationJNDIName()
|
int |
getDestinationType()
|
java.lang.String |
getDurableSubscriberName()
|
int |
getIdleTaskExecutionLimit()
|
int |
getInitialReconnectDuration()
|
java.util.Hashtable<java.lang.String,java.lang.String> |
getJmsProperties()
|
int |
getMaxConcurrentConsumers()
|
int |
getMaxMessagesPerTask()
|
long |
getMaxReconnectDuration()
|
java.lang.String |
getMessageSelector()
|
java.util.List<org.apache.axis2.transport.jms.ServiceTaskManager.MessageListenerTask> |
getPollingTasks()
|
int |
getReceiveTimeout()
|
double |
getReconnectionProgressionFactor()
|
java.lang.String |
getServiceName()
|
int |
getSessionAckMode()
|
int |
getTransactionality()
|
java.lang.String |
getUserTransactionJNDIName()
|
boolean |
isCacheUserTransaction()
|
boolean |
isJmsSpec11()
|
boolean |
isPubSubNoLocal()
|
boolean |
isSessionTransacted()
|
boolean |
isSubscriptionDurable()
|
void |
pause()
Temporarily suspend receipt and processing of messages. |
void |
removeJmsProperties(java.lang.String key)
|
void |
resume()
Resume receipt and processing of messages of paused tasks |
void |
setCacheLevel(int cacheLevel)
|
void |
setCacheUserTransaction(java.lang.Boolean cacheUserTransaction)
|
void |
setConcurrentConsumers(int concurrentConsumers)
|
void |
setConnFactoryJNDIName(java.lang.String connFactoryJNDIName)
|
void |
setDestinationJNDIName(java.lang.String destinationJNDIName)
|
void |
setDestinationType(int destinationType)
|
void |
setDurableSubscriberName(java.lang.String durableSubscriberName)
|
void |
setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
|
void |
setInitialReconnectDuration(int initialReconnectDuration)
|
void |
setJmsMessageReceiver(JMSMessageReceiver jmsMessageReceiver)
|
void |
setJmsSpec11(boolean jmsSpec11)
|
void |
setMaxConcurrentConsumers(int maxConcurrentConsumers)
|
void |
setMaxMessagesPerTask(int maxMessagesPerTask)
|
void |
setMaxReconnectDuration(long maxReconnectDuration)
|
void |
setMessageSelector(java.lang.String messageSelector)
|
void |
setPubSubNoLocal(java.lang.Boolean pubSubNoLocal)
|
void |
setReceiveTimeout(int receiveTimeout)
|
void |
setReconnectionProgressionFactor(double reconnectionProgressionFactor)
|
void |
setServiceName(java.lang.String serviceName)
|
void |
setServiceTaskManagerState(int serviceTaskManagerState)
|
void |
setSessionAckMode(int sessionAckMode)
|
void |
setSessionTransacted(java.lang.Boolean sessionTransacted)
|
void |
setSubscriptionDurable(java.lang.Boolean subscriptionDurable)
|
void |
setTransactionality(int transactionality)
|
void |
setUserTransactionJNDIName(java.lang.String userTransactionJNDIName)
|
void |
setWorkerPool(WorkerPool workerPool)
|
void |
start()
Start or re-start the Task Manager by shutting down any existing worker tasks and re-creating them. |
void |
stop()
Shutdown the tasks and release any shared resources |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ServiceTaskManager()
Method Detail |
---|
public void start()
public void stop()
public void pause()
public void resume()
public java.lang.String getServiceName()
public void setServiceName(java.lang.String serviceName)
public java.lang.String getConnFactoryJNDIName()
public void setConnFactoryJNDIName(java.lang.String connFactoryJNDIName)
public java.lang.String getDestinationJNDIName()
public void setDestinationJNDIName(java.lang.String destinationJNDIName)
public int getDestinationType()
public void setDestinationType(int destinationType)
public java.lang.String getMessageSelector()
public void setMessageSelector(java.lang.String messageSelector)
public int getTransactionality()
public void setTransactionality(int transactionality)
public boolean isSessionTransacted()
public void setSessionTransacted(java.lang.Boolean sessionTransacted)
public int getSessionAckMode()
public void setSessionAckMode(int sessionAckMode)
public boolean isSubscriptionDurable()
public void setSubscriptionDurable(java.lang.Boolean subscriptionDurable)
public java.lang.String getDurableSubscriberName()
public void setDurableSubscriberName(java.lang.String durableSubscriberName)
public boolean isPubSubNoLocal()
public void setPubSubNoLocal(java.lang.Boolean pubSubNoLocal)
public int getConcurrentConsumers()
public void setConcurrentConsumers(int concurrentConsumers)
public int getMaxConcurrentConsumers()
public void setMaxConcurrentConsumers(int maxConcurrentConsumers)
public int getIdleTaskExecutionLimit()
public void setIdleTaskExecutionLimit(int idleTaskExecutionLimit)
public int getReceiveTimeout()
public void setReceiveTimeout(int receiveTimeout)
public int getCacheLevel()
public void setCacheLevel(int cacheLevel)
public int getInitialReconnectDuration()
public void setInitialReconnectDuration(int initialReconnectDuration)
public double getReconnectionProgressionFactor()
public void setReconnectionProgressionFactor(double reconnectionProgressionFactor)
public long getMaxReconnectDuration()
public void setMaxReconnectDuration(long maxReconnectDuration)
public int getMaxMessagesPerTask()
public void setMaxMessagesPerTask(int maxMessagesPerTask)
public java.lang.String getUserTransactionJNDIName()
public void setUserTransactionJNDIName(java.lang.String userTransactionJNDIName)
public boolean isCacheUserTransaction()
public void setCacheUserTransaction(java.lang.Boolean cacheUserTransaction)
public boolean isJmsSpec11()
public void setJmsSpec11(boolean jmsSpec11)
public java.util.Hashtable<java.lang.String,java.lang.String> getJmsProperties()
public void addJmsProperties(java.util.Map<java.lang.String,java.lang.String> jmsProperties)
public void removeJmsProperties(java.lang.String key)
public javax.naming.Context getContext()
public javax.jms.ConnectionFactory getConnectionFactory()
public java.util.List<org.apache.axis2.transport.jms.ServiceTaskManager.MessageListenerTask> getPollingTasks()
public void setJmsMessageReceiver(JMSMessageReceiver jmsMessageReceiver)
public void setWorkerPool(WorkerPool workerPool)
public int getActiveTaskCount()
public void setServiceTaskManagerState(int serviceTaskManagerState)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |