public final class InternalChannelMessageQueue
extends java.util.Observable
These messages are added by the corresponding channel upon reception from the multiplexer and processed accordingly.
Modifier and Type | Field and Description |
---|---|
private InternalChannelMessage |
m_messageQueueHead |
private InternalChannelMessage |
m_messageQueueTail |
private java.lang.Object |
m_oSync |
Constructor and Description |
---|
InternalChannelMessageQueue()
Initializes an empty queue.
|
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.
|
private InternalChannelMessage m_messageQueueHead
private InternalChannelMessage m_messageQueueTail
private java.lang.Object m_oSync
public InternalChannelMessageQueue()
public void addChannelMessage(InternalChannelMessage a_message)
a_message
- public InternalChannelMessage getFirstMessage()
public InternalChannelMessage waitForNextMessage() throws java.lang.InterruptedException
java.lang.InterruptedException
Copyright © 2023. All rights reserved.