org.exolab.jms.client
Class JmsServerSession

java.lang.Object
  |
  +--org.exolab.jms.client.JmsServerSession

All Implemented Interfaces:

java.lang.Runnable, javax.jms.ServerSession, javax.jms.Session

public class JmsServerSession

extends java.lang.Object

implements javax.jms.ServerSession, javax.jms.Session

This class maps a server session to a corresponding thread and is used to deliver messages to a corresponding client. This is an application server class.

The ConnectionConsumer is responsible for requesitng a server session from the ServerSessionPool, loading it with messages and then calling the start method to process them.

This class also implements the Session interface since it behaves distinctly from other Session object (i.e TopicSession etc).

Version:

$Revision: 1.5 $ $Date: 2003/08/07 13:32:50 $

Author:

Jim Alateras, Tim Anderson

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE

Method Summary

void	close()
void	commit()
javax.jms.BytesMessage	createBytesMessage()
javax.jms.MapMessage	createMapMessage()
javax.jms.Message	createMessage()
javax.jms.ObjectMessage	createObjectMessage()
javax.jms.ObjectMessage	createObjectMessage(java.io.Serializable object)
javax.jms.StreamMessage	createStreamMessage()
javax.jms.TextMessage	createTextMessage()
javax.jms.TextMessage	createTextMessage(java.lang.String text)
javax.jms.MessageListener	getMessageListener() Return a reference to the message listener
javax.jms.Session	getSession()
boolean	getTransacted()
void	recover()
void	rollback()
void	run() Only intended to be used by Application Servers (optional operation).
void	setMessageListener(javax.jms.MessageListener listener) Set the message listener for this server session.
void	start()

Methods inherited from class java.lang.Object

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

Method Detail

getSession

public javax.jms.Session getSession()
                             throws javax.jms.JMSException

Specified by:

getSession in interface javax.jms.ServerSession

start

public void start()
           throws javax.jms.JMSException

Specified by:

start in interface javax.jms.ServerSession

createBytesMessage

public javax.jms.BytesMessage createBytesMessage()
                                          throws javax.jms.JMSException

Specified by:

createBytesMessage in interface javax.jms.Session

createMapMessage

public javax.jms.MapMessage createMapMessage()
                                      throws javax.jms.JMSException

Specified by:

createMapMessage in interface javax.jms.Session

createMessage

public javax.jms.Message createMessage()
                                throws javax.jms.JMSException

Specified by:

createMessage in interface javax.jms.Session

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage()
                                            throws javax.jms.JMSException

Specified by:

createObjectMessage in interface javax.jms.Session

createObjectMessage

public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable object)
                                            throws javax.jms.JMSException

Specified by:

createObjectMessage in interface javax.jms.Session

createStreamMessage

public javax.jms.StreamMessage createStreamMessage()
                                            throws javax.jms.JMSException

Specified by:

createStreamMessage in interface javax.jms.Session

createTextMessage

public javax.jms.TextMessage createTextMessage()
                                        throws javax.jms.JMSException

Specified by:

createTextMessage in interface javax.jms.Session

createTextMessage

public javax.jms.TextMessage createTextMessage(java.lang.String text)
                                        throws javax.jms.JMSException

Specified by:

createTextMessage in interface javax.jms.Session

getTransacted

public boolean getTransacted()
                      throws javax.jms.JMSException

Specified by:

getTransacted in interface javax.jms.Session

commit

public void commit()
            throws javax.jms.JMSException

Specified by:

commit in interface javax.jms.Session

rollback

public void rollback()
              throws javax.jms.JMSException

Specified by:

rollback in interface javax.jms.Session

close

public void close()
           throws javax.jms.JMSException

Specified by:

close in interface javax.jms.Session

recover

public void recover()
             throws javax.jms.JMSException

Specified by:

recover in interface javax.jms.Session

run

public void run()

Only intended to be used by Application Servers (optional operation).

Specified by:

run in interface javax.jms.Session

See Also:

ServerSession

setMessageListener

public void setMessageListener(javax.jms.MessageListener listener)

Set the message listener for this server session. This should be part of the set up procedure, before the start method is called.

Specified by:

setMessageListener in interface javax.jms.Session

Parameters:

listener - message listener

getMessageListener

public javax.jms.MessageListener getMessageListener()

Return a reference to the message listener

Specified by:

getMessageListener in interface javax.jms.Session

Returns:

MessageListener