public class ServiceTaskManager extends Object
Constructor and Description |
---|
ServiceTaskManager() |
Modifier and Type | Method and Description |
---|---|
void |
addJmsProperties(Map<String,String> jmsProperties) |
int |
getActiveTaskCount() |
int |
getCacheLevel() |
int |
getConcurrentConsumers() |
ConnectionFactory |
getConnectionFactory() |
String |
getConnFactoryJNDIName() |
int |
getConsumerCount()
Get the number of existing JMS message consumers.
|
Context |
getContext() |
String |
getDestinationJNDIName() |
int |
getDestinationType() |
String |
getDurableSubscriberName() |
int |
getIdleTaskExecutionLimit() |
int |
getInitialReconnectDuration() |
Hashtable<String,String> |
getJmsProperties() |
int |
getMaxConcurrentConsumers() |
int |
getMaxMessagesPerTask() |
long |
getMaxReconnectDuration() |
String |
getMessageSelector() |
List<org.apache.axis2.transport.jms.ServiceTaskManager.MessageListenerTask> |
getPollingTasks() |
int |
getReceiveTimeout() |
double |
getReconnectionProgressionFactor() |
String |
getServiceName() |
int |
getSessionAckMode() |
int |
getTransactionality() |
String |
getUserTransactionJNDIName() |
boolean |
isCacheUserTransaction() |
boolean |
isJmsSpec11() |
boolean |
isPubSubNoLocal() |
boolean |
isSessionTransacted() |
boolean |
isSubscriptionDurable() |
void |
pause()
Temporarily suspend receipt and processing of messages.
|
void |
removeJmsProperties(String key) |
void |
resume()
Resume receipt and processing of messages of paused tasks
|
void |
setCacheLevel(int cacheLevel) |
void |
setCacheUserTransaction(Boolean cacheUserTransaction) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConnFactoryJNDIName(String connFactoryJNDIName) |
void |
setDestinationJNDIName(String destinationJNDIName) |
void |
setDestinationType(int destinationType) |
void |
setDurableSubscriberName(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(String messageSelector) |
void |
setPubSubNoLocal(Boolean pubSubNoLocal) |
void |
setReceiveTimeout(int receiveTimeout) |
void |
setReconnectionProgressionFactor(double reconnectionProgressionFactor) |
void |
setServiceName(String serviceName) |
void |
setServiceTaskManagerState(int serviceTaskManagerState) |
void |
setSessionAckMode(int sessionAckMode) |
void |
setSessionTransacted(Boolean sessionTransacted) |
void |
setSubscriptionDurable(Boolean subscriptionDurable) |
void |
setTransactionality(int transactionality) |
void |
setUserTransactionJNDIName(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
|
public void start()
public void stop()
public void pause()
public void resume()
public String getServiceName()
public void setServiceName(String serviceName)
public String getConnFactoryJNDIName()
public void setConnFactoryJNDIName(String connFactoryJNDIName)
public String getDestinationJNDIName()
public void setDestinationJNDIName(String destinationJNDIName)
public int getDestinationType()
public void setDestinationType(int destinationType)
public String getMessageSelector()
public void setMessageSelector(String messageSelector)
public int getTransactionality()
public void setTransactionality(int transactionality)
public boolean isSessionTransacted()
public void setSessionTransacted(Boolean sessionTransacted)
public int getSessionAckMode()
public void setSessionAckMode(int sessionAckMode)
public boolean isSubscriptionDurable()
public void setSubscriptionDurable(Boolean subscriptionDurable)
public String getDurableSubscriberName()
public void setDurableSubscriberName(String durableSubscriberName)
public boolean isPubSubNoLocal()
public void setPubSubNoLocal(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 String getUserTransactionJNDIName()
public void setUserTransactionJNDIName(String userTransactionJNDIName)
public boolean isCacheUserTransaction()
public void setCacheUserTransaction(Boolean cacheUserTransaction)
public boolean isJmsSpec11()
public void setJmsSpec11(boolean jmsSpec11)
public void removeJmsProperties(String key)
public Context getContext()
public ConnectionFactory getConnectionFactory()
public List<org.apache.axis2.transport.jms.ServiceTaskManager.MessageListenerTask> getPollingTasks()
public void setJmsMessageReceiver(JMSMessageReceiver jmsMessageReceiver)
public void setWorkerPool(WorkerPool workerPool)
public int getActiveTaskCount()
public int getConsumerCount()
public void setServiceTaskManagerState(int serviceTaskManagerState)
Copyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.