You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2020/04/16 14:28:13 UTC

[activemq-artemis] 03/03: This closes #3087

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit c1a000c870aca60e82356ea4279e46ad1dbc0022
Merge: ceceb66 ad60a0b
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Thu Apr 16 10:27:56 2020 -0400

    This closes #3087

 .../protocol/amqp/broker/AMQPLargeMessage.java     |   7 +-
 .../protocol/amqp/broker/AMQPSessionCallback.java  |   5 +
 .../amqp/proton/ProtonServerReceiverContext.java   |  29 +++-
 .../proton/ProtonServerReceiverContextTest.java    |  13 +-
 .../artemis/core/persistence/StorageManager.java   |   2 +
 .../impl/journal/JournalStorageManager.java        |  42 +++---
 .../impl/journal/LargeServerMessageImpl.java       |   1 +
 .../impl/nullpm/NullStorageLargeServerMessage.java |   6 +
 .../impl/nullpm/NullStorageManager.java            |   5 +
 .../artemis/core/server/ActiveMQServer.java        |   4 +
 .../artemis/core/server/LargeServerMessage.java    |   2 +
 .../core/transaction/impl/TransactionImplTest.java |   5 +
 .../largemessages/InterruptedAMQPLargeMessage.java | 167 +++++++++++++++++++++
 .../SimpleStreamingLargeMessageTest.java           |  33 ++++
 .../client/LargeMessageAvoidLargeMessagesTest.java |   4 +
 .../client/LargeMessageCompressTest.java           |   4 +
 .../tests/integration/client/LargeMessageTest.java |  73 +++++++++
 .../tests/integration/client/SendAckFailTest.java  |   5 +
 18 files changed, 387 insertions(+), 20 deletions(-)