You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ha...@apache.org on 2022/06/06 10:08:46 UTC
[activemq-nms-openwire] branch main updated (b40c5a2 -> fde8a9b)
This is an automated email from the ASF dual-hosted git repository.
havret pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-nms-openwire.git
from b40c5a2 Merge pull request #20 from apache/michaelandrepearce-2022-1
new fafd30a AMQNET-637 NMS 2.0
new 61a3de5 AMQNET-637 NMS 2.0
new 1e667f2 AMQNET-637 NMS 2.0
new c155c5a AMQNET-637 NMS 2.0
new fde8a9b Merge pull request #18 from lukeabsent/AMQNET-637
The 778 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
src/AdvisoryConsumer.cs | 21 +-
src/Commands/ActiveMQBytesMessage.cs | 12 +-
src/Commands/ActiveMQMapMessage.cs | 11 +
src/Commands/ActiveMQMessage.cs | 31 +-
src/Commands/ActiveMQObjectMessage.cs | 12 +
src/Commands/ActiveMQStreamMessage.cs | 5 +
src/Commands/ActiveMQTempDestination.cs | 7 +
src/Commands/ActiveMQTextMessage.cs | 13 +-
src/Connection.cs | 126 +++--
src/ConnectionFactory.cs | 54 +-
src/IDispatcher.cs | 3 +-
src/ISynchronization.cs | 8 +-
src/MessageConsumer.cs | 221 +++++----
src/MessageProducer.cs | 97 +++-
src/NetTxConnection.cs | 26 +-
src/NetTxMessageConsumer.cs | 15 +-
src/NetTxSession.cs | 26 +-
src/NetTxTransactionContext.cs | 108 ++--
src/NmsConsumer.cs | 127 +++++
src/NmsContext.cs | 545 +++++++++++++++++++++
src/NmsProducer.cs | 435 ++++++++++++++++
src/QueueBrowser.cs | 24 +-
src/Session.cs | 328 +++++++++++--
src/SessionExecutor.cs | 9 +-
src/State/ConnectionStateTracker.cs | 3 +-
src/Threads/CompositeTaskRunner.cs | 12 +-
src/Threads/DedicatedTaskRunner.cs | 7 +-
src/Threads/PooledTaskRunner.cs | 11 +-
src/Threads/ThreadPoolExecutor.cs | 10 +-
src/TransactionContext.cs | 31 +-
src/Transport/Discovery/AbstractDiscoveryAgent.cs | 15 +
src/Transport/Failover/BackupTransport.cs | 4 +-
src/Transport/Failover/FailoverTransport.cs | 50 +-
src/Transport/FutureResponse.cs | 64 +--
src/Transport/ITransport.cs | 17 +-
src/Transport/InactivityMonitor.cs | 5 +-
src/Transport/LoggingTransport.cs | 6 +-
src/Transport/Mock/MockTransport.cs | 47 +-
src/Transport/MutexTransport.cs | 5 +-
src/Transport/ResponseCorrelator.cs | 33 +-
src/Transport/Tcp/TcpTransport.cs | 30 +-
src/Transport/TransportFilter.cs | 39 +-
src/Transport/WireFormatNegotiator.cs | 8 +-
src/Util/ActiveMQMessageTransformation.cs | 57 +++
.../{FactoryAttribute.cs => AtomicExtensions.cs} | 36 +-
src/Util/FifoMessageDispatchChannel.cs | 5 +-
src/Util/MessageDispatchChannel.cs | 3 +-
src/Util/SimplePriorityMessageDispatchChannel.cs | 5 +-
.../Synchronization/NmsSynchronizationMonitor.cs | 314 ++++++++++++
src/Util/Synchronization/TaskExtensions.cs | 66 +++
.../Synchronization/TaskSynchronizationSettings.cs | 38 ++
src/nms-openwire.csproj | 7 +-
test/AMQNET366Test.cs | 22 +-
.../ConnectionFactoryTestAsync.cs} | 54 +-
.../MessageConsumerTestAsync.cs} | 111 +++--
test/Async/MessageProducerTestAsync.cs | 150 ++++++
test/DtcConsumerTransactionsTest.cs | 17 +-
test/DtcTransactionsTestSupport.cs | 15 +-
test/NMSConnectionFactoryTest.cs | 5 +-
test/NMSConsumerTest.cs | 306 ++++++++++++
.../{MessageProducerTest.cs => NMSProducerTest.cs} | 35 +-
test/NetTxTransactionTest.cs | 20 +-
test/OpenWire/MaxInactivityDurationTest.cs | 4 +-
test/State/ConnectionStateTrackerTest.cs | 21 +-
test/Transport/Inactivity/InactivityMonitorTest.cs | 9 +-
test/Transport/Mock/MockTransportTest.cs | 35 +-
test/Transport/Tcp/TcpFaultyTransport.cs | 13 +-
test/Transport/Tcp/TcpFaultyTransportTest.cs | 9 +-
test/Transport/failover/FailoverTransactionTest.cs | 25 +-
test/Transport/failover/FailoverTransportTest.cs | 70 +--
test/Util/ConnectionAuditTest.cs | 4 +-
test/nms-openwire-test.csproj | 5 +-
72 files changed, 3434 insertions(+), 688 deletions(-)
create mode 100644 src/NmsConsumer.cs
create mode 100644 src/NmsContext.cs
create mode 100644 src/NmsProducer.cs
copy src/Util/{FactoryAttribute.cs => AtomicExtensions.cs} (63%)
create mode 100644 src/Util/Synchronization/NmsSynchronizationMonitor.cs
create mode 100644 src/Util/Synchronization/TaskExtensions.cs
create mode 100644 src/Util/Synchronization/TaskSynchronizationSettings.cs
copy test/{ConnectionFactoryTest.cs => Async/ConnectionFactoryTestAsync.cs} (79%)
copy test/{MessageConsumerTest.cs => Async/MessageConsumerTestAsync.cs} (69%)
create mode 100644 test/Async/MessageProducerTestAsync.cs
create mode 100644 test/NMSConsumerTest.cs
copy test/{MessageProducerTest.cs => NMSProducerTest.cs} (71%)