-
Notifications
You must be signed in to change notification settings - Fork 2
MessageQueue Class
sequenze edited this page Jun 19, 2017
·
3 revisions
A threadsafe data structure that facilitates message parsing. It allows threads to wait and signal through querying specific messages similar to that of the tuplespace datastructure.
Object
internal sealed class MessageQueue
Name | Description |
---|---|
MessageQueue() | Initializes a new instance of the MessageQueue class. |
Name | Description |
---|---|
Get(String) | Blocks the calling thread until a message arrives with a matching sessions id. The message is returned once it arrives. If the message already exists, the message is dequeued and returned. |
Put(IMessage) | Inserts a message into the underlying set, thereby awaking any waiting threads. |