-
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. |