This is an automated email from the ASF dual-hosted git repository.
dakirily pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-broker-j.git
from e24922bd54 QPID-8767: [Broker-J] Bump fasterxml jackson dependencies
to the version 3.2.2 (#446)
new 0db16e4115 NO-JIRA: [Broker-J] AMQP 0-8 / 0-9 / 0-9-1 validation
improvements
new 60a0637a8e NO-JIRA: [Broker-J] AMQP 0-10 validation improvements
new a319c05339 NO-JIRA: [Broker-J] GZIP compression optimization
new ede64d973d NO-JIRA: [Broker-J] Network selector resilience improvements
new 23003b1db8 NO-JIRA: [Broker-J] Renew HTTP management sessions after
authentication
The 5 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:
.../qpid/server/bytebuffer/QpidByteBuffer.java | 17 +-
.../server/bytebuffer/QpidByteBufferFactory.java | 25 +-
.../AmqpCompoundMimeContentToObjectConverter.java | 57 +
.../org/apache/qpid/server/model/Connection.java | 13 +
...ntent.java => DecompressionLimitedContent.java} | 11 +-
.../qpid/server/plugin/MessageConverter.java | 20 +-
.../apache/qpid/server/protocol/ErrorCodes.java | 5 +
.../apache/qpid/server/queue/AbstractQueue.java | 301 +++++-
.../qpid/server/transport/AMQPConnection.java | 7 +
.../server/transport/AbstractAMQPConnection.java | 11 +
.../transport/NetworkConnectionScheduler.java | 56 +-
.../qpid/server/transport/SelectorThread.java | 5 +
.../org/apache/qpid/server/util/GZIPUtils.java | 195 +++-
.../qpid/server/bytebuffer/QpidByteBufferTest.java | 40 +-
.../consumer/AbstractConsumerTargetTest.java | 85 +-
...qpCompoundMimeContentToObjectConverterTest.java | 83 ++
.../qpid/server/plugin/MessageConverterTest.java | 122 +++
.../qpid/server/queue/StandardQueueTest.java | 165 ++-
.../transport/NetworkConnectionSchedulerTest.java | 148 +++
.../NonBlockingConnectionExceptionTest.java | 121 +++
.../org/apache/qpid/server/util/GZIPUtilsTest.java | 99 +-
.../server/protocol/v0_10/AMQPConnection_0_10.java | 20 +
.../protocol/v0_10/AMQPConnection_0_10Impl.java | 44 +-
.../server/protocol/v0_10/ConsumerTarget_0_10.java | 40 +-
.../v0_10/MessageConverter_Internal_to_v0_10.java | 9 +
.../protocol/v0_10/MessageConverter_v0_10.java | 9 +
.../v0_10/MessageConverter_v0_10_to_Internal.java | 61 +-
.../protocol/v0_10/MessageTransferMessage.java | 40 +-
.../v0_10/MessageTransferMessageMutator.java | 3 +-
.../server/protocol/v0_10/ServerAssembler.java | 346 ++++--
.../server/protocol/v0_10/ServerConnection.java | 7 +
.../protocol/v0_10/ServerConnectionDelegate.java | 45 +-
.../qpid/server/protocol/v0_10/ServerDecoder.java | 140 ++-
.../qpid/server/protocol/v0_10/ServerFrame.java | 5 +-
.../server/protocol/v0_10/ServerInputHandler.java | 214 ++--
.../protocol/v0_10/ServerSessionDelegate.java | 5 +-
.../protocol/v0_10/transport/AbstractDecoder.java | 429 ++++++--
.../protocol/v0_10/transport/AbstractEncoder.java | 6 +-
.../server/protocol/v0_10/transport/BBDecoder.java | 152 ++-
.../protocol/v0_10/transport/ConnectionSecure.java | 6 +
.../v0_10/transport/ConnectionSecureOk.java | 6 +
.../v0_10/transport/ConnectionStartOk.java | 6 +
.../protocol/v0_10/transport/EncoderUtils.java | 2 +
.../server/protocol/v0_10/transport/Struct.java | 20 +-
.../AmqpListToListConverter.java | 15 +-
.../AmqpMapToMapConverter.java | 15 +-
.../protocol/v0_10/AMQPConnection_0_10Test.java | 155 +++
.../MessageConverter_0_10_to_InternalTest.java | 144 ++-
.../v0_10/MessageTransferMessageMutatorTest.java | 7 +-
.../protocol/v0_10/SaslFrameLoggingTest.java | 198 ++++
.../protocol/v0_10/ServerAssemblerNestingTest.java | 127 +++
.../server/protocol/v0_10/ServerAssemblerTest.java | 493 +++++++++
.../protocol/v0_10/ServerCompoundDecoderTest.java | 94 ++
.../v0_10/ServerConnectionDelegateTest.java | 109 +-
.../server/protocol/v0_10/ServerDecoderTest.java | 83 ++
.../protocol/v0_10/ServerInputHandlerTest.java | 153 +++
.../protocol/v0_10/transport/BBDecoderTest.java | 70 ++
.../protocol/v0_10/transport/BBEncoderTest.java | 23 +
.../v0_10/transport/CompoundDecoderTest.java | 198 ++++
.../transport/CompoundNestingDecoderTest.java | 177 ++++
.../qpid/server/protocol/v0_8/AMQChannel.java | 213 ++--
.../qpid/server/protocol/v0_8/AMQDecoder.java | 66 +-
.../v0_8/AMQFatalFrameDecodingException.java | 16 +-
.../protocol/v0_8/AMQFrameDecodingException.java | 57 +-
.../qpid/server/protocol/v0_8/AMQMessage.java | 9 +-
.../server/protocol/v0_8/AMQPConnection_0_8.java | 18 +-
.../protocol/v0_8/AMQPConnection_0_8Impl.java | 176 +++-
.../apache/qpid/server/protocol/v0_8/AMQType.java | 47 +-
.../qpid/server/protocol/v0_8/AMQTypedValue.java | 21 +-
...xception.java => AMQValueNestingException.java} | 9 +-
.../qpid/server/protocol/v0_8/BrokerDecoder.java | 9 +-
.../server/protocol/v0_8/ConsumerTarget_0_8.java | 3 +-
.../qpid/server/protocol/v0_8/EncodingUtils.java | 65 +-
.../qpid/server/protocol/v0_8/FieldArray.java | 13 +-
.../qpid/server/protocol/v0_8/FieldTable.java | 260 ++++-
.../server/protocol/v0_8/FieldTableFactory.java | 7 +
.../protocol/v0_8/FieldValueNestingValidator.java | 154 +++
...ameBoundaryValidatingServerMethodProcessor.java | 610 +++++++++++
.../qpid/server/protocol/v0_8/IncomingMessage.java | 50 +-
.../v0_8/MessageConverter_Internal_to_v0_8.java | 9 +
.../v0_8/MessageConverter_v0_8_to_Internal.java | 61 +-
.../protocol/v0_8/ProtocolOutputConverterImpl.java | 18 +-
.../qpid/server/protocol/v0_8/ServerDecoder.java | 501 +++++----
.../protocol/v0_8/transport/BasicConsumeBody.java | 32 +-
.../transport/BasicContentHeaderProperties.java | 63 +-
.../protocol/v0_8/transport/ChannelAlertBody.java | 14 +-
.../v0_8/transport/ConnectionStartBody.java | 25 +-
.../v0_8/transport/ConnectionStartOkBody.java | 35 +-
.../protocol/v0_8/transport/ContentHeaderBody.java | 94 +-
.../v0_8/transport/ExchangeDeclareBody.java | 33 +-
.../protocol/v0_8/transport/HeartbeatBody.java | 30 +-
.../protocol/v0_8/transport/MethodProcessor.java | 8 +
.../protocol/v0_8/transport/QueueBindBody.java | 26 +-
.../protocol/v0_8/transport/QueueDeclareBody.java | 26 +-
.../protocol/v0_8/transport/QueueUnbindBody.java | 26 +-
.../transport/ServerChannelMethodProcessor.java | 10 +
.../qpid/server/protocol/v0_8/AMQChannelTest.java | 271 +++++
.../protocol/v0_8/AMQPConnection_0_8Test.java | 1000 +++++++++++++++++-
.../server/protocol/v0_8/EncodingUtilsTest.java | 192 +++-
.../v0_8/FieldTableNestingDecoderTest.java | 354 +++++++
.../qpid/server/protocol/v0_8/FieldTableTest.java | 369 ++++++-
.../server/protocol/v0_8/IncomingMessageTest.java | 125 +++
.../v0_8/MessageConverter_0_8_to_InternalTest.java | 121 ++-
.../server/protocol/v0_8/ServerDecoderTest.java | 1103 ++++++++++++++++++++
.../BasicContentHeaderPropertiesDisposalTest.java | 460 ++++++++
.../BasicContentHeaderPropertiesTest.java | 39 +-
.../ClientFieldTableBodyDisposalTest.java | 106 ++
.../v0_8/transport/ConnectionStartOkBodyTest.java | 126 +++
.../ServerFieldTableBodyDisposalTest.java | 160 +++
.../server/protocol/v1_0/AMQPConnection_1_0.java | 5 -
.../protocol/v1_0/AMQPConnection_1_0Impl.java | 2 +
.../server/protocol/v1_0/ConsumerTarget_1_0.java | 3 +-
.../v1_0/MessageConverter_Internal_to_v1_0.java | 15 +
.../protocol/v1_0/MessageConverter_to_1_0.java | 172 ++-
.../v1_0/MessageConverter_v1_0_to_Internal.java | 9 +
.../v1_0/MessageConverter_Internal_to_1_0Test.java | 38 +-
.../v0_10_v1_0/MessageConverter_0_10_to_1_0.java | 12 +-
.../v0_10_v1_0/MessageConverter_1_0_to_v0_10.java | 33 +-
.../MessageConverter_0_10_to_1_0Test.java | 107 +-
.../PropertyConverter_1_0_to_0_10Test.java | 63 ++
.../v0_8_v0_10/MessageConverter_0_10_to_0_8.java | 9 +
.../v0_8_v0_10/MessageConverter_0_8_to_0_10.java | 9 +
.../v0_8_v1_0/MessageConverter_0_8_to_1_0.java | 10 +
.../v0_8_v1_0/MessageConverter_1_0_to_v0_8.java | 9 +
.../v0_8_v1_0/MessageConverter_0_8_to_1_0Test.java | 154 ++-
.../server/management/amqp/ManagementNode.java | 63 +-
.../amqp/ManagementAddressSpaceTest.java | 60 ++
.../management/plugin/GunzipOutputStream.java | 93 +-
.../server/management/plugin/HttpManagement.java | 2 +
.../management/plugin/HttpManagementUtil.java | 27 +-
.../plugin/servlet/rest/AbstractServlet.java | 97 +-
.../management/plugin/GunzipOutputStreamTest.java | 40 +
.../management/plugin/HttpManagementUtilTest.java | 114 +-
.../auth/InteractiveAuthenticationSessionTest.java | 380 +++++++
.../auth/OAuth2InteractiveAuthenticatorTest.java | 7 +
.../plugin/servlet/rest/AbstractServletTest.java | 573 ++++++++++
systests/end-to-end-conversion-tests/pom.xml | 5 +
.../Amqp10ToAmqp010ConversionTest.java | 117 +++
.../extensions/maxsize/MaximumMessageSizeTest.java | 31 +-
.../qpid/tests/protocol/v0_8/ConnectionTest.java | 135 ++-
.../protocol/v0_8/ContentBodyFrameLimitTest.java | 108 ++
.../v0_8/IncompleteContentSequenceTest.java | 186 ++++
.../tests/protocol/v0_8/MalformedFrameTest.java | 244 +++++
.../v0_8/extension/basic/MalformedMessageTest.java | 38 +-
.../PreemptiveAuthenticationTest.java | 110 +-
.../qpid/tests/http/authentication/SaslTest.java | 61 +-
.../authentication/SpnegoAuthenticationTest.java | 235 +++++
147 files changed, 14589 insertions(+), 1289 deletions(-)
create mode 100644
broker-core/src/main/java/org/apache/qpid/server/message/mimecontentconverter/AmqpCompoundMimeContentToObjectConverter.java
copy broker-core/src/main/java/org/apache/qpid/server/model/{Content.java =>
DecompressionLimitedContent.java} (78%)
create mode 100644
broker-core/src/test/java/org/apache/qpid/server/message/mimecontentconverter/AmqpCompoundMimeContentToObjectConverterTest.java
create mode 100644
broker-core/src/test/java/org/apache/qpid/server/plugin/MessageConverterTest.java
create mode 100644
broker-core/src/test/java/org/apache/qpid/server/transport/NetworkConnectionSchedulerTest.java
create mode 100644
broker-core/src/test/java/org/apache/qpid/server/transport/NonBlockingConnectionExceptionTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/AMQPConnection_0_10Test.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/SaslFrameLoggingTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/ServerAssemblerNestingTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/ServerAssemblerTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/ServerCompoundDecoderTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/ServerDecoderTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/ServerInputHandlerTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/transport/CompoundDecoderTest.java
create mode 100644
broker-plugins/amqp-0-10-protocol/src/test/java/org/apache/qpid/server/protocol/v0_10/transport/CompoundNestingDecoderTest.java
copy
broker-core/src/main/java/org/apache/qpid/server/model/IntegrityViolationException.java
=>
broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQFatalFrameDecodingException.java
(74%)
copy
broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/{ConsumerTagInUseException.java
=> AMQValueNestingException.java} (81%)
create mode 100644
broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/FieldValueNestingValidator.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/FrameBoundaryValidatingServerMethodProcessor.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/FieldTableNestingDecoderTest.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/IncomingMessageTest.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/ServerDecoderTest.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/transport/BasicContentHeaderPropertiesDisposalTest.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/transport/ClientFieldTableBodyDisposalTest.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/transport/ConnectionStartOkBodyTest.java
create mode 100644
broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/transport/ServerFieldTableBodyDisposalTest.java
create mode 100644
broker-plugins/management-http/src/test/java/org/apache/qpid/server/management/plugin/auth/InteractiveAuthenticationSessionTest.java
create mode 100644
broker-plugins/management-http/src/test/java/org/apache/qpid/server/management/plugin/servlet/rest/AbstractServletTest.java
create mode 100644
systests/end-to-end-conversion-tests/src/test/java/org/apache/qpid/systests/end_to_end_conversion/Amqp10ToAmqp010ConversionTest.java
create mode 100644
systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/ContentBodyFrameLimitTest.java
create mode 100644
systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/IncompleteContentSequenceTest.java
create mode 100644
systests/protocol-tests-amqp-0-8/src/test/java/org/apache/qpid/tests/protocol/v0_8/MalformedFrameTest.java
create mode 100644
systests/qpid-systests-http-management/src/test/java/org/apache/qpid/tests/http/authentication/SpnegoAuthenticationTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
