anon.client

Class InternalChannelMessageQueue

java.lang.Object

java.util.Observable

anon.client.InternalChannelMessageQueue

public final class InternalChannelMessageQueue
extends java.util.Observable

This class holds messages, that are channel specific and distinct from the user traffic, i. e. a message signaling the closing of the channel.

These messages are added by the corresponding channel upon reception from the multiplexer and processed accordingly.

Author:

Stefan Lieske

Field Summary

Fields

Modifier and Type	Field and Description
private InternalChannelMessage	m_messageQueueHead
private InternalChannelMessage	m_messageQueueTail
private java.lang.Object	m_oSync

Constructor Summary

Constructors

Constructor and Description
InternalChannelMessageQueue() Initializes an empty queue.

Method Summary

Modifier and Type	Method and Description
void	addChannelMessage(InternalChannelMessage a_message) Adds (only) the given message to the tail of the queue and notify all observers.
InternalChannelMessage	getFirstMessage() Returns the next message without removing it.
InternalChannelMessage	waitForNextMessage() This method will return the current message queue head.

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Field Detail

m_messageQueueHead

private InternalChannelMessage m_messageQueueHead

m_messageQueueTail

private InternalChannelMessage m_messageQueueTail

m_oSync

private java.lang.Object m_oSync

Constructor Detail

InternalChannelMessageQueue

public InternalChannelMessageQueue()

Initializes an empty queue.

Method Detail

addChannelMessage

public void addChannelMessage(InternalChannelMessage a_message)

Adds (only) the given message to the tail of the queue and notify all observers.

Parameters:

a_message -

getFirstMessage

public InternalChannelMessage getFirstMessage()

Returns the next message without removing it.

Returns:

the next message, may be null

waitForNextMessage

public InternalChannelMessage waitForNextMessage()
                                          throws java.lang.InterruptedException

This method will return the current message queue head. If there is no message to return this method will block until a message is available or an exception is thrown. The message is removed from the queue.

Returns:

internal channel message

Throws:

java.lang.InterruptedException