messaging library
Messaging package
This will connect your components and services through Publisher/Subscriber pattern of messages.
Classes
- AllowedMessagingGuardResponse
- Response from guard that allows the message
- DefaultKeyResolver
- Default key resolver
- FailedPublishResult
- Result of publishing a message that failed
- GuardPublishResult
- Result of publishing a message after the guard step
- ILogger
- Logger interface
-
IterableWrapper<
T> - Wrapper class that allows to have access to specific method of an Iterable
- KeyResolver
- Class to resolve unique key
- Log
- Log utility
- LogConfig
- Configuration for log
- Message
- The base class extended by every kind of message
- MessageQueue
- Interface to access public API of the queue of messaging
- MessageState
- State of a message
- MessageStateUpdatableData
- Data of MessageState that can be updated
- MessageStore
- An interface to access public APIs of the store of messages
- Messaging
- Pub/Sub messaging handler that allows to publish and subscribe to message from anywhere in your app.
- MessagingGuard
- Messaging guard that check if the message can be published
- MessagingGuardResponse
- A response from guard
- MessagingMemoryStore
- Implementation of MessagingStore that saved messages in memory
- MessagingObserver
- Observer that is notified in every lifecycle of the message
- MessagingQueue
- A queue that store all message keys
- MessagingQueueDispatcher
- Dispatcher that will dispatch message key
- MessagingStore
- A store to save the messages temporarily or forever
- MessagingSubscriber
- Component or service that is notified when a message it subscribed is published.
- NotAllowedMessagingGuardResponse
- Response from guard that doesn't allow the message
- OneShotMessagingGuard
- A guard that will not allowed message that was already published.
- PublishResult
- Result of publishing a message
-
QueueItem<
S> - Item of queue
- SyncMessagingQueue
- A message queue that dispatch a new key directly when it is added
- TimerMessagingQueue
- A message queue that dispatch a new key every timing.
- ToggableLog
- Log that can be toggable
- UniqueDependantMessagingGuard
- A guard that will not allowed message that was already published until another one is published.
Enums
- LogLevel
- Level of log to show
- MessageStateType
- Type of state of a message during its lifecycle
- MessagingState
- The state of the messaging instance
- PublishNowErrorHandlingStrategy
- Strategy to apply when error occurred during publish/dispatch now
- ResumeQueueStrategy
- Strategy to apply when the queue is resumed
Typedefs
- MessagingQueueFactory = MessagingQueue Function(MessagingQueueDispatcher dispatcher)
- A factory that allows to create a MessagingQueue