Namespace LfrlAnvil.MessageBroker.Client
Classes
- MessageBrokerClient
Represents a message broker client.
- MessageBrokerListener
Represents a message broker listener, which allows the client to react to messages published to the related channel.
- MessageBrokerPublisher
Represents a message broker listener, which allows the client to publish messages to the related channel.
- MessageBrokerPushContext
Represents an object that can push a single message to the server, with access to the client's internal memory pool, which allows to efficiently buffer data to be sent.
Structs
- MessageBrokerBindListenerResult
Represents the result of binding a client to a channel as a listener.
- MessageBrokerBindPublisherResult
Represents the result of binding a client to a channel as a publisher.
- MessageBrokerClientNetworkPacketOptions
Represents available network packet options during MessageBrokerClient creation.
- MessageBrokerClientOptions
Represents available MessageBrokerClient creation options.
- MessageBrokerClientRoutingTarget
Represents a message routing target, based on either a target client id or name.
- MessageBrokerClientTcpOptions
Represents available TcpClient options during MessageBrokerClient creation.
- MessageBrokerDeadLetterQueryResult
Represents the result of a dead letter query.
- MessageBrokerExternalObject
Represents basic information about a server-side message broker object.
- MessageBrokerListenerCallbackArgs
Represents a set of attributes that defines a single message received from the server.
- MessageBrokerListenerCollection
Represents a collection of MessageBrokerListener instances.
- MessageBrokerListenerOptions
Represents available MessageBrokerListener options during its binding.
- MessageBrokerNegativeAck
Represents available negative ACK options.
- MessageBrokerPublisherCollection
Represents a collection of MessageBrokerPublisher instances.
- MessageBrokerPushMessageFinalizer
Represents an object capable of finalizing the process of pushing previously enqueued message to the server.
- MessageBrokerPushResult
Represents the result of pushing a message to a channel.
- MessageBrokerUnbindListenerResult
Represents the result of unbinding a client from a channel as a listener.
- MessageBrokerUnbindPublisherResult
Represents the result of unbinding a client from a channel as a publisher.
Enums
- MessageBrokerClientState
Defines possible MessageBrokerClient states.
- MessageBrokerListenerState
Defines possible MessageBrokerListener states.
- MessageBrokerPublisherState
Defines possible MessageBrokerPublisher states.
Delegates
- MessageBrokerClientStreamDecorator
Represents a callback which allows to decorate MessageBrokerClient's network stream.
Owner of thestream.NetworkStream to decorate.CancellationToken instance.A ValueTask<TResult> which returns a stream, that will be used by the client.
- MessageBrokerListenerCallback
Represents an asynchronous callback invoked when a MessageBrokerListener receives a message from the server.