activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nigrofr...@apache.org
Subject [activemq-artemis] branch master updated (7b34b56 -> e5e5744)
Date Thu, 10 Jan 2019 15:40:30 GMT
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


Mime
View raw message