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 2017/11/13 22:02:47 UTC

[8/8] activemq-artemis git commit: This closes #1654

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 <cl...@apache.org>
Authored: Mon Nov 13 16:55:49 2017 -0500
Committer: Clebert Suconic <cl...@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(-)
----------------------------------------------------------------------