|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.atomikos.jms.MessageConsumerSession
public abstract class MessageConsumerSession
Common message-driven session functionality.
Field Summary | |
---|---|
protected Thread |
current
|
Constructor Summary | |
---|---|
protected |
MessageConsumerSession()
|
Method Summary | |
---|---|
protected AbstractConnectionFactoryBean |
getAbstractConnectionFactoryBean()
|
boolean |
getDaemonThreads()
Tests whether threads are daemon threads. |
javax.jms.Destination |
getDestination()
Gets the destination. |
protected abstract String |
getDestinationName()
|
javax.jms.ExceptionListener |
getExceptionListener()
Gets the exception listener (if any). |
javax.jms.MessageListener |
getMessageListener()
Get the message listener of this session, if any. |
String |
getMessageSelector()
Get the message selector (if any) |
protected abstract boolean |
getNoLocal()
|
boolean |
getNotifyListenerOnClose()
Check wether the session is configured to notify the listener upon close. |
protected abstract String |
getSubscriberName()
|
int |
getTransactionTimeout()
Get the transaction timeout in seconds. |
String |
getUser()
Get the user to connect with. |
protected void |
setAbstractConnectionFactoryBean(AbstractConnectionFactoryBean bean)
|
void |
setDaemonThreads(boolean value)
Sets whether threads should be daemon threads or not. |
void |
setDestination(javax.jms.Destination destination)
Sets the destination to listen on. |
void |
setExceptionListener(javax.jms.ExceptionListener exceptionListener)
Sets the exception listener. |
void |
setMessageListener(javax.jms.MessageListener listener)
Set the message listener for this session. |
void |
setMessageSelector(String selector)
Set the message selector to use. |
protected abstract void |
setNoLocal(boolean value)
|
void |
setNotifyListenerOnClose(boolean b)
Set whether the listener should be notified on close. |
void |
setPassword(String password)
Set the password to use for connecting. |
protected abstract void |
setSubscriberName(String name)
|
void |
setTransactionTimeout(int seconds)
Set the transaction timeout, after which long transactions are rolled back automatically. |
void |
setUser(String user)
Set the user to create connections with. |
void |
startListening()
Start listening for messages. |
protected void |
startNewThread()
|
void |
stopListening()
Stop listening for messages. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected transient Thread current
Constructor Detail |
---|
protected MessageConsumerSession()
Method Detail |
---|
protected abstract String getSubscriberName()
protected abstract void setSubscriberName(String name)
protected abstract void setNoLocal(boolean value)
protected abstract boolean getNoLocal()
protected void setAbstractConnectionFactoryBean(AbstractConnectionFactoryBean bean)
protected AbstractConnectionFactoryBean getAbstractConnectionFactoryBean()
public void setDaemonThreads(boolean value)
value
- If true then threads will be daemon threads.public boolean getDaemonThreads()
public String getMessageSelector()
public void setMessageSelector(String selector)
selector
- public void setUser(String user)
user
- public String getUser()
public void setPassword(String password)
password
- public javax.jms.Destination getDestination()
public void setDestination(javax.jms.Destination destination)
destination
- public void setTransactionTimeout(int seconds)
seconds
- The timeout for transactions started by the session.public int getTransactionTimeout()
public void setMessageListener(javax.jms.MessageListener listener)
listener
- public javax.jms.MessageListener getMessageListener()
public void startListening() throws javax.jms.JMSException, SystemException
javax.jms.JMSException
SystemException
protected abstract String getDestinationName()
protected void startNewThread()
public void stopListening()
public boolean getNotifyListenerOnClose()
public void setNotifyListenerOnClose(boolean b)
b
- public javax.jms.ExceptionListener getExceptionListener()
public void setExceptionListener(javax.jms.ExceptionListener exceptionListener)
exceptionListener
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |