Classes | |
class | Channel |
A Concurrency.Channels.Channel<T> implementing the IChannel<T> More... | |
class | GenericSerializer |
An IMessageSerializer<T> that uses the IO.BinaryConverter to serialze any message type. More... | |
interface | IChannel |
An Concurrency.Channels.IChannel<T> implementing the IPublisher<T> interface. More... | |
interface | IMessageQueue |
The implementor stores messages of type T. More... | |
interface | IMessageSerializer |
The implementor converts a message to a byte array and back. The IMessageSerializer<T> is used to de-/serialize messages to the TopicPublisher<T> and the TopicSubscription<T>. More... | |
interface | IPublisher |
An Concurrency.Channels.IPublisher<T> with an additional Publish method that includes a host id. The host id is included to identify and filter received messages that were sent from the same host. More... | |
class | LockedMessageQueue |
The LockedMessageQueue<T> is a thread safe extension of the MessageQueue<T>. More... | |
class | MessageQueue |
This class collects messages from a Channel<T> for later use, for example for a http client. More... | |
class | SubscriptionContainer |
A container for IChannel<T> subscriptions with a topic. More... | |
class | TopicChannel |
this class is a hybrid between TopicSubscription<T> and TopicPublishChannel<T>: it sends locally published messages through a ISocketSender and receives remote messages through the TopicMessageReceiver More... | |
class | TopicChannelFactory |
A factor for TopicChannel<T>s. More... | |
struct | TopicMessage |
This stuct is sent through the socket. More... | |
class | TopicMessageReceiver |
The TopicMessageReceiver receives TopicMessages from an ISocketReceiver. More... | |
class | TopicPublishChannel |
A Concurrency.Channels.IChannel<T> wrapper that extends class TopicPublisher<T>. More... | |
class | TopicPublisher |
This is a IPublisher<T> wrapper that sends all messages as TopicMessage to a ISocketSender. More... | |
class | TopicSubscription |
A topic subscription receives TopicMessages and filters them by a topic string. The payload of the remainging messages are deserialized with a IMessageSerializer<T> and published on a Concurrency.Channels.IPublisher<T> (typically a Concurrency.Channels.Channel<T>). More... | |