This closes #1654
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/fd2ce26d Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/fd2ce26d Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/fd2ce26d Branch: refs/heads/master Commit: fd2ce26d50b8207b49e0cb42c5ed171a7a25a873 Parents: 63b156e 18109e3 Author: Clebert Suconic <clebertsuco...@apache.org> Authored: Mon Nov 13 16:55:49 2017 -0500 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Mon Nov 13 16:55:49 2017 -0500 ---------------------------------------------------------------------- .../core/protocol/stomp/StompConnection.java | 14 +- .../stomp/StompPostReceiptFunction.java | 21 + .../protocol/stomp/StompProtocolManager.java | 16 +- .../core/protocol/stomp/StompSession.java | 19 +- .../stomp/VersionedStompFrameHandler.java | 56 ++- .../transport/amqp/client/AmqpClient.java | 4 +- .../transport/amqp/client/AmqpConnection.java | 7 +- .../client/transport/NettyTcpTransport.java | 460 ----------------- .../amqp/client/transport/NettyTransport.java | 56 --- .../client/transport/NettyTransportFactory.java | 83 ---- .../transport/NettyTransportListener.java | 48 -- .../client/transport/NettyTransportOptions.java | 208 -------- .../transport/NettyTransportSslOptions.java | 302 ------------ .../client/transport/NettyTransportSupport.java | 304 ------------ .../amqp/client/transport/NettyWSTransport.java | 171 ------- .../client/transport/X509AliasKeyManager.java | 86 ---- .../transport/netty/NettyTcpTransport.java | 460 +++++++++++++++++ .../transport/netty/NettyTransport.java | 57 +++ .../transport/netty/NettyTransportFactory.java | 82 ++++ .../transport/netty/NettyTransportListener.java | 48 ++ .../transport/netty/NettyTransportOptions.java | 219 +++++++++ .../netty/NettyTransportSslOptions.java | 302 ++++++++++++ .../transport/netty/NettyTransportSupport.java | 304 ++++++++++++ .../transport/netty/NettyWSTransport.java | 172 +++++++ .../transport/netty/X509AliasKeyManager.java | 86 ++++ .../integration/plugin/StompPluginTest.java | 44 +- .../tests/integration/stomp/FQQNStompTest.java | 29 +- .../tests/integration/stomp/StompTest.java | 60 +-- .../tests/integration/stomp/StompTestBase.java | 50 +- .../stomp/StompTestPropertiesInterceptor.java | 10 +- .../stomp/StompTestWithInterceptors.java | 2 +- .../stomp/StompTestWithLargeMessages.java | 490 ++++++++++--------- .../stomp/StompTestWithMessageID.java | 4 +- .../stomp/StompTestWithSecurity.java | 2 +- .../stomp/StompWebSocketMaxFrameTest.java | 94 ++++ .../stomp/util/AbstractClientStompFrame.java | 12 + .../util/AbstractStompClientConnection.java | 174 +++++-- .../stomp/util/ClientStompFrame.java | 6 + .../stomp/util/StompClientConnection.java | 5 + .../util/StompClientConnectionFactory.java | 45 ++ .../stomp/util/StompClientConnectionV10.java | 11 + .../stomp/util/StompClientConnectionV11.java | 23 +- .../stomp/util/StompClientConnectionV12.java | 9 + .../integration/stomp/v11/ExtraStompTest.java | 25 +- .../integration/stomp/v11/StompV11Test.java | 142 +++--- .../integration/stomp/v12/StompV12Test.java | 91 ++-- .../impl/netty/NettyHandshakeTimeoutTest.java | 6 +- 47 files changed, 2705 insertions(+), 2214 deletions(-) ----------------------------------------------------------------------