- Fixed thread safety for CachedMessageQueue, MemoryMessageQueue
- fixed imports in tests
- Added connect and test package
- Update MemoryMessageQueue
- To build added IMessageQueueFactory, MessageQueueFactory
- To queues added CachedMessageQueue, CallbackMessageReceiver, LockedMessage
- Added type hints
- Update MessageEnvelope
- MessageQueue added abstract methods:
- _check_open
- is_open
- close
- clear
- read_message_count
- send methods
- peek
- peek_batch
- receive
- renew_lock
- complete
- abandon
- move_to_dead_letter
- listen
- end_listen
- fixed imports in tests
Initial public release
- Build - message queues factories
- Queues - asynchronous message queues