Namespace LfrlAnvil.MessageBroker.Server
Classes
- MessageBrokerChannel
Represents a message broker channel, which allows clients to bind to it as either a publisher or a listener.
- MessageBrokerChannelListenerBinding
Represents a message broker channel binding for a listener, which allows clients to listen to messages published through channels.
- MessageBrokerChannelPublisherBinding
Represents a message broker channel binding for a publisher, which allows clients to publish messages through channels.
- MessageBrokerQueue
Represents a message broker queue, which allows a single MessageBrokerRemoteClient instance to manage the order of message notifications between multiple listeners, sent by the server.
- MessageBrokerRemoteClient
Represents a remote message broker client.
- MessageBrokerRemoteClientConnector
Represents a remote message broker client connector.
- MessageBrokerServer
Represents a message broker server.
- MessageBrokerStream
Represents a message broker stream, which allows MessageBrokerChannelPublisherBinding instances to push messages in order to be processed and moved to relevant MessageBrokerChannelListenerBinding instances.
Structs
- MessageBrokerChannelCollection
Represents a collection of MessageBrokerChannel instances.
- MessageBrokerChannelListenerBindingCollection
Represents a collection of MessageBrokerChannelListenerBinding instances attached to a single channel, identified by client ids.
- MessageBrokerChannelPublisherBindingCollection
Represents a collection of MessageBrokerChannelPublisherBinding instances attached to a single channel, identified by client ids.
- MessageBrokerFilterExpressionContext
Represents a context for a single message filter predicate applied by a MessageBrokerChannelListenerBinding.
- MessageBrokerFilterExpressionContext.Span
Represents binary message data.
- MessageBrokerQueueDeadLetterMessage
Represents a snapshot of a dead letter message stored by a MessageBrokerQueue.
- MessageBrokerQueueDeadLetterMessageCollection
Represents a collection of dead letter messages stored in a MessageBrokerQueue.
- MessageBrokerQueueListenerCollection
Represents a collection of MessageBrokerChannelListenerBinding instances attached to a single queue, identified by channel ids.
- MessageBrokerQueueMessageCollection
Represents a collection of messages stored in a MessageBrokerQueue.
- MessageBrokerQueueMessageRetriesCollection
Collection of scheduled message retries stored in a MessageBrokerQueue.
- MessageBrokerQueueMessageRetry
Represents a snapshot of a scheduled message retry stored by a MessageBrokerQueue.
- MessageBrokerQueuePendingMessage
Represents a snapshot of a pending message stored by a MessageBrokerQueue.
- MessageBrokerQueuePendingMessageCollection
Represents a collection of pending messages stored in a MessageBrokerQueue.
- MessageBrokerQueueUnackedMessage
Represents a snapshot of an unacked message stored by a MessageBrokerQueue.
- MessageBrokerQueueUnackedMessageCollection
Represents a collection of unacked messages stored in a MessageBrokerQueue.
- MessageBrokerRemoteClientCollection
Represents a collection of MessageBrokerRemoteClient instances.
- MessageBrokerRemoteClientConnectorCollection
Represents a collection of MessageBrokerRemoteClientConnector instances.
- MessageBrokerRemoteClientListenerCollection
Represents a collection of MessageBrokerChannelListenerBinding instances attached to a single client, identified by channel ids.
- MessageBrokerRemoteClientPublisherCollection
Represents a collection of MessageBrokerChannelPublisherBinding instances attached to a single client, identified by channel ids.
- MessageBrokerRemoteClientQueueCollection
Represents a collection of MessageBrokerQueue instances attached to a single client, identified by their names.
- MessageBrokerServerNetworkPacketOptions
Represents available network packet options during MessageBrokerServer creation.
- MessageBrokerServerOptions
Represents available MessageBrokerServer creation options.
- MessageBrokerServerTcpOptions
Represents available TcpClient options during MessageBrokerServer creation.
- MessageBrokerStreamCollection
Represents a collection of MessageBrokerStream instances.
- MessageBrokerStreamMessage
Represents a snapshot of a message stored by a MessageBrokerStream.
- MessageBrokerStreamMessageCollection
Represents a collection of messages stored in a MessageBrokerStream.
- MessageBrokerStreamPublisherCollection
Represents a collection of MessageBrokerChannelPublisherBinding instances attached to a single stream, identified by (client-id, channel-id) tuples.
Interfaces
- IMessageBrokerMessagePublisher
Represents a message publisher.
Enums
- MessageBrokerChannelListenerBindingState
Defines possible MessageBrokerChannelListenerBinding states.
- MessageBrokerChannelPublisherBindingState
Defines possible MessageBrokerChannelPublisherBinding states.
- MessageBrokerChannelState
Defines possible MessageBrokerChannel states.
- MessageBrokerQueueState
Defines possible MessageBrokerQueue states.
- MessageBrokerRemoteClientConnectorState
Defines possible MessageBrokerRemoteClientConnector states.
- MessageBrokerRemoteClientState
Defines possible MessageBrokerRemoteClient states.
- MessageBrokerServerState
Defines possible MessageBrokerServer states.
- MessageBrokerStreamState
Defines possible MessageBrokerStream states.
Delegates
- MessageBrokerRemoteClientStreamDecorator
Represents a callback which allows to decorate MessageBrokerRemoteClientConnector's network stream, which will also be used by a MessageBrokerRemoteClient.
Owner of thestream.NetworkStream to decorate.A ValueTask<TResult> which returns a stream, that will be used by the connector.