Skip to content
This repository was archived by the owner on Jun 16, 2022. It is now read-only.

Dtronix Message Queue v0.9 Released

Pre-release
Pre-release

Choose a tag to compare

View all tags
@DJGosnell DJGosnell released this 14 Sep 21:50
· 189 commits to master since this release
v0.9
3b0ae5f

Change Highlights

  • Added simple RPC functionality.
    • Remote proxy methods can return values, throw exceptions and be canceled via CancellationToken.
  • Updated performance tester.
  • Fixed issue of messages remaining in queue pending a new read/write. (Issue #1)
  • Revamped MqPostmaster to now use SmartThreadPool instead of threads via MqWorker.
  • MqWorker removed.
  • Changed project layout to allow for more flexibility.
  • Completely removed Nlog.

3b0ae5f - Added performance test for testing multiple clients across process boundaries.
9bbcf31 - Removed MqWorker.cs due to new reliance on
b2d5181 - Cleaned up code.
787d494 - Removed unnecessary usage of exception catching.
88e7e29 - Implemented remote invoke cancellation.
b45fcdc - Added new RpcMessageType for cancellation.
11b5ec1 - Started work on cancellation notification.
ce16625 - Testing using SmartThreadPool for threading of work items.
d819280 - Fixed tests. Rpc requests functioning correctly now.
b5d6a8f - Fixed test hanging.
ac5f408 - Replaced reset event with SemaphoreSlim
13cbe86 - Isolated socket from MQ implementation.
229d0bb - Updated nuspec for inclusion of Rpc system.
77055e6 - Combined the Rpc classes into the base Message queue system and removed associated projects.
2af8c77 - Added documentation. Started sub-threadding work on RPC calls.
072840e - Changed existing remote exception to a Data Contract and added a new RpcRemoteException class. Completed initial changeover to protobuf.
0f42224 - Fixed bug with MqMessageReader.NextFrame where the message position would not be updated. Added MqMessageReader.ReadToEnd to read remaining bytes in the message. Added Position and Length properties to MqMessageReader. Added tests for the new methods and properties. Removed redundant actions in EnsureBuffer. Now will only check and throw if there is not enough buffer space.
8311936 - Moved frame creation methods into Sessions to further break logic between the socket and the MqSessions.
6cc402c - Performance tests are now functioning. Finally fixed long standing bug for issue #1.
1572d82 - Fixed some compiler warnings.
7c897f9 - Added logging to test why client stops calling server proxy method.
16aee36 - Initial RPC Performance test complete.
08a8251 - Added config to control the length of time it takes an idle worker to timeout.
61af5b4 - Adding performance tests for PRC functionality.
871fbcb - Added tests. Testing performance.
a103457 - Migrated RPC project into MessageQueue solution. Created initial tests.
c8fc219 - Created override-able method to be invoked after setup has occurred on the session.
95ec972 - Fixed performance test. Changed IncomingMessageEventArgs to directly use the session instead of the super class.
7955b9f - Renamed CloseSession to just Close to match standard conventions.
cb6a2ac - Modified MqSession to be inherited to allow for session manipulation. Fixed tests.

Assets 2
Loading