This is an automated email from the ASF dual-hosted git repository.
nigrofranz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git.
from 7b34b56 This closes #2495
new a40a459 ARTEMIS-2205 Netty is used in a more idiomatic way
new d79762f ARTEMIS-2205 Refactor AMQP Processing into Netty Thread
new 8281e3b ARTEMIS-2205 Optimizing some Lambda usages
new e5e5744 This closes #2467
The 4 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:
.../artemis/cli/commands/etc/artemis.profile | 3 +
.../artemis/api/core/TransportConfiguration.java | 11 +
.../core/remoting/impl/netty/NettyConnection.java | 125 +++------
.../org/apache/activemq/artemis/junit/Wait.java | 7 +-
.../amqp/broker/AMQPConnectionCallback.java | 14 +-
.../protocol/amqp/broker/AMQPSessionCallback.java | 165 ++++--------
.../broker/ActiveMQProtonRemotingConnection.java | 3 +-
.../amqp/broker/ProtonProtocolManager.java | 10 +
.../amqp/proton/AMQPConnectionContext.java | 228 ++++++++--------
.../protocol/amqp/proton/AMQPSessionContext.java | 40 ++-
.../amqp/proton/ProtonServerReceiverContext.java | 136 +++++-----
.../amqp/proton/ProtonServerSenderContext.java | 196 +++++++++-----
.../amqp/proton/handler/ExecutorNettyAdapter.java | 221 ++++++++++++++++
.../amqp/proton/handler/ProtonHandler.java | 287 +++++++++++----------
.../transaction/ProtonTransactionHandler.java | 14 +-
.../proton/transaction/ProtonTransactionImpl.java | 25 +-
.../amqp/broker/AMQPSessionCallbackTest.java | 83 +++---
.../core/paging/cursor/PagedReferenceImpl.java | 26 +-
.../activemq/artemis/core/postoffice/Binding.java | 4 +
.../activemq/artemis/core/postoffice/Bindings.java | 3 +
.../artemis/core/postoffice/impl/BindingsImpl.java | 145 +++++++----
.../core/postoffice/impl/LocalQueueBinding.java | 5 +
.../core/postoffice/impl/PostOfficeImpl.java | 161 ++++++------
.../remoting/server/impl/RemotingServiceImpl.java | 2 +-
.../artemis/core/server/ActiveMQServerLogger.java | 2 +-
.../activemq/artemis/core/server/Consumer.java | 8 +
.../artemis/core/server/MessageReference.java | 11 +
.../apache/activemq/artemis/core/server/Queue.java | 8 +
.../artemis/core/server/RoutingContext.java | 29 +++
.../artemis/core/server/ServerConsumer.java | 6 +-
.../artemis/core/server/ServerSession.java | 17 ++
.../artemis/core/server/impl/LastValueQueue.java | 12 +
.../core/server/impl/MessageReferenceImpl.java | 26 +-
.../artemis/core/server/impl/QueueImpl.java | 54 ++--
.../core/server/impl/RoutingContextImpl.java | 82 +++++-
.../core/server/impl/ServerConsumerImpl.java | 22 +-
.../core/server/impl/ServerSessionImpl.java | 41 ++-
.../server/impl/ScheduledDeliveryHandlerTest.java | 5 +
.../integration/addressing/AddressingTest.java | 2 +-
.../integration/amqp/AmqpExpiredMessageTest.java | 2 +-
.../integration/amqp/AmqpFlowControlFailTest.java | 4 +-
.../integration/amqp/AmqpSendReceiveTest.java | 49 ++++
.../integration/amqp/AmqpTransactionTest.java | 2 +-
.../integration/amqp/JMSNonDestructiveTest.java | 8 +-
.../tests/integration/cli/DummyServerConsumer.java | 5 +
.../tests/integration/client/ConsumerTest.java | 10 +-
.../tests/integration/client/HangConsumerTest.java | 5 +
.../tests/unit/core/postoffice/impl/FakeQueue.java | 5 +
.../impl/WildcardAddressManagerUnitTest.java | 5 +
49 files changed, 1529 insertions(+), 805 deletions(-)
create mode 100644
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/handler/ExecutorNettyAdapter.java
