org.rvpf.som.queue

Class ReceiverSessionImpl

Object

SessionImpl

ExportedSessionImpl

SOMSessionImpl

ReceiverSessionImpl

All Implemented Interfaces:

Remote, Unreferenced, Session, ReceiverSession, SOMSession

public class ReceiverSessionImpl
extends SOMSessionImpl
implements ReceiverSession

Receiver session implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface Session

Session.ConnectionMode

Method Summary

Modifier and Type	Method and Description
void	close() Closes the session.
void	commit() Commits uncommitted messages.
protected String	getType() Gets the session type.
long	purge() Purges the queue.
Serializable[]	receive(int limit, long timeout) Receives messages.
void	rollback() Rolls back uncommitted messages.

Methods inherited from class SOMSessionImpl

adjustTimeout, toString

Methods inherited from class ExportedSessionImpl

equals, hashCode, open

Methods inherited from class SessionImpl

getClientName, getConnectionMode, getIdentity, getSessionFactory, getThisLogger, getUser, isClosed, login, logout, open, securityCheck, setLogID, setUser, unreferenced

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface Session

getConnectionMode, login, logout

Method Detail

close

public void close()

Closes the session.

Specified by:

close in interface SOMSession

Overrides:

close in class ExportedSessionImpl

commit

public void commit()
            throws SessionException

Commits uncommitted messages.

Specified by:

commit in interface ReceiverSession

Throws:

SessionException - From session security check.

purge

public long purge()
           throws SessionException

Purges the queue.

Specified by:

purge in interface ReceiverSession

Returns:

The number of messages purged.

Throws:

SessionException - From session security check.

receive

public Serializable[] receive(int limit,
                              long timeout)
                       throws SessionException

Receives messages.

Specified by:

receive in interface ReceiverSession

Parameters:

limit - The maximum number of messages.

timeout - A time limit in millis to wait for the first message (negative for infinite).

Returns:

The messages.

Throws:

SessionException - From session security check.

rollback

public void rollback()
              throws SessionException

Rolls back uncommitted messages.

Specified by:

rollback in interface ReceiverSession

Throws:

SessionException - From session security check.

getType

protected String getType()

Gets the session type.

Specified by:

getType in class SOMSessionImpl

Returns:

The session type.