broker library
Message Broker
Classes
- AmqpBrokerService
- Implements BrokerService as an AMQP client using dart_amqp lib.
- BrokerExchange
- BrokerMessage
- BrokerMessageProperties
- BrokerQueue
- BrokerService
- Interface for message broker connections.
-
EphemeralHubEventSocket<
T> - HubEventSocket for ephemeral event messages.
- EventHubService
-
HubConsumerService<
THub extends EventHubService> - A service consuming and processing EventHub events.
-
HubEvent<
T> -
HubEventSocket<
T> - HubEventSocket for eventual consistent messages.
-
HubSocket<
T>
Enums
Exceptions / Errors
- ConsumerException
- Exception can be used to control message ack behaviour.