|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.atomikos.jms.MessageConsumerSession
public abstract class MessageConsumerSession
Copyright © 2006, Atomikos. All rights reserved. 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. |
Destination |
getDestination()
Gets the destination. |
ExceptionListener |
getExceptionListener()
Gets the exception listener (if any). |
MessageListener |
getMessageListener()
Get the message listener of this session, if any. |
String |
getMessageSelector()
Get the message selector (if any) |
boolean |
getNotifyListenerOnClose()
Check wether the session is configured to notify the listener upon close. |
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(Destination destination)
Sets the destination to listen on. |
void |
setExceptionListener(ExceptionListener exceptionListener)
Sets the exception listener. |
void |
setMessageListener(MessageListener listener)
Set the message listener for this session. |
void |
setMessageSelector(String selector)
Set the message selector to use. |
void |
setNotifyListenerOnClose(boolean b)
Set whether the listener should be notified on close. |
void |
setPassword(String password)
Set the password to use for connecting. |
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 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 Destination getDestination()
public void setDestination(Destination destination)
destination
- public void setTransactionTimeout(int seconds)
seconds
- The timeout for transactions started by the session.public int getTransactionTimeout()
public void setMessageListener(MessageListener listener)
listener
- public MessageListener getMessageListener()
public void startListening() throws JMSException, SystemException
JMSException
SystemException
protected void startNewThread()
public void stopListening()
public boolean getNotifyListenerOnClose()
public void setNotifyListenerOnClose(boolean b)
b
- public ExceptionListener getExceptionListener()
public void setExceptionListener(ExceptionListener exceptionListener)
exceptionListener
-
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |