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 6b2ddfd5a3 QPID-8760: [Broker-J] ServletContextHandler.setHandler
should not be called directly (#440)
new 804858330a QPID-8757: [Broker-J] WebSocket idle checker queues
unbounded tick jobs while a connection is writing, exhausting the broker heap
new 2f198a9f3a QPID-8758: [Broker-J] Ensure AMQP-over-WebSocket
connections terminate after an unanswered close
The 2 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:
.../transport/MultiVersionProtocolEngine.java | 6 +
.../qpid/server/transport/ProtocolEngine.java | 11 +
.../protocol/v1_0/AMQPConnection_1_0Impl.java | 8 +
.../protocol/v1_0/AMQPConnection_1_0ImplTest.java | 72 +-
.../protocol/v1_0/ProtocolEngine_1_0_0Test.java | 9 +-
broker-plugins/websocket/pom.xml | 12 +
.../transport/websocket/PortSslContextFactory.java | 69 ++
.../QpidByteBufferTrackingThreadPool.java} | 21 +-
.../transport/websocket/WebSocketProvider.java | 649 +++---------------
.../websocket/connection/AmqpWebSocket.java | 200 ++++++
.../transport/websocket/connection/CleanupJob.java | 253 +++++++
.../websocket/connection/CloseCallback.java | 33 +-
.../websocket/connection/ProtocolWorkJob.java | 79 +++
.../transport/websocket/connection/TickJob.java | 206 ++++++
.../websocket/connection/WebSocketConnection.java | 497 ++++++++++++++
.../connection/WebSocketConnectionScheduler.java | 305 +++++++++
.../websocket/connection/WebSocketReceiver.java | 153 +++++
.../websocket/connection/WebSocketSettings.java | 15 +-
.../websocket/connection/WebSocketWriteQueue.java | 178 +++++
.../websocket/connection/WriteCallback.java | 73 ++
.../transport/websocket/connection/WriteJob.java | 316 +++++++++
.../websocket/PortSslContextFactoryTest.java | 151 +++++
.../websocket/connection/AmqpWebSocketTest.java | 371 +++++++++++
.../websocket/connection/CleanupJobTest.java | 473 +++++++++++++
.../websocket/connection/ProtocolWorkJobTest.java | 61 ++
.../WebSocketConnectionSchedulerTest.java | 394 +++++++++++
.../connection/WebSocketConnectionTest.java | 741 +++++++++++++++++++++
.../connection/WebSocketDeadlineUpdateTest.java | 597 +++++++++++++++++
.../websocket/connection/WebSocketTestBase.java | 265 ++++++++
.../websocket/connection/WriteJobTest.java | 254 +++++++
.../websocket/WebSocketFrameTransport.java | 147 +++-
.../websocket/WebSocketCloseTimeoutTest.java | 86 +++
.../WebSocketCompressedCloseTimeoutTest.java | 160 +++++
.../websocket/WebSocketIdleTimeoutTest.java | 154 +++++
.../v1_0/extensions/websocket/WebSocketTest.java | 74 +-
.../org/apache/qpid/tests/utils/BrokerAdmin.java | 26 +
.../utils/EmbeddedBrokerPerClassAdminImpl.java | 38 ++
.../tests/utils/LoggingBrokerAdminDecorator.java | 18 +
38 files changed, 6568 insertions(+), 607 deletions(-)
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/PortSslContextFactory.java
copy
broker-plugins/{amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/codec/SimpleVariableWidthWriter.java
=>
websocket/src/main/java/org/apache/qpid/server/transport/websocket/QpidByteBufferTrackingThreadPool.java}
(64%)
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/AmqpWebSocket.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/CleanupJob.java
copy
broker-core/src/main/java/org/apache/qpid/server/util/ServerScopedRuntimeException.java
=>
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/CloseCallback.java
(55%)
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/ProtocolWorkJob.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/TickJob.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WebSocketConnection.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WebSocketConnectionScheduler.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WebSocketReceiver.java
copy
broker-core/src/main/java/org/apache/qpid/server/typedmessage/TypedBytesFormatException.java
=>
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WebSocketSettings.java
(76%)
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WebSocketWriteQueue.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WriteCallback.java
create mode 100644
broker-plugins/websocket/src/main/java/org/apache/qpid/server/transport/websocket/connection/WriteJob.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/PortSslContextFactoryTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/AmqpWebSocketTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/CleanupJobTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/ProtocolWorkJobTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/WebSocketConnectionSchedulerTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/WebSocketConnectionTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/WebSocketDeadlineUpdateTest.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/WebSocketTestBase.java
create mode 100644
broker-plugins/websocket/src/test/java/org/apache/qpid/server/transport/websocket/connection/WriteJobTest.java
create mode 100644
systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/websocket/WebSocketCloseTimeoutTest.java
create mode 100644
systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/websocket/WebSocketCompressedCloseTimeoutTest.java
create mode 100644
systests/protocol-tests-amqp-1-0/src/test/java/org/apache/qpid/tests/protocol/v1_0/extensions/websocket/WebSocketIdleTimeoutTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
