pip_services3_messaging library
Classes
- CachedMessageQueue
- Message queue that caches received messages in memory to allow peek operations that may not be supported by the undelying queue.
- CallbackMessageReceiver
- Wraps message callback into IMessageReceiver
- DefaultMessagingFactory
- Creates MemoryMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.
- IMessageQueue
- Interface for asynchronous message queues.
- IMessageQueueConnection
- Defines an interface for message queue connections
- IMessageQueueFactory
- Creates message queue componens.
- IMessageReceiver
- Callback interface to receive incoming messages.
- LockedMessage
- Data object used to store and lock incoming messages in MemoryMessageQueue.
- MemoryMessageQueue
- Message queue that sends and receives messages within the same process by using shared memory.
- MemoryMessageQueueFactory
- Creates MemoryMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.
- MessageEnvelope
- Allows adding additional information to messages. A correlation id, message id, and a message type are added to the data being sent/received. Additionally, a MessageEnvelope can reference a lock token.
- MessageQueue
- Abstract message queue that is used as a basis for specific message queue implementations.
- MessageQueueFactory
- Creates IMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.
- MessagingCapabilities
- Data object that contains supported capabilities of a message queue. If certain capability is not supported a queue will throw NotImplemented exception.