com.maverick.ssh.message

Class SshMessageStore

java.lang.Object

com.maverick.ssh.message.SshMessageStore

All Implemented Interfaces:

MessageStore

public class SshMessageStore
extends Object
implements MessageStore

This class is the central storage location for channel messages; each channel has its own message store and the message pump delivers them here where they are stored in a lightweight linked list.

Author:

Lee David Painter

Field Summary

Fields

Modifier and Type	Field and Description
static int	NO_MESSAGES

Constructor Summary

Constructors

Constructor and Description
SshMessageStore(SshMessageRouter manager, SshAbstractChannel channel, MessageObserver stickyMessageObserver)

Method Summary

Modifier and Type	Method and Description
void	close()
Thread	getBlockingThread()
boolean	hasBlockingThread()
Message	hasMessage(MessageObserver observer)
boolean	isClosed()
SshMessage	nextMessage(MessageObserver observer, long timeout)

Methods inherited from class java.lang.Object

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

Field Detail

NO_MESSAGES

public static final int NO_MESSAGES

See Also:

Constant Field Values

Constructor Detail

SshMessageStore

public SshMessageStore(SshMessageRouter manager,
                       SshAbstractChannel channel,
                       MessageObserver stickyMessageObserver)

Method Detail

nextMessage

public SshMessage nextMessage(MessageObserver observer,
                              long timeout)
                       throws SshException,
                              EOFException

Parameters:

messagefilter -

timeout -

Returns:

SshMessage

Throws:

IOException

InterruptedIOException

SshException

EOFException

isClosed

public boolean isClosed()

hasMessage

public Message hasMessage(MessageObserver observer)

Specified by:

hasMessage in interface MessageStore

close

public void close()

hasBlockingThread

public boolean hasBlockingThread()

getBlockingThread

public Thread getBlockingThread()