activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbert...@apache.org
Subject [51/51] [partial] activemq-6 git commit: ACTIVEMQ6-1 - Initial HornetQ Donation Commit
Date Mon, 10 Nov 2014 16:33:02 GMT
ACTIVEMQ6-1 - Initial HornetQ Donation Commit

https://issues.apache.org/jira/browse/ACTIVEMQ6-1

This is the initial donation of the HornetQ codebase as per document http://incubator.apache.org/ip-clearance/hornetq.html


Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/8ecd255f
Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/8ecd255f
Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/8ecd255f

Branch: refs/heads/master
Commit: 8ecd255f981e5d806173cf86f6fac9c4c7c25167
Parents: 40e8479
Author: Andy Taylor <andytaylor@apache.org>
Authored: Fri Oct 31 10:20:28 2014 +0000
Committer: jbertram <jbertram@redhat.com>
Committed: Mon Nov 10 10:31:25 2014 -0600

----------------------------------------------------------------------
 .gitignore                                      |  754 +++
 .project                                        |   17 +
 .../de.loskutov.anyedit.AnyEditTools.prefs      |   14 +
 .settings/intellij_settings.jar                 |  Bin 0 -> 21942 bytes
 NOTICE                                          |   14 +
 README.md                                       |  171 +
 RELEASING.md                                    |   61 +
 distribution/hornetq/pom.xml                    |  186 +
 distribution/hornetq/src/main/assembly/dep.xml  |  508 ++
 .../hornetq/src/main/resources/bin/run.bat      |   21 +
 .../hornetq/src/main/resources/bin/run.sh       |   35 +
 .../hornetq/src/main/resources/bin/stop.bat     |    9 +
 .../hornetq/src/main/resources/bin/stop.sh      |    5 +
 .../clustered/hornetq-configuration.xml         |  122 +
 .../clustered/hornetq-jboss-beans.xml           |   62 +
 .../config/jboss-as-6/clustered/hornetq-jms.xml |   47 +
 .../config/jboss-as-6/clustered/jms-ds.xml      |   26 +
 .../non-clustered/hornetq-configuration.xml     |   97 +
 .../non-clustered/hornetq-jboss-beans.xml       |   61 +
 .../jboss-as-6/non-clustered/hornetq-jms.xml    |   46 +
 .../config/jboss-as-6/non-clustered/jms-ds.xml  |   26 +
 .../stand-alone/clustered/hornetq-beans.xml     |   61 +
 .../clustered/hornetq-configuration.xml         |   94 +
 .../stand-alone/clustered/hornetq-jms.xml       |   53 +
 .../stand-alone/clustered/hornetq-users.xml     |    7 +
 .../stand-alone/clustered/jndi.properties       |    2 +
 .../stand-alone/clustered/logging.properties    |   56 +
 .../stand-alone/non-clustered/hornetq-beans.xml |   61 +
 .../non-clustered/hornetq-configuration.xml     |   67 +
 .../stand-alone/non-clustered/hornetq-jms.xml   |   53 +
 .../stand-alone/non-clustered/hornetq-users.xml |    7 +
 .../stand-alone/non-clustered/jndi.properties   |    2 +
 .../non-clustered/logging.properties            |   56 +
 .../stand-alone/replicated/hornetq-beans.xml    |   61 +
 .../replicated/hornetq-configuration.xml        |  101 +
 .../stand-alone/replicated/hornetq-jms.xml      |   53 +
 .../stand-alone/replicated/hornetq-users.xml    |    7 +
 .../stand-alone/replicated/jndi.properties      |    2 +
 .../stand-alone/replicated/logging.properties   |   56 +
 .../stand-alone/shared-store/hornetq-beans.xml  |   61 +
 .../shared-store/hornetq-configuration.xml      |  101 +
 .../stand-alone/shared-store/hornetq-jms.xml    |   53 +
 .../stand-alone/shared-store/hornetq-users.xml  |    7 +
 .../stand-alone/shared-store/jndi.properties    |    2 +
 .../stand-alone/shared-store/logging.properties |   56 +
 .../trunk/clustered-backup/hornetq-beans.xml    |   74 +
 .../clustered-backup/hornetq-configuration.xml  |   88 +
 .../trunk/clustered-backup/hornetq-jms.xml      |   28 +
 .../trunk/clustered-backup/hornetq-users.xml    |    7 +
 .../trunk/clustered-backup/jndi.properties      |   15 +
 .../trunk/clustered-backup/logging.properties   |   34 +
 .../config/trunk/clustered/hornetq-beans.xml    |   61 +
 .../trunk/clustered/hornetq-configuration.xml   |   73 +
 .../config/trunk/clustered/hornetq-jms.xml      |   28 +
 .../config/trunk/clustered/hornetq-users.xml    |    7 +
 .../config/trunk/clustered/jndi.properties      |    2 +
 .../config/trunk/clustered/logging.properties   |   34 +
 .../trunk/non-clustered/hornetq-beans.xml       |   60 +
 .../non-clustered/hornetq-configuration.xml     |   59 +
 .../config/trunk/non-clustered/hornetq-jms.xml  |   40 +
 .../trunk/non-clustered/hornetq-users.xml       |    7 +
 .../config/trunk/non-clustered/jndi.properties  |    2 +
 .../trunk/non-clustered/logging.properties      |   38 +
 .../examples/common/config/ant.properties       |    4 +
 .../src/main/resources/licenses/LGPL.txt        |  503 ++
 .../src/main/resources/licenses/LICENSE.txt     |  202 +
 .../resources/licenses/LICENSE_twitter4j.txt    |   26 +
 .../src/main/resources/licenses/base64.txt      |   10 +
 .../src/main/resources/licenses/json.txt        |   23 +
 distribution/jboss-mc/pom.xml                   |  123 +
 distribution/jnp-client/pom.xml                 |   75 +
 distribution/pom.xml                            |   53 +
 docs/README.html                                |   25 +
 docs/design-guide/en/Author_Group.xml           |   30 +
 docs/design-guide/en/Book_Info.xml              |   44 +
 docs/design-guide/en/HornetQ_Design_Guide.ent   |    5 +
 docs/design-guide/en/HornetQ_Design_Guide.xml   |   26 +
 docs/design-guide/en/about.xml                  |   24 +
 docs/design-guide/en/clustering.xml             |   43 +
 docs/design-guide/en/diagrams/design-docs.odg   |  Bin 0 -> 11896 bytes
 .../en/images/hornetQ_logo_600px.png            |  Bin 0 -> 23866 bytes
 docs/design-guide/en/images/topology-update.jpg |  Bin 0 -> 94951 bytes
 docs/design-guide/en/notice.xml                 |   32 +
 docs/design-guide/pom.xml                       |  306 +
 docs/diagrams/standard_image.odg                |  Bin 0 -> 11094 bytes
 docs/diagrams/widgets.odg                       |  Bin 0 -> 13133 bytes
 docs/eap-manual/en/Author_Group.xml             |   30 +
 docs/eap-manual/en/Book_Info.xml                |   44 +
 docs/eap-manual/en/HornetQ_EAP_Manual.ent       |    7 +
 docs/eap-manual/en/HornetQ_EAP_Manual.xml       |   24 +
 docs/eap-manual/en/clusters.xml                 |  569 ++
 docs/eap-manual/en/diagrams/ha-topologies1.odg  |  Bin 0 -> 14529 bytes
 docs/eap-manual/en/images/simple-colocated.jpg  |  Bin 0 -> 94996 bytes
 docs/eap-manual/en/images/simple-colocated2.jpg |  Bin 0 -> 124592 bytes
 docs/eap-manual/en/images/simple-colocated3.jpg |  Bin 0 -> 162357 bytes
 .../en/images/simple-dedicated-jca-remote.jpg   |  Bin 0 -> 65959 bytes
 .../en/images/simple-dedicated-jca.jpg          |  Bin 0 -> 100349 bytes
 docs/eap-manual/en/images/simple-dedicated.jpg  |  Bin 0 -> 49812 bytes
 docs/eap-manual/en/master.xml                   |    0
 docs/eap-manual/pom.xml                         |  305 +
 docs/pom.xml                                    |   51 +
 docs/quickstart-guide/en/Author_Group.xml       |   45 +
 docs/quickstart-guide/en/Book_Info.xml          |   31 +
 .../en/HornetQ_QuickStart_Guide.ent             |    5 +
 .../en/HornetQ_QuickStart_Guide.xml             |   17 +
 docs/quickstart-guide/en/about.xml              |   84 +
 docs/quickstart-guide/en/download.xml           |   75 +
 docs/quickstart-guide/en/examples.xml           |  330 +
 .../en/images/hornetQ_logo_600px.png            |  Bin 0 -> 23866 bytes
 docs/quickstart-guide/en/installation.xml       |  102 +
 docs/quickstart-guide/en/introduction.xml       |   33 +
 docs/quickstart-guide/en/master.xml             |    0
 docs/quickstart-guide/en/notice.xml             |   37 +
 docs/quickstart-guide/en/running.xml            |  125 +
 docs/quickstart-guide/pom.xml                   |  300 +
 docs/quickstart-guide/quickstart-guide.xpr      |   21 +
 docs/quickstart-guide/zh/about.xml              |   67 +
 docs/quickstart-guide/zh/download.xml           |   70 +
 docs/quickstart-guide/zh/examples.xml           |  216 +
 .../zh/images/hornetQ_logo_600px.png            |  Bin 0 -> 23866 bytes
 docs/quickstart-guide/zh/installation.xml       |  158 +
 docs/quickstart-guide/zh/introduction.xml       |   25 +
 docs/quickstart-guide/zh/master.xml             |   46 +
 docs/quickstart-guide/zh/notice.xml             |   29 +
 docs/quickstart-guide/zh/running.xml            |   68 +
 docs/user-manual/en/Author_Group.xml            |   82 +
 docs/user-manual/en/Book_Info.xml               |   44 +
 docs/user-manual/en/HornetQ_User_Manual.ent     |   18 +
 docs/user-manual/en/HornetQ_User_Manual.xml     |   74 +
 docs/user-manual/en/aerogear-integration.xml    |  116 +
 docs/user-manual/en/appserver-integration.xml   | 1342 ++++
 docs/user-manual/en/architecture.xml            |  152 +
 docs/user-manual/en/client-classpath.xml        |   59 +
 docs/user-manual/en/client-reconnection.xml     |  155 +
 docs/user-manual/en/clusters.xml                |  998 +++
 docs/user-manual/en/configuration-index.xml     |  705 ++
 docs/user-manual/en/configuring-transports.xml  |  453 ++
 docs/user-manual/en/connection-ttl.xml          |  203 +
 docs/user-manual/en/core-bridges.xml            |  240 +
 .../en/diagrams/architecture-diagrams.odg       |  Bin 0 -> 10587 bytes
 .../en/diagrams/ha-replicated-store.odg         |  Bin 0 -> 11620 bytes
 .../user-manual/en/diagrams/ha-shared-store.odg |  Bin 0 -> 10650 bytes
 docs/user-manual/en/diverts.xml                 |  114 +
 docs/user-manual/en/duplicate-detection.xml     |  149 +
 docs/user-manual/en/embedding-hornetq.xml       |  271 +
 docs/user-manual/en/examples.xml                |  689 ++
 docs/user-manual/en/filter-expressions.xml      |   87 +
 docs/user-manual/en/flow-control.xml            |  316 +
 docs/user-manual/en/ha.xml                      |  539 ++
 docs/user-manual/en/images/architecture1.jpg    |  Bin 0 -> 19948 bytes
 docs/user-manual/en/images/architecture2.jpg    |  Bin 0 -> 18718 bytes
 docs/user-manual/en/images/architecture3.jpg    |  Bin 0 -> 12274 bytes
 docs/user-manual/en/images/console1.png         |  Bin 0 -> 81814 bytes
 .../en/images/ha-replicated-store.png           |  Bin 0 -> 21496 bytes
 docs/user-manual/en/images/ha-shared-store.png  |  Bin 0 -> 14147 bytes
 .../en/images/hornetQ-banner_final.png          |  Bin 0 -> 109633 bytes
 .../en/images/hornetQ_logo_600px.png            |  Bin 0 -> 23866 bytes
 docs/user-manual/en/intercepting-operations.xml |  100 +
 docs/user-manual/en/interoperability.xml        |  288 +
 docs/user-manual/en/jms-bridge.xml              |  450 ++
 docs/user-manual/en/jms-core-mapping.xml        |   51 +
 docs/user-manual/en/large-messages.xml          |  297 +
 docs/user-manual/en/last-value-queues.xml       |   71 +
 docs/user-manual/en/libaio.xml                  |  130 +
 docs/user-manual/en/logging.xml                 |  153 +
 docs/user-manual/en/management.xml              | 1109 +++
 docs/user-manual/en/message-expiry.xml          |  101 +
 docs/user-manual/en/message-grouping.xml        |  207 +
 docs/user-manual/en/messaging-concepts.xml      |  268 +
 docs/user-manual/en/notice.xml                  |   37 +
 docs/user-manual/en/paging.xml                  |  216 +
 docs/user-manual/en/perf-tuning.xml             |  305 +
 docs/user-manual/en/persistence.xml             |  357 +
 docs/user-manual/en/pre-acknowledge.xml         |   99 +
 docs/user-manual/en/preface.xml                 |   87 +
 docs/user-manual/en/project-info.xml            |   91 +
 docs/user-manual/en/queue-attributes.xml        |  160 +
 docs/user-manual/en/rest.xml                    | 2151 ++++++
 docs/user-manual/en/scheduled-messages.xml      |   54 +
 docs/user-manual/en/security.xml                |  288 +
 docs/user-manual/en/send-guarantees.xml         |  153 +
 docs/user-manual/en/spring-integration.xml      |   93 +
 docs/user-manual/en/thread-pooling.xml          |  157 +
 docs/user-manual/en/tools.xml                   |  117 +
 docs/user-manual/en/transaction-config.xml      |   39 +
 docs/user-manual/en/undelivered-messages.xml    |  160 +
 docs/user-manual/en/using-core.xml              |  213 +
 docs/user-manual/en/using-jms.xml               |  313 +
 docs/user-manual/en/using-server.xml            |  385 ++
 docs/user-manual/en/vertx-integration.xml       |  115 +
 docs/user-manual/en/wildcard-routing.xml        |   43 +
 docs/user-manual/en/wildcard-syntax.xml         |   44 +
 docs/user-manual/pom.xml                        |  361 +
 docs/user-manual/publican.cfg                   |    7 +
 .../src/main/resources/schemaToTable.xsl        |  374 ++
 docs/user-manual/user-manual.xpr                |   66 +
 docs/user-manual/zh/appserver-integration.xml   | 1001 +++
 docs/user-manual/zh/architecture.xml            |   95 +
 docs/user-manual/zh/client-classpath.xml        |   47 +
 docs/user-manual/zh/client-reconnection.xml     |  116 +
 docs/user-manual/zh/clusters.xml                |  551 ++
 docs/user-manual/zh/configuration-index.xml     | 1284 ++++
 docs/user-manual/zh/configuring-transports.xml  |  376 ++
 docs/user-manual/zh/connection-ttl.xml          |  139 +
 docs/user-manual/zh/core-bridges.xml            |  179 +
 .../zh/diagrams/architecture-diagrams.odg       |  Bin 0 -> 10587 bytes
 .../zh/diagrams/ha-replicated-store.odg         |  Bin 0 -> 11620 bytes
 .../user-manual/zh/diagrams/ha-shared-store.odg |  Bin 0 -> 10650 bytes
 docs/user-manual/zh/diverts.xml                 |   86 +
 docs/user-manual/zh/duplicate-detection.xml     |  120 +
 docs/user-manual/zh/embedding-hornetq.xml       |  178 +
 docs/user-manual/zh/examples.xml                |  427 ++
 docs/user-manual/zh/filter-expressions.xml      |   71 +
 docs/user-manual/zh/flow-control.xml            |  243 +
 docs/user-manual/zh/ha.xml                      |  283 +
 docs/user-manual/zh/images/architecture1.jpg    |  Bin 0 -> 19948 bytes
 docs/user-manual/zh/images/architecture2.jpg    |  Bin 0 -> 18718 bytes
 docs/user-manual/zh/images/architecture3.jpg    |  Bin 0 -> 12274 bytes
 docs/user-manual/zh/images/console1.png         |  Bin 0 -> 81814 bytes
 .../zh/images/ha-replicated-store.png           |  Bin 0 -> 21496 bytes
 docs/user-manual/zh/images/ha-shared-store.png  |  Bin 0 -> 14147 bytes
 .../zh/images/hornetQ-banner_final.png          |  Bin 0 -> 109633 bytes
 .../zh/images/hornetQ_logo_600px.png            |  Bin 0 -> 23866 bytes
 docs/user-manual/zh/intercepting-operations.xml |   71 +
 docs/user-manual/zh/interoperability.xml        |  142 +
 docs/user-manual/zh/jms-bridge.xml              |  382 ++
 docs/user-manual/zh/jms-core-mapping.xml        |   42 +
 docs/user-manual/zh/large-messages.xml          |  234 +
 docs/user-manual/zh/last-value-queues.xml       |   66 +
 docs/user-manual/zh/libaio.xml                  |  114 +
 docs/user-manual/zh/logging.xml                 |   46 +
 docs/user-manual/zh/management.xml              |  805 +++
 docs/user-manual/zh/master.xml                  |  128 +
 docs/user-manual/zh/message-expiry.xml          |   81 +
 docs/user-manual/zh/message-grouping.xml        |  149 +
 docs/user-manual/zh/messaging-concepts.xml      |  164 +
 docs/user-manual/zh/notice.xml                  |   27 +
 docs/user-manual/zh/paging.xml                  |  198 +
 docs/user-manual/zh/perf-tuning.xml             |  233 +
 docs/user-manual/zh/persistence.xml             |  263 +
 docs/user-manual/zh/pre-acknowledge.xml         |   72 +
 docs/user-manual/zh/preface.xml                 |   68 +
 docs/user-manual/zh/project-info.xml            |   89 +
 docs/user-manual/zh/queue-attributes.xml        |  120 +
 docs/user-manual/zh/scheduled-messages.xml      |   47 +
 docs/user-manual/zh/security.xml                |  235 +
 docs/user-manual/zh/send-guarantees.xml         |  102 +
 docs/user-manual/zh/thread-pooling.xml          |  108 +
 docs/user-manual/zh/transaction-config.xml      |   29 +
 docs/user-manual/zh/undelivered-messages.xml    |  118 +
 docs/user-manual/zh/using-core.xml              |  163 +
 docs/user-manual/zh/using-jms.xml               |  273 +
 docs/user-manual/zh/using-server.xml            |  312 +
 docs/user-manual/zh/wildcard-routing.xml        |   37 +
 docs/user-manual/zh/wildcard-syntax.xml         |   37 +
 etc/IDEA-style.jar                              |  Bin 0 -> 3551 bytes
 etc/checkstyle.xml                              |   75 +
 etc/findbugs-exclude.xml                        |  148 +
 etc/license-header.txt                          |   11 +
 etc/org.eclipse.jdt.core.prefs                  |  305 +
 etc/org.eclipse.jdt.ui.prefs                    |  119 +
 examples/core/embedded-remote/pom.xml           |  113 +
 examples/core/embedded-remote/readme.html       |   85 +
 .../core/example/EmbeddedRemoteExample.java     |  111 +
 .../hornetq/core/example/EmbeddedServer.java    |   69 +
 examples/core/embedded/pom.xml                  |   78 +
 examples/core/embedded/readme.html              |   97 +
 .../hornetq/core/example/EmbeddedExample.java   |  119 +
 examples/core/microcontainer/pom.xml            |   84 +
 examples/core/microcontainer/readme.html        |   82 +
 .../example/EmbeddedMicroContainerExample.java  |  108 +
 .../src/main/resources/hornetq-beans.xml        |   36 +
 .../main/resources/hornetq-configuration.xml    |   29 +
 examples/core/perf/perf.properties              |   21 +
 examples/core/perf/pom.xml                      |  180 +
 .../java/org/hornetq/core/example/PerfBase.java |  550 ++
 .../org/hornetq/core/example/PerfListener.java  |   55 +
 .../org/hornetq/core/example/PerfParams.java    |  299 +
 .../org/hornetq/core/example/PerfSender.java    |   55 +
 .../main/resources/server0/hornetq-beans.xml    |   17 +
 .../hornetq-configuration-messaging-lab.xml     |   40 +
 .../resources/server0/hornetq-configuration.xml |   53 +
 examples/core/pom.xml                           |   20 +
 examples/core/twitter-connector/pom.xml         |  184 +
 examples/core/twitter-connector/readme.html     |   96 +
 .../core/example/TwitterConnectorExample.java   |  117 +
 .../main/resources/server0/hornetq-beans.xml    |   59 +
 .../resources/server0/hornetq-configuration.xml |   71 +
 .../src/main/resources/server0/hornetq-jms.xml  |   19 +
 .../main/resources/server0/hornetq-users.xml    |    7 +
 examples/core/vertx-connector/pom.xml           |  181 +
 examples/core/vertx-connector/readme.html       |   84 +
 .../hornetq/core/example/ExampleVerticle.java   |   55 +
 .../core/example/VertxConnectorExample.java     |  114 +
 .../main/resources/server0/hornetq-beans.xml    |   59 +
 .../resources/server0/hornetq-configuration.xml |   61 +
 .../src/main/resources/server0/hornetq-jms.xml  |   19 +
 .../main/resources/server0/hornetq-users.xml    |    7 +
 examples/javaee/README.md                       |   12 +
 examples/javaee/ejb-jms-transaction/pom.xml     |   14 +
 examples/javaee/ejb-jms-transaction/readme.html |  203 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  502 ++
 .../javaee/example/EJBClientExample.java        |   94 +
 .../javaee/example/server/SendMessageBean.java  |  142 +
 .../example/server/SendMessageService.java      |   26 +
 .../main/resources/jboss-ejb-client.properties  |    7 +
 .../examples/MDBEJBTXRequiredRunnerTest.java    |   53 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/jca-config/pom.xml              |   64 +
 examples/javaee/jca-config/readme.html          |  109 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  493 ++
 .../configuration/standalone-example2.xml       |  496 ++
 .../javaee/example/MDBRemoteClientExample.java  |   64 +
 .../javaee/example/server/MDBQueueA.java        |   51 +
 .../javaee/example/server2/MDBQueueB.java       |   55 +
 .../javaee/example/server2/StatelessSender.java |   55 +
 .../example/server2/StatelessSenderService.java |   28 +
 .../main/resources/jboss-ejb-client.properties  |    7 +
 .../example/server/ExampleRunner2Test.java      |  103 +
 .../src/test/resources/arquillian.xml           |   48 +
 .../resources/jboss-deployment-structure.xml    |    7 +
 examples/javaee/jca-remote/pom.xml              |   64 +
 examples/javaee/jca-remote/readme.html          |  160 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  496 ++
 .../configuration/standalone-example2.xml       |  493 ++
 .../example/MDBRemoteServerClientExample.java   |   99 +
 .../hornetq/javaee/example/server/MDBQueue.java |   75 +
 .../javaee/examples/JCARemoteRunnerTest.java    |   86 +
 .../src/test/resources/arquillian.xml           |   47 +
 .../resources/jboss-deployment-structure.xml    |    7 +
 examples/javaee/jms-bridge/pom.xml              |   14 +
 examples/javaee/jms-bridge/readme.html          |  168 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  508 ++
 .../javaee/example/JMSBridgeExample.java        |  112 +
 .../javaee/examples/JMSBridgeRunnerTest.java    |   35 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/jms-context-injection/pom.xml   |   14 +
 .../javaee/jms-context-injection/readme.html    |  108 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  493 ++
 .../JmsContextInjectionClientExample.java       |   83 +
 .../server/JmsContextInjectionExample.java      |   76 +
 .../examples/JmsContextInjectionRunnerTest.java |   59 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/mdb-bmt/pom.xml                 |   14 +
 examples/javaee/mdb-bmt/readme.html             |  113 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../javaee/example/MDB_BMTClientExample.java    |   82 +
 .../javaee/example/server/MDB_BMTExample.java   |   73 +
 .../example/server/ExampleRunnerTest.java       |   50 +
 .../mdb-bmt/src/test/resources/arquillian.xml   |   34 +
 .../mdb-cmt-setrollbackonly-with-dlq/pom.xml    |   14 +
 .../readme.html                                 |  127 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  494 ++
 ...CMT_SetRollbackOnlyWithDLQClientExample.java |   99 +
 .../MDB_CMT_SetRollbackOnlyWithDLQExample.java  |   66 +
 .../MDBCMTSetRollbackOnlyWithDLQRunnerTest.java |   48 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/mdb-cmt-setrollbackonly/pom.xml |   14 +
 .../javaee/mdb-cmt-setrollbackonly/readme.html  |  112 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../MDB_CMT_SetRollbackOnlyClientExample.java   |   83 +
 .../server/MDB_CMT_SetRollbackOnlyExample.java  |   72 +
 .../MDBCMTSetRollbackOnlyRunnerTest.java        |   50 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/mdb-cmt-tx-local/pom.xml        |   14 +
 examples/javaee/mdb-cmt-tx-local/readme.html    |  125 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../example/MDB_CMT_TxLocalClientExample.java   |   83 +
 .../example/server/MDB_CMT_TxLocalExample.java  |   92 +
 .../example/MDBCMTSetLocalTXRunnerTest.java     |   51 +
 .../src/test/resources/arquillian.xml           |   34 +
 .../javaee/mdb-cmt-tx-not-supported/pom.xml     |   14 +
 .../javaee/mdb-cmt-tx-not-supported/readme.html |  116 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../MDB_CMT_TxNotSupportedClientExample.java    |   82 +
 .../example/server/MDB_CMT_TxNotSupported.java  |   75 +
 .../MDBCMTSetTXNotSupportedRunnerTest.java      |   51 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/mdb-cmt-tx-required/pom.xml     |   14 +
 examples/javaee/mdb-cmt-tx-required/readme.html |  115 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../MDB_CMT_TxRequiredClientExample.java        |   88 +
 .../server/MDB_CMT_TxRequiredExample.java       |   56 +
 .../examples/MDBCMTSetTXRequiredRunnerTest.java |   54 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/javaee/mdb-message-selector/pom.xml    |   14 +
 .../javaee/mdb-message-selector/readme.html     |  127 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../MDBMessageSelectorClientExample.java        |   94 +
 .../server/MDBMessageSelectorExample.java       |   60 +
 .../MDBCMTSetMessageSelectorRunnerTest.java     |   50 +
 .../src/test/resources/arquillian.xml           |   34 +
 .../javaee/mdb-remote-failover-static/pom.xml   |   90 +
 .../mdb-remote-failover-static/readme.html      |  165 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-backup.xml         |  511 ++
 .../configuration/standalone-example.xml        |  508 ++
 .../configuration/standalone-live.xml           |  513 ++
 .../MDBRemoteFailoverStaticClientExample.java   |  126 +
 .../server/MDBRemoteFailoverStaticExample.java  |   86 +
 .../javaee/example/server/ServerKiller.java     |   21 +
 .../examples/FailoverStaticRunnerTest.java      |   98 +
 .../src/test/resources/arquillian.xml           |   57 +
 .../resources/jboss-deployment-structure.xml    |    7 +
 examples/javaee/mdb-remote-failover/pom.xml     |   90 +
 examples/javaee/mdb-remote-failover/readme.html |  165 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-backup.xml         |  519 ++
 .../configuration/standalone-example.xml        |  504 ++
 .../configuration/standalone-live.xml           |  521 ++
 .../example/MDBRemoteFailoverClientExample.java |  118 +
 .../server/MDBRemoteFailoverExample.java        |   94 +
 .../javaee/example/server/ServerKiller.java     |   21 +
 .../javaee/examples/FailoverRunnerTest.java     |   94 +
 .../src/test/resources/arquillian.xml           |   57 +
 .../resources/jboss-deployment-structure.xml    |    7 +
 examples/javaee/mdb-tx-send/pom.xml             |   14 +
 examples/javaee/mdb-tx-send/readme.html         |  155 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  493 ++
 .../example/MDBMessageSendTxClientExample.java  |   97 +
 .../example/server/MDBMessageSendTxExample.java |   95 +
 .../javaee/examples/MDBCMTTxSendRunnerTest.java |   54 +
 .../src/test/resources/arquillian.xml           |   34 +
 .../resources/jboss-deployment-structure.xml    |    7 +
 examples/javaee/pom.xml                         |  181 +
 examples/javaee/xarecovery/pom.xml              |   14 +
 examples/javaee/xarecovery/readme.html          |  201 +
 .../configuration/application-roles.properties  |   22 +
 .../configuration/application-users.properties  |   24 +
 .../standalone/configuration/logging.properties |   52 +
 .../configuration/mgmt-users.properties         |   24 +
 .../configuration/standalone-example.xml        |  489 ++
 .../example/XARecoveryExampleStepOne.java       |   77 +
 .../example/XARecoveryExampleStepTwo.java       |  101 +
 .../example/server/XARecoveryExampleBean.java   |  171 +
 .../server/XARecoveryExampleService.java        |   23 +
 .../main/resources/jboss-ejb-client.properties  |    7 +
 .../javaee/examples/XARecoveryRunnerTest.java   |   97 +
 .../src/test/resources/arquillian.xml           |   34 +
 examples/jms/README.md                          |   29 +
 examples/jms/aerogear/pom.xml                   |  139 +
 examples/jms/aerogear/readme.html               |  135 +
 .../hornetq/jms/example/AerogearExample.java    |   92 +
 .../hornetq/server0/hornetq-configuration.xml   |   61 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/applet/applet.html                 |   17 +
 examples/jms/applet/pom.xml                     |  129 +
 examples/jms/applet/readme.html                 |   21 +
 .../org/hornetq/jms/example/AppletExample.java  |  290 +
 .../jms/example/HttpStaticFileServer.java       |   77 +
 .../example/HttpStaticFileServerHandler.java    |  185 +
 .../HttpStaticFileServerPipelineFactory.java    |   64 +
 .../hornetq/server0/hornetq-configuration.xml   |   41 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/application-layer-failover/pom.xml |  143 +
 .../jms/application-layer-failover/readme.html  |  149 +
 .../ApplicationLayerFailoverExample.java        |  237 +
 .../hornetq/server0/hornetq-configuration.xml   |   39 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   40 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/bridge/pom.xml                     |  152 +
 examples/jms/bridge/readme.html                 |  215 +
 .../org/hornetq/jms/example/BridgeExample.java  |  184 +
 .../jms/example/HatColourChangeTransformer.java |   42 +
 .../hornetq/server0/hornetq-configuration.xml   |   72 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   44 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/browser/pom.xml                    |  114 +
 examples/jms/browser/readme.html                |  128 +
 .../jms/example/QueueBrowserExample.java        |  119 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/client-kickoff/pom.xml             |  139 +
 examples/jms/client-kickoff/readme.html         |  137 +
 .../jms/example/ClientKickoffExample.java       |  126 +
 .../hornetq/server0/hornetq-configuration.xml   |   30 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   14 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../jms/client-side-failoverlistener/pom.xml    |  168 +
 .../client-side-failoverlistener/readme.html    |   94 +
 .../ClientSideFailoverListerExample.java        |  135 +
 .../hornetq/server0/hornetq-configuration.xml   |   67 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   33 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   67 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/client-side-load-balancing/pom.xml |  198 +
 .../jms/client-side-load-balancing/readme.html  |  149 +
 .../example/ClientSideLoadBalancingExample.java |  157 +
 .../hornetq/server0/hornetq-configuration.xml   |   73 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   17 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   72 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   17 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   72 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   17 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 .../jms/clustered-durable-subscription/pom.xml  |  167 +
 .../clustered-durable-subscription/readme.html  |  194 +
 .../ClusteredDurableSubscriptionExample.java    |  165 +
 .../hornetq/server0/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/clustered-grouping/pom.xml         |  199 +
 examples/jms/clustered-grouping/readme.html     |  246 +
 .../jms/example/ClusteredGroupingExample.java   |  200 +
 .../hornetq/server0/hornetq-configuration.xml   |   83 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   80 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   80 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 examples/jms/clustered-jgroups/pom.xml          |  151 +
 examples/jms/clustered-jgroups/readme.html      |  188 +
 .../jms/example/ClusteredJgroupsExample.java    |  151 +
 .../hornetq/server0/client-jndi.properties      |    3 +
 .../resources/hornetq/server0/hornetq-beans.xml |   60 +
 .../hornetq/server0/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server0/test-jgroups-file_ping.xml  |   52 +
 .../hornetq/server1/client-jndi.properties      |    3 +
 .../resources/hornetq/server1/hornetq-beans.xml |   59 +
 .../hornetq/server1/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server1/test-jgroups-file_ping.xml  |   52 +
 examples/jms/clustered-queue/pom.xml            |  147 +
 examples/jms/clustered-queue/readme.html        |  177 +
 .../jms/example/ClusteredQueueExample.java      |  151 +
 .../hornetq/server0/hornetq-configuration.xml   |   74 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/clustered-standalone/pom.xml       |  178 +
 examples/jms/clustered-standalone/readme.html   |   51 +
 .../jms/example/ClusteredStandaloneExample.java |  197 +
 .../hornetq/server0/hornetq-configuration.xml   |   74 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 examples/jms/clustered-static-discovery/pom.xml |  191 +
 .../jms/clustered-static-discovery/readme.html  |  180 +
 .../example/StaticClusteredQueueExample.java    |  201 +
 .../hornetq/server0/hornetq-configuration.xml   |   64 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../resources/hornetq/server0/jndi.properties   |    2 +
 .../hornetq/server1/hornetq-configuration.xml   |   64 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../resources/hornetq/server1/jndi.properties   |    2 +
 .../hornetq/server2/hornetq-configuration.xml   |   77 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   45 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 .../resources/hornetq/server2/jndi.properties   |   15 +
 .../hornetq/server3/hornetq-configuration.xml   |   77 +
 .../resources/hornetq/server3/hornetq-jms.xml   |   45 +
 .../resources/hornetq/server3/hornetq-users.xml |    7 +
 .../resources/hornetq/server3/jndi.properties   |    2 +
 examples/jms/clustered-static-oneway/pom.xml    |  169 +
 .../jms/clustered-static-oneway/readme.html     |  229 +
 .../jms/example/ClusterStaticOnewayExample.java |  186 +
 .../hornetq/server0/hornetq-configuration.xml   |   77 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../resources/hornetq/server0/jndi.properties   |    2 +
 .../hornetq/server1/hornetq-configuration.xml   |   77 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../resources/hornetq/server1/jndi.properties   |    2 +
 .../hornetq/server2/hornetq-configuration.xml   |   69 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   45 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 .../resources/hornetq/server2/jndi.properties   |   15 +
 examples/jms/clustered-topic/pom.xml            |  167 +
 examples/jms/clustered-topic/readme.html        |  174 +
 .../jms/example/ClusteredTopicExample.java      |  149 +
 .../hornetq/server0/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   74 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../jms/colocated-failover-scale-down/pom.xml   |  153 +
 .../colocated-failover-scale-down/readme.html   |  160 +
 .../ColocatedFailoverScaleDownExample.java      |  134 +
 .../hornetq/server0/hornetq-configuration.xml   |   85 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   86 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/colocated-failover/pom.xml         |  153 +
 examples/jms/colocated-failover/readme.html     |  164 +
 .../jms/example/ColocatedFailoverExample.java   |  142 +
 .../hornetq/server0/hornetq-configuration.xml   |   80 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   80 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/consumer-rate-limit/pom.xml        |  116 +
 examples/jms/consumer-rate-limit/readme.html    |  163 +
 .../jms/example/ConsumerRateLimitExample.java   |  132 +
 .../hornetq/server0/client-jndi.properties      |    3 +
 .../resources/hornetq/server0/hornetq-beans.xml |   59 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/dead-letter/pom.xml                |  116 +
 examples/jms/dead-letter/readme.html            |  207 +
 .../hornetq/jms/example/DeadLetterExample.java  |  151 +
 .../hornetq/server0/client-jndi.properties      |    3 +
 .../resources/hornetq/server0/hornetq-beans.xml |   60 +
 .../hornetq/server0/hornetq-configuration.xml   |   50 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/delayed-redelivery/pom.xml         |  114 +
 examples/jms/delayed-redelivery/readme.html     |  168 +
 .../jms/example/DelayedRedeliveryExample.java   |  142 +
 .../hornetq/server0/client-jndi.properties      |    3 +
 .../resources/hornetq/server0/hornetq-beans.xml |   60 +
 .../hornetq/server0/hornetq-configuration.xml   |   49 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/divert/pom.xml                     |  152 +
 examples/jms/divert/readme.html                 |  419 ++
 .../example/AddForwardingTimeTransformer.java   |   35 +
 .../org/hornetq/jms/example/DivertExample.java  |  246 +
 .../hornetq/server0/hornetq-configuration.xml   |   96 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   38 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   45 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/durable-subscription/pom.xml       |  116 +
 examples/jms/durable-subscription/readme.html   |  140 +
 .../jms/example/DurableSubscriptionExample.java |  129 +
 .../hornetq/server0/client-jndi.properties      |    3 +
 .../resources/hornetq/server0/hornetq-beans.xml |   60 +
 .../hornetq/server0/hornetq-configuration.xml   |   44 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/embedded-simple/pom.xml            |  113 +
 examples/jms/embedded-simple/readme.html        |   52 +
 .../hornetq/jms/example/EmbeddedExample.java    |   88 +
 .../main/resources/hornetq-configuration.xml    |   34 +
 .../src/main/resources/hornetq-jms.xml          |   19 +
 .../src/main/resources/hornetq-users.xml        |    7 +
 examples/jms/embedded/pom.xml                   |  113 +
 examples/jms/embedded/readme.html               |  109 +
 .../hornetq/jms/example/EmbeddedExample.java    |  132 +
 examples/jms/expiry/pom.xml                     |  116 +
 examples/jms/expiry/readme.html                 |  187 +
 .../org/hornetq/jms/example/ExpiryExample.java  |  135 +
 .../hornetq/server0/hornetq-configuration.xml   |   50 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/ha-policy-autobackup/pom.xml       |  153 +
 .../jms/example/HAPolicyAutoBackupExample.java  |  173 +
 .../hornetq/server0/hornetq-configuration.xml   |   82 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   82 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../jms/hornetq-jms-examples-common/common.css  |   29 +
 .../config/hornetq-example-beans.xml            |  165 +
 .../config/logging.properties                   |   35 +
 .../config/server.properties                    |    1 +
 .../images/hornetQ-banner_final.png             |  Bin 0 -> 109633 bytes
 .../jms/hornetq-jms-examples-common/pom.xml     |   37 +
 .../hornetq-jms-examples-common/prettify.css    |    1 +
 .../jms/hornetq-jms-examples-common/prettify.js |   23 +
 .../org/hornetq/common/example/DummyXid.java    |  207 +
 .../hornetq/common/example/HornetQExample.java  |  234 +
 examples/jms/hornetq-ra-rar/pom.xml             |   82 +
 .../hornetq-ra-rar/src/main/resources/ra.xml    |  304 +
 examples/jms/http-transport/pom.xml             |  122 +
 examples/jms/http-transport/readme.html         |  115 +
 .../jms/example/HttpTransportExample.java       |  102 +
 .../hornetq/server0/hornetq-configuration.xml   |   46 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../jms/instantiate-connection-factory/pom.xml  |  126 +
 .../instantiate-connection-factory/readme.html  |  118 +
 .../InstantiateConnectionFactoryExample.java    |  110 +
 .../hornetq/server0/hornetq-configuration.xml   |   45 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   10 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/interceptor/pom.xml                |  121 +
 examples/jms/interceptor/readme.html            |  157 +
 .../hornetq/jms/example/InterceptorExample.java |  102 +
 .../hornetq/jms/example/SimpleInterceptor.java  |   49 +
 .../hornetq/server0/hornetq-configuration.xml   |   47 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/jaas/pom.xml                       |  139 +
 examples/jms/jaas/readme.html                   |   98 +
 .../jms/example/ExampleCallbackHandler.java     |   34 +
 .../jms/example/ExampleConfiguration.java       |   54 +
 .../hornetq/jms/example/ExampleLoginModule.java |  138 +
 .../org/hornetq/jms/example/JAASExample.java    |   99 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 examples/jms/jms-auto-closeable/pom.xml         |  116 +
 examples/jms/jms-auto-closeable/readme.html     |   76 +
 .../jms/example/JMSAutoCloseableExample.java    |   78 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/jms-bridge/jms-bridge.png          |  Bin 0 -> 93885 bytes
 examples/jms/jms-bridge/pom.xml                 |  165 +
 examples/jms/jms-bridge/readme.html             |  220 +
 .../hornetq/jms/example/JMSBridgeExample.java   |  171 +
 .../src/main/resources/hornetq-beans.xml        |  234 +
 .../hornetq/server0/hornetq-configuration.xml   |   35 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   27 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../resources/hornetq/server0/jndi.properties   |    2 +
 .../hornetq/server1/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   27 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../resources/hornetq/server1/jndi.properties   |    2 +
 examples/jms/jms-completion-listener/pom.xml    |  116 +
 .../jms/jms-completion-listener/readme.html     |   92 +
 .../example/JMSCompletionListenerExample.java   |  100 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/jms-context/pom.xml                |  116 +
 examples/jms/jms-context/readme.html            |   74 +
 .../hornetq/jms/example/JMSContextExample.java  |   77 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/jms-shared-consumer/pom.xml        |  116 +
 examples/jms/jms-shared-consumer/readme.html    |   99 +
 .../jms/example/JMSSharedConsumerExample.java   |  107 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/jmx/pom.xml                        |  144 +
 examples/jms/jmx/readme.html                    |  161 +
 .../org/hornetq/jms/example/JMXExample.java     |  137 +
 .../hornetq/server0/hornetq-configuration.xml   |   45 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/large-message/pom.xml              |  122 +
 examples/jms/large-message/readme.html          |  179 +
 .../jms/example/LargeMessageExample.java        |  213 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/last-value-queue/pom.xml           |  116 +
 examples/jms/last-value-queue/readme.html       |  142 +
 .../jms/example/LastValueQueueExample.java      |  127 +
 .../hornetq/server0/hornetq-configuration.xml   |   50 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   18 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/management-notifications/pom.xml   |  116 +
 .../jms/management-notifications/readme.html    |  194 +
 .../example/ManagementNotificationExample.java  |  129 +
 .../hornetq/server0/hornetq-configuration.xml   |   58 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   23 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/management/pom.xml                 |  116 +
 examples/jms/management/readme.html             |  189 +
 .../hornetq/jms/example/ManagementExample.java  |  148 +
 .../hornetq/server0/hornetq-configuration.xml   |   56 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   18 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/message-counters/pom.xml           |  139 +
 examples/jms/message-counters/readme.html       |  177 +
 .../jms/example/MessageCounterExample.java      |  156 +
 .../hornetq/server0/hornetq-configuration.xml   |   64 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/message-group/pom.xml              |  116 +
 examples/jms/message-group/readme.html          |  132 +
 .../jms/example/MessageGroupExample.java        |  149 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/message-group2/pom.xml             |  116 +
 examples/jms/message-group2/readme.html         |  140 +
 .../jms/example/MessageGroup2Example.java       |  160 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/message-priority/pom.xml           |  116 +
 examples/jms/message-priority/readme.html       |  137 +
 .../jms/example/MessagePriorityExample.java     |  153 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/multiple-failover-failback/pom.xml |  199 +
 .../MultipleFailoverFailbackExample.java        |  157 +
 .../hornetq/server0/hornetq-configuration.xml   |   69 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   33 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   69 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   70 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 examples/jms/multiple-failover/pom.xml          |  199 +
 .../jms/example/MultipleFailoverExample.java    |  158 +
 .../hornetq/server0/hornetq-configuration.xml   |   69 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   33 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   67 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   67 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 examples/jms/no-consumer-buffering/pom.xml      |  116 +
 examples/jms/no-consumer-buffering/readme.html  |  185 +
 .../jms/example/NoConsumerBufferingExample.java |  133 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/non-transaction-failover/pom.xml   |  167 +
 .../jms/non-transaction-failover/readme.html    |  136 +
 .../example/NonTransactionFailoverExample.java  |  137 +
 .../hornetq/server0/hornetq-configuration.xml   |   67 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   68 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/paging/pom.xml                     |  116 +
 examples/jms/paging/readme.html                 |  166 +
 .../org/hornetq/jms/example/PagingExample.java  |  155 +
 .../hornetq/server0/hornetq-configuration.xml   |   67 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   23 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/perf/pom.xml                       |  180 +
 examples/jms/perf/readme.html                   |   20 +
 .../java/org/hornetq/jms/example/PerfBase.java  |  524 ++
 .../org/hornetq/jms/example/PerfListener.java   |   60 +
 .../org/hornetq/jms/example/PerfParams.java     |  183 +
 .../org/hornetq/jms/example/PerfSender.java     |   60 +
 .../src/main/resources/client.jndi.properties   |    3 +
 .../hornetq-configuration-messaging-lab.xml     |   32 +
 .../hornetq/server0/hornetq-configuration.xml   |   34 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   18 +
 .../jms/perf/src/main/resources/perf.properties |   13 +
 examples/jms/pom.xml                            |  121 +
 examples/jms/pre-acknowledge/pom.xml            |  116 +
 examples/jms/pre-acknowledge/readme.html        |  133 +
 .../jms/example/PreacknowledgeExample.java      |  148 +
 .../hornetq/server0/hornetq-configuration.xml   |   46 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/producer-rate-limit/pom.xml        |  116 +
 examples/jms/producer-rate-limit/readme.html    |  156 +
 .../jms/example/ProducerRateLimitExample.java   |  128 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   24 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/proton-j/pom.xml                   |  122 +
 examples/jms/proton-j/readme.html               |   75 +
 .../org/hornetq/jms/example/ProtonJExample.java |   73 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |    6 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/proton-ruby/pom.xml                |  100 +
 examples/jms/proton-ruby/readme.html            |   35 +
 .../hornetq/server0/hornetq-configuration.xml   |   41 +
 .../resources/hornetq/server0/hornetq-jms.xml   |    9 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../jms/proton-ruby/src/main/scripts/receive.rb |   58 +
 .../jms/proton-ruby/src/main/scripts/send.rb    |   33 +
 .../jms/queue-message-redistribution/pom.xml    |  167 +
 .../queue-message-redistribution/readme.html    |  225 +
 .../QueueMessageRedistributionExample.java      |  180 +
 .../hornetq/server0/hornetq-configuration.xml   |   86 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   87 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/queue-requestor/pom.xml            |  116 +
 examples/jms/queue-requestor/readme.html        |  120 +
 .../jms/example/QueueRequestorExample.java      |  111 +
 .../jms/example/TextReverserService.java        |  123 +
 .../hornetq/server0/hornetq-configuration.xml   |   50 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/queue-selector/pom.xml             |  116 +
 examples/jms/queue-selector/readme.html         |  146 +
 .../jms/example/QueueSelectorExample.java       |  156 +
 .../hornetq/server0/hornetq-configuration.xml   |   41 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/queue/pom.xml                      |  116 +
 examples/jms/queue/readme.html                  |   94 +
 .../org/hornetq/jms/example/QueueExample.java   |   97 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/reattach-node/pom.xml              |  125 +
 examples/jms/reattach-node/readme.html          |  132 +
 .../hornetq/jms/example/ReattachExample.java    |  167 +
 .../hornetq/server0/hornetq-configuration.xml   |   66 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   51 +
 .../resources/hornetq/server0/hornetq-users.xml |   11 +
 examples/jms/replicated-failback-static/pom.xml |  167 +
 .../jms/replicated-failback-static/readme.html  |  153 +
 .../ReplicatedFailbackStaticExample.java        |  162 +
 .../hornetq/server0/hornetq-configuration.xml   |   65 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   33 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   66 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/replicated-failback/pom.xml        |  167 +
 examples/jms/replicated-failback/readme.html    |  153 +
 .../jms/example/ReplicatedFailbackExample.java  |  162 +
 .../hornetq/server0/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   33 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   79 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../jms/replicated-multiple-failover/pom.xml    |  199 +
 .../replicated-multiple-failover/readme.html    |  151 +
 .../ReplicatedMultipleFailoverExample.java      |  158 +
 .../hornetq/server0/hornetq-configuration.xml   |   69 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   33 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   73 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   72 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 .../jms/replicated-transaction-failover/pom.xml |  167 +
 .../replicated-transaction-failover/readme.html |  129 +
 .../ReplicatedTransactionFailoverExample.java   |  176 +
 .../hornetq/server0/hornetq-configuration.xml   |   70 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/request-reply/pom.xml              |  116 +
 examples/jms/request-reply/readme.html          |  161 +
 .../jms/example/RequestReplyExample.java        |  222 +
 .../hornetq/server0/hornetq-configuration.xml   |   49 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/rest/dup-send/README.txt           |   41 +
 examples/jms/rest/dup-send/pom.xml              |  141 +
 .../jms/rest/dup-send/src/main/java/Order.java  |   77 +
 .../rest/dup-send/src/main/java/PostOrder.java  |   74 +
 .../dup-send/src/main/java/PostOrderWithId.java |   44 +
 .../dup-send/src/main/java/ReceiveOrder.java    |   55 +
 .../src/main/resources/hornetq-client.xml       |   12 +
 .../main/resources/hornetq-configuration.xml    |   38 +
 .../dup-send/src/main/resources/hornetq-jms.xml |   19 +
 .../src/main/resources/hornetq-rest.xml         |    3 +
 .../src/main/resources/hornetq-users.xml        |    7 +
 .../dup-send/src/main/webapp/WEB-INF/web.xml    |   37 +
 examples/jms/rest/javascript-chat/README.txt    |   16 +
 examples/jms/rest/javascript-chat/pom.xml       |  158 +
 .../main/resources/hornetq-configuration.xml    |   34 +
 .../src/main/resources/hornetq-jms.xml          |   19 +
 .../src/main/resources/hornetq-users.xml        |    7 +
 .../src/main/webapp/WEB-INF/web.xml             |   31 +
 .../javascript-chat/src/main/webapp/index.html  |  170 +
 .../messaging/test/AutoAckTopicTest.java        |   91 +
 examples/jms/rest/jms-to-rest/README.txt        |   49 +
 examples/jms/rest/jms-to-rest/pom.xml           |  141 +
 examples/jms/rest/jms-to-rest/postOrder.py      |   28 +
 examples/jms/rest/jms-to-rest/receiveOrder.py   |   52 +
 .../jms-to-rest/src/main/java/JmsHelper.java    |   41 +
 .../jms-to-rest/src/main/java/JmsReceive.java   |   60 +
 .../rest/jms-to-rest/src/main/java/JmsSend.java |   49 +
 .../rest/jms-to-rest/src/main/java/Order.java   |   77 +
 .../jms-to-rest/src/main/java/RestReceive.java  |   59 +
 .../jms-to-rest/src/main/java/RestSend.java     |   39 +
 .../src/main/resources/hornetq-client.xml       |   12 +
 .../main/resources/hornetq-configuration.xml    |   38 +
 .../src/main/resources/hornetq-jms.xml          |   19 +
 .../src/main/resources/hornetq-users.xml        |    7 +
 .../jms-to-rest/src/main/webapp/WEB-INF/web.xml |   31 +
 examples/jms/rest/pom.xml                       |   22 +
 examples/jms/rest/push/README.txt               |   32 +
 examples/jms/rest/push/pom.xml                  |  147 +
 .../jms/rest/push/src/main/java/JmsHelper.java  |   39 +
 examples/jms/rest/push/src/main/java/Order.java |   77 +
 .../jms/rest/push/src/main/java/PostOrder.java  |   49 +
 .../jms/rest/push/src/main/java/PushReg.java    |   52 +
 .../push/src/main/java/ReceiveShipping.java     |   59 +
 .../push/src/main/resources/hornetq-client.xml  |   12 +
 .../main/resources/hornetq-configuration.xml    |   38 +
 .../push/src/main/resources/hornetq-jms.xml     |   22 +
 .../push/src/main/resources/hornetq-users.xml   |    7 +
 .../src/main/resources/test-realm.properties    |    1 +
 .../rest/push/src/main/webapp/WEB-INF/web.xml   |   50 +
 examples/jms/scale-down/pom.xml                 |  153 +
 examples/jms/scale-down/readme.html             |  150 +
 .../hornetq/jms/example/ScaleDownExample.java   |  131 +
 .../hornetq/server0/hornetq-configuration.xml   |  106 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   88 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   30 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/scheduled-message/pom.xml          |  116 +
 examples/jms/scheduled-message/readme.html      |  112 +
 .../jms/example/ScheduledMessageExample.java    |  110 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/security/pom.xml                   |  116 +
 examples/jms/security/readme.html               |  304 +
 .../hornetq/jms/example/SecurityExample.java    |  320 +
 .../hornetq/server0/hornetq-configuration.xml   |   60 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   28 +
 .../resources/hornetq/server0/hornetq-users.xml |   25 +
 examples/jms/send-acknowledgements/pom.xml      |  116 +
 examples/jms/send-acknowledgements/readme.html  |  118 +
 .../example/SendAcknowledgementsExample.java    |  121 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/spring-integration/pom.xml         |  105 +
 examples/jms/spring-integration/readme.html     |   17 +
 .../hornetq/jms/example/ExampleListener.java    |   40 +
 .../org/hornetq/jms/example/MessageSender.java  |   66 +
 .../org/hornetq/jms/example/SpringExample.java  |   33 +
 .../main/resources/hornetq-configuration.xml    |   34 +
 .../src/main/resources/hornetq-jms.xml          |   19 +
 .../src/main/resources/hornetq-users.xml        |    7 +
 .../src/main/resources/spring-jms-beans.xml     |   25 +
 examples/jms/ssl-enabled/pom.xml                |  116 +
 examples/jms/ssl-enabled/readme.html            |  138 +
 .../org/hornetq/jms/example/SSLExample.java     |  100 +
 .../hornetq/server0/hornetq-configuration.xml   |   53 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server0/hornetq.example.keystore    |  Bin 0 -> 1259 bytes
 .../hornetq/server0/hornetq.example.truststore  |  Bin 0 -> 852 bytes
 examples/jms/static-selector-jms/pom.xml        |  116 +
 examples/jms/static-selector-jms/readme.html    |  139 +
 .../jms/example/StaticSelectorJMSExample.java   |  150 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/static-selector/pom.xml            |  116 +
 examples/jms/static-selector/readme.html        |  141 +
 .../jms/example/StaticSelectorExample.java      |  150 +
 .../hornetq/server0/hornetq-configuration.xml   |   49 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../aerogear-chat/aerogear-chat.css             |   83 +
 .../aerogear-chat/aerogear-chat.js              |   97 +
 .../aerogear-chat/aerogear-index.html           |   78 +
 .../aerogear-chat/aerogear.min.js               |   19 +
 .../jms/stomp-websockets/aerogear-chat/stomp.js |  373 ++
 examples/jms/stomp-websockets/chat/chat.css     |   99 +
 examples/jms/stomp-websockets/chat/chat.js      |   53 +
 examples/jms/stomp-websockets/chat/index.html   |   54 +
 examples/jms/stomp-websockets/chat/stomp.js     |  370 +
 examples/jms/stomp-websockets/pom.xml           |  130 +
 examples/jms/stomp-websockets/readme.html       |   37 +
 .../jms/example/StompWebSocketExample.java      |   87 +
 .../hornetq/server0/hornetq-configuration.xml   |   49 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/stomp/pom.xml                      |  121 +
 examples/jms/stomp/readme.html                  |  111 +
 .../org/hornetq/jms/example/StompExample.java   |  132 +
 .../hornetq/server0/hornetq-configuration.xml   |   51 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/stomp1.1/pom.xml                   |  121 +
 examples/jms/stomp1.1/readme.html               |  119 +
 .../org/hornetq/jms/example/StompExample.java   |  153 +
 .../hornetq/server0/hornetq-configuration.xml   |   51 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/stomp1.2/pom.xml                   |  121 +
 examples/jms/stomp1.2/readme.html               |  119 +
 .../org/hornetq/jms/example/StompExample.java   |  152 +
 .../hornetq/server0/hornetq-configuration.xml   |   51 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/stop-server-failover/pom.xml       |  167 +
 examples/jms/stop-server-failover/readme.html   |  136 +
 .../jms/example/StopServerFailoverExample.java  |  138 +
 .../hornetq/server0/hornetq-configuration.xml   |   68 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   68 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   32 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/symmetric-cluster/pom.xml          |  295 +
 examples/jms/symmetric-cluster/readme.html      |  257 +
 .../jms/example/SymmetricClusterExample.java    |  239 +
 .../hornetq/server0/hornetq-configuration.xml   |   78 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   22 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   22 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 .../hornetq/server2/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server2/hornetq-jms.xml   |   22 +
 .../resources/hornetq/server2/hornetq-users.xml |    7 +
 .../hornetq/server3/hornetq-configuration.xml   |   76 +
 .../resources/hornetq/server3/hornetq-jms.xml   |   22 +
 .../resources/hornetq/server3/hornetq-users.xml |    7 +
 .../hornetq/server4/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server4/hornetq-jms.xml   |   22 +
 .../resources/hornetq/server4/hornetq-users.xml |    7 +
 .../hornetq/server5/hornetq-configuration.xml   |   75 +
 .../resources/hornetq/server5/hornetq-jms.xml   |   22 +
 .../resources/hornetq/server5/hornetq-users.xml |    7 +
 examples/jms/temp-queue/pom.xml                 |  116 +
 examples/jms/temp-queue/readme.html             |  143 +
 .../jms/example/TemporaryQueueExample.java      |  133 +
 .../hornetq/server0/hornetq-configuration.xml   |   50 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/topic-hierarchies/pom.xml          |  116 +
 examples/jms/topic-hierarchies/readme.html      |  181 +
 .../jms/example/TopicHierarchyExample.java      |  135 +
 .../hornetq/server0/hornetq-configuration.xml   |   43 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   40 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/topic-selector-example1/pom.xml    |  116 +
 .../jms/topic-selector-example1/readme.html     |  160 +
 .../jms/example/TopicSelectorExample1.java      |  167 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/topic-selector-example2/pom.xml    |  116 +
 .../jms/topic-selector-example2/readme.html     |  138 +
 .../jms/example/TopicSelectorExample2.java      |  157 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/topic/pom.xml                      |  116 +
 examples/jms/topic/readme.html                  |  104 +
 .../org/hornetq/jms/example/TopicExample.java   |  107 +
 .../hornetq/server0/client-jndi.properties      |    3 +
 .../resources/hornetq/server0/hornetq-beans.xml |   59 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/transaction-failover/pom.xml       |  167 +
 examples/jms/transaction-failover/readme.html   |  129 +
 .../jms/example/TransactionFailoverExample.java |  176 +
 .../hornetq/server0/hornetq-configuration.xml   |   70 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../hornetq/server1/hornetq-configuration.xml   |   70 +
 .../resources/hornetq/server1/hornetq-jms.xml   |   31 +
 .../resources/hornetq/server1/hornetq-users.xml |    7 +
 examples/jms/transactional/pom.xml              |  116 +
 examples/jms/transactional/readme.html          |  129 +
 .../jms/example/TransactionalExample.java       |  141 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   19 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/xa-heuristic/pom.xml               |  139 +
 examples/jms/xa-heuristic/readme.html           |  228 +
 .../hornetq/jms/example/XAHeuristicExample.java |  252 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/xa-receive/pom.xml                 |  116 +
 examples/jms/xa-receive/readme.html             |  203 +
 .../hornetq/jms/example/XAReceiveExample.java   |  169 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/xa-send/pom.xml                    |  116 +
 examples/jms/xa-send/readme.html                |  196 +
 .../org/hornetq/jms/example/XASendExample.java  |  211 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 examples/jms/xa-with-jta/pom.xml                |  125 +
 examples/jms/xa-with-jta/readme.html            |  201 +
 .../hornetq/jms/example/XAwithJTAExample.java   |  218 +
 .../hornetq/server0/hornetq-configuration.xml   |   42 +
 .../resources/hornetq/server0/hornetq-jms.xml   |   20 +
 .../resources/hornetq/server0/hornetq-users.xml |    7 +
 .../src/main/resources/jbossts-properties.xml   |  179 +
 examples/pom.xml                                |   26 +
 examples/soak/normal/README                     |   77 +
 examples/soak/normal/build.xml                  |   92 +
 examples/soak/normal/server0/hornetq-beans.xml  |   40 +
 .../normal/server0/hornetq-configuration.xml    |   38 +
 examples/soak/normal/server0/hornetq-jms.xml    |   23 +
 examples/soak/normal/soak.properties            |   13 +
 .../org/hornetq/jms/soak/example/SoakBase.java  |  134 +
 .../hornetq/jms/soak/example/SoakParams.java    |  183 +
 .../hornetq/jms/soak/example/SoakReceiver.java  |  235 +
 .../hornetq/jms/soak/example/SoakSender.java    |  249 +
 examples/soak/tx-restarts/README                |   29 +
 examples/soak/tx-restarts/build.bat             |   13 +
 examples/soak/tx-restarts/build.sh              |   15 +
 examples/soak/tx-restarts/build.xml             |   38 +
 .../tx-restarts/server0/client-jndi.properties  |    3 +
 .../soak/tx-restarts/server0/hornetq-beans.xml  |   59 +
 .../server0/hornetq-configuration.xml           |   65 +
 .../soak/tx-restarts/server0/hornetq-jms.xml    |   28 +
 .../soak/tx-restarts/server0/hornetq-users.xml  |    7 +
 .../soak/tx-restarts/server0/jndi.properties    |    2 +
 .../org/hornetq/jms/example/ClientAbstract.java |  277 +
 .../src/org/hornetq/jms/example/Receiver.java   |  191 +
 .../src/org/hornetq/jms/example/Sender.java     |  128 +
 .../org/hornetq/jms/example/TXRestartSoak.java  |  179 +
 hornetq-bootstrap/pom.xml                       |   34 +
 .../bootstrap/HornetQBootstrapBundle.java       |   31 +
 .../bootstrap/HornetQBootstrapLogger.java       |   67 +
 .../bootstrap/HornetQBootstrapServer.java       |  284 +
 hornetq-commons/pom.xml                         |   39 +
 .../api/core/HornetQAddressExistsException.java |   35 +
 .../api/core/HornetQAddressFullException.java   |   35 +
 .../HornetQAlreadyReplicatingException.java     |   35 +
 .../org/hornetq/api/core/HornetQBuffer.java     | 1084 +++
 .../org/hornetq/api/core/HornetQBuffers.java    |   96 +
 .../core/HornetQClusterSecurityException.java   |   32 +
 .../HornetQConnectionTimedOutException.java     |   35 +
 .../api/core/HornetQDisconnectedException.java  |   35 +
 .../api/core/HornetQDuplicateIdException.java   |   35 +
 .../core/HornetQDuplicateMetaDataException.java |   35 +
 .../org/hornetq/api/core/HornetQException.java  |   76 +
 .../hornetq/api/core/HornetQExceptionType.java  |  298 +
 .../api/core/HornetQIOErrorException.java       |   40 +
 .../api/core/HornetQIllegalStateException.java  |   36 +
 ...ornetQIncompatibleClientServerException.java |   37 +
 ...rnetQInterceptorRejectedPacketException.java |   37 +
 .../api/core/HornetQInternalErrorException.java |   45 +
 .../api/core/HornetQInterruptedException.java   |   27 +
 ...HornetQInvalidFilterExpressionException.java |   35 +
 ...ornetQInvalidTransientQueueUseException.java |   35 +
 .../api/core/HornetQLargeMessageException.java  |   35 +
 ...HornetQLargeMessageInterruptedException.java |   36 +
 .../hornetq/api/core/HornetQNativeIOError.java  |   35 +
 .../core/HornetQNonExistentQueueException.java  |   35 +
 .../api/core/HornetQNotConnectedException.java  |   35 +
 .../api/core/HornetQObjectClosedException.java  |   36 +
 .../HornetQPropertyConversionException.java     |   30 +
 .../api/core/HornetQQueueExistsException.java   |   35 +
 .../api/core/HornetQSecurityException.java      |   35 +
 .../core/HornetQSessionCreationException.java   |   36 +
 ...rnetQTransactionOutcomeUnknownException.java |   35 +
 .../HornetQTransactionRolledBackException.java  |   35 +
 .../api/core/HornetQUnBlockedException.java     |   35 +
 .../core/HornetQUnsupportedPacketException.java |   35 +
 .../main/java/org/hornetq/api/core/Pair.java    |  105 +
 .../java/org/hornetq/api/core/SimpleString.java |  452 ++
 .../core/buffers/impl/ChannelBufferWrapper.java |  623 ++
 .../hornetq/core/server/HornetQComponent.java   |   31 +
 .../src/main/java/org/hornetq/utils/Base64.java | 2375 +++++++
 .../org/hornetq/utils/ClassloadingUtil.java     |  129 +
 .../org/hornetq/utils/ConcurrentHashSet.java    |   90 +
 .../java/org/hornetq/utils/ConcurrentSet.java   |   28 +
 .../java/org/hornetq/utils/DataConstants.java   |   67 +
 .../utils/DefaultSensitiveStringCodec.java      |  107 +
 .../org/hornetq/utils/HornetQThreadFactory.java |   92 +
 .../org/hornetq/utils/HornetQUtilBundle.java    |   48 +
 .../org/hornetq/utils/HornetQUtilLogger.java    |   50 +
 .../org/hornetq/utils/PasswordMaskingUtil.java  |   92 +
 .../org/hornetq/utils/ReferenceCounter.java     |   24 +
 .../org/hornetq/utils/ReferenceCounterUtil.java |   67 +
 .../java/org/hornetq/utils/ReusableLatch.java   |  155 +
 .../org/hornetq/utils/SensitiveDataCodec.java   |   33 +
 .../java/org/hornetq/utils/TypedProperties.java | 1147 ++++
 .../main/java/org/hornetq/utils/UTF8Util.java   |  273 +
 .../src/main/java/org/hornetq/utils/UUID.java   |  270 +
 .../java/org/hornetq/utils/UUIDGenerator.java   |  371 +
 .../main/java/org/hornetq/utils/UUIDTimer.java  |  324 +
 .../test/java/org/hornetq/utils/PairTest.java   |   32 +
 .../org/hornetq/utils/ReferenceCounterTest.java |  132 +
 hornetq-core-client/pom.xml                     |  176 +
 .../org/hornetq/api/core/BroadcastEndpoint.java |   95 +
 .../api/core/BroadcastEndpointFactory.java      |   19 +
 .../BroadcastEndpointFactoryConfiguration.java  |   25 +
 .../api/core/BroadcastGroupConfiguration.java   |  132 +
 .../api/core/DiscoveryGroupConfiguration.java   |  198 +
 ...ryGroupConfigurationCompatibilityHelper.java |   42 +
 .../org/hornetq/api/core/FilterConstants.java   |   71 +
 .../java/org/hornetq/api/core/Interceptor.java  |   40 +
 .../JGroupsBroadcastGroupConfiguration.java     |  422 ++
 .../main/java/org/hornetq/api/core/Message.java |  539 ++
 .../api/core/TransportConfiguration.java        |  405 ++
 .../core/UDPBroadcastGroupConfiguration.java    |  301 +
 .../hornetq/api/core/client/ClientConsumer.java |  122 +
 .../hornetq/api/core/client/ClientMessage.java  |  117 +
 .../hornetq/api/core/client/ClientProducer.java |  149 +
 .../api/core/client/ClientRequestor.java        |  110 +
 .../hornetq/api/core/client/ClientSession.java  |  670 ++
 .../api/core/client/ClientSessionFactory.java   |  182 +
 .../core/client/ClusterTopologyListener.java    |   40 +
 .../api/core/client/FailoverEventListener.java  |   30 +
 .../api/core/client/FailoverEventType.java      |   20 +
 .../hornetq/api/core/client/HornetQClient.java  |  209 +
 .../hornetq/api/core/client/MessageHandler.java |   31 +
 .../core/client/SendAcknowledgementHandler.java |   41 +
 .../hornetq/api/core/client/ServerLocator.java  |  752 +++
 .../api/core/client/SessionFailureListener.java |   33 +
 .../hornetq/api/core/client/TopologyMember.java |   96 +
 .../ConnectionLoadBalancingPolicy.java          |   28 +
 ...rstElementConnectionLoadBalancingPolicy.java |   33 +
 .../RandomConnectionLoadBalancingPolicy.java    |   35 +
 ...ndomStickyConnectionLoadBalancingPolicy.java |   41 +
 ...RoundRobinConnectionLoadBalancingPolicy.java |   63 +
 .../core/client/loadbalance/package-info.java   |   21 +
 .../hornetq/api/core/client/package-info.java   |   19 +
 .../api/core/management/AcceptorControl.java    |   43 +
 .../api/core/management/AddressControl.java     |   77 +
 .../core/management/AddressSettingsInfo.java    |  176 +
 .../api/core/management/BridgeControl.java      |   83 +
 .../core/management/BroadcastGroupControl.java  |   58 +
 .../management/ClusterConnectionControl.java    |   85 +
 .../api/core/management/DayCounterInfo.java     |  102 +
 .../api/core/management/DivertControl.java      |   59 +
 .../management/HornetQComponentControl.java     |   36 +
 .../core/management/HornetQServerControl.java   |  603 ++
 .../api/core/management/ManagementHelper.java   |  455 ++
 .../api/core/management/NotificationType.java   |   60 +
 .../api/core/management/ObjectNameBuilder.java  |  231 +
 .../hornetq/api/core/management/Operation.java  |   39 +
 .../hornetq/api/core/management/Parameter.java  |   35 +
 .../api/core/management/QueueControl.java       |  359 +
 .../api/core/management/ResourceNames.java      |   56 +
 .../hornetq/api/core/management/RoleInfo.java   |  148 +
 .../api/core/management/package-info.java       |   20 +
 .../java/org/hornetq/api/core/package-info.java |   20 +
 .../impl/ResetLimitWrappedHornetQBuffer.java    |  382 ++
 .../core/client/HornetQClientLogger.java        |  411 ++
 .../core/client/HornetQClientMessageBundle.java |  244 +
 .../core/client/impl/AddressQueryImpl.java      |   44 +
 .../impl/AfterConnectInternalListener.java      |   27 +
 .../core/client/impl/ClientConsumerImpl.java    | 1242 ++++
 .../client/impl/ClientConsumerInternal.java     |   72 +
 .../client/impl/ClientLargeMessageImpl.java     |  223 +
 .../client/impl/ClientLargeMessageInternal.java |   31 +
 .../core/client/impl/ClientMessageImpl.java     |  241 +
 .../core/client/impl/ClientMessageInternal.java |   44 +
 .../impl/ClientProducerCreditManager.java       |   41 +
 .../impl/ClientProducerCreditManagerImpl.java   |  232 +
 .../core/client/impl/ClientProducerCredits.java |   45 +
 .../client/impl/ClientProducerCreditsImpl.java  |  221 +
 .../core/client/impl/ClientProducerImpl.java    |  607 ++
 .../client/impl/ClientProducerInternal.java     |   29 +
 .../client/impl/ClientSessionFactoryImpl.java   | 1611 +++++
 .../impl/ClientSessionFactoryInternal.java      |   61 +
 .../core/client/impl/ClientSessionImpl.java     | 1922 ++++++
 .../core/client/impl/ClientSessionInternal.java |  119 +
 .../CompressedLargeMessageControllerImpl.java   |  769 +++
 .../core/client/impl/DelegatingSession.java     |  645 ++
 .../client/impl/LargeMessageController.java     |   66 +
 .../client/impl/LargeMessageControllerImpl.java | 1505 +++++
 .../core/client/impl/QueueQueryImpl.java        |   99 +
 .../core/client/impl/ServerLocatorImpl.java     | 2079 ++++++
 .../core/client/impl/ServerLocatorInternal.java |   86 +
 .../org/hornetq/core/client/impl/Topology.java  |  543 ++
 .../core/client/impl/TopologyMemberImpl.java    |  138 +
 .../hornetq/core/cluster/DiscoveryEntry.java    |   58 +
 .../hornetq/core/cluster/DiscoveryGroup.java    |  432 ++
 .../hornetq/core/cluster/DiscoveryListener.java |   30 +
 .../core/exception/HornetQXAException.java      |   39 +
 .../org/hornetq/core/message/BodyEncoder.java   |   54 +
 .../hornetq/core/message/impl/MessageImpl.java  | 1069 +++
 .../core/message/impl/MessageInternal.java      |   66 +
 .../core/protocol/ClientPacketDecoder.java      |   71 +
 .../org/hornetq/core/protocol/core/Channel.java |  197 +
 .../core/protocol/core/ChannelHandler.java      |   30 +
 .../core/CommandConfirmationHandler.java        |   31 +
 .../protocol/core/CoreRemotingConnection.java   |  104 +
 .../org/hornetq/core/protocol/core/Packet.java  |   86 +
 .../core/protocol/core/impl/ChannelImpl.java    |  700 ++
 .../core/impl/HornetQClientProtocolManager.java |  580 ++
 .../HornetQClientProtocolManagerFactory.java    |   30 +
 .../core/impl/HornetQSessionContext.java        |  923 +++
 .../core/protocol/core/impl/PacketDecoder.java  |  474 ++
 .../core/protocol/core/impl/PacketImpl.java     |  379 ++
 .../core/impl/RemotingConnectionImpl.java       |  643 ++
 .../impl/wireformat/CheckFailoverMessage.java   |   49 +
 .../wireformat/CheckFailoverReplyMessage.java   |   56 +
 .../ClusterTopologyChangeMessage.java           |  217 +
 .../ClusterTopologyChangeMessage_V2.java        |  192 +
 .../ClusterTopologyChangeMessage_V3.java        |  108 +
 .../impl/wireformat/CreateQueueMessage.java     |  205 +
 .../impl/wireformat/CreateSessionMessage.java   |  272 +
 .../CreateSessionResponseMessage.java           |   91 +
 .../wireformat/CreateSharedQueueMessage.java    |  180 +
 .../wireformat/DisconnectConsumerMessage.java   |   50 +
 .../core/impl/wireformat/DisconnectMessage.java |  120 +
 .../impl/wireformat/DisconnectMessage_V2.java   |  105 +
 .../wireformat/HornetQExceptionMessage.java     |  118 +
 .../core/impl/wireformat/MessagePacket.java     |   42 +
 .../impl/wireformat/NullResponseMessage.java    |   33 +
 .../wireformat/PacketsConfirmedMessage.java     |  105 +
 .../protocol/core/impl/wireformat/Ping.java     |  103 +
 .../impl/wireformat/ReattachSessionMessage.java |  106 +
 .../ReattachSessionResponseMessage.java         |  109 +
 .../core/impl/wireformat/RollbackMessage.java   |   97 +
 .../wireformat/SessionAcknowledgeMessage.java   |  111 +
 .../wireformat/SessionAddMetaDataMessage.java   |  111 +
 .../wireformat/SessionAddMetaDataMessageV2.java |  140 +
 .../wireformat/SessionBindingQueryMessage.java  |   87 +
 .../SessionBindingQueryResponseMessage.java     |  119 +
 .../impl/wireformat/SessionCloseMessage.java    |   54 +
 .../impl/wireformat/SessionCommitMessage.java   |   34 +
 .../wireformat/SessionConsumerCloseMessage.java |   86 +
 .../SessionConsumerFlowCreditMessage.java       |   98 +
 .../wireformat/SessionContinuationMessage.java  |  121 +
 .../SessionCreateConsumerMessage.java           |  170 +
 .../wireformat/SessionDeleteQueueMessage.java   |   93 +
 .../impl/wireformat/SessionExpireMessage.java   |  103 +
 .../SessionForceConsumerDelivery.java           |  104 +
 .../SessionIndividualAcknowledgeMessage.java    |  119 +
 .../SessionProducerCreditsFailMessage.java      |   98 +
 .../SessionProducerCreditsMessage.java          |   98 +
 .../wireformat/SessionQueueQueryMessage.java    |   87 +
 .../SessionQueueQueryResponseMessage.java       |  231 +
 .../SessionReceiveClientLargeMessage.java       |   38 +
 .../SessionReceiveContinuationMessage.java      |  135 +
 .../wireformat/SessionReceiveLargeMessage.java  |  139 +
 .../impl/wireformat/SessionReceiveMessage.java  |  134 +
 .../SessionRequestProducerCreditsMessage.java   |  106 +
 .../SessionSendContinuationMessage.java         |  157 +
 .../wireformat/SessionSendLargeMessage.java     |   91 +
 .../impl/wireformat/SessionSendMessage.java     |  134 +
 .../SessionUniqueAddMetaDataMessage.java        |   55 +
 .../wireformat/SessionXAAfterFailedMessage.java |   99 +
 .../impl/wireformat/SessionXACommitMessage.java |  111 +
 .../impl/wireformat/SessionXAEndMessage.java    |  105 +
 .../impl/wireformat/SessionXAForgetMessage.java |   86 +
 .../SessionXAGetInDoubtXidsResponseMessage.java |  106 +
 .../SessionXAGetTimeoutResponseMessage.java     |   84 +
 .../impl/wireformat/SessionXAJoinMessage.java   |   86 +
 .../wireformat/SessionXAPrepareMessage.java     |   94 +
 .../wireformat/SessionXAResponseMessage.java    |  118 +
 .../impl/wireformat/SessionXAResumeMessage.java |   88 +
 .../wireformat/SessionXARollbackMessage.java    |   95 +
 .../wireformat/SessionXASetTimeoutMessage.java  |   80 +
 .../SessionXASetTimeoutResponseMessage.java     |   86 +
 .../impl/wireformat/SessionXAStartMessage.java  |   98 +
 .../SubscribeClusterTopologyUpdatesMessage.java |  102 +
 ...ubscribeClusterTopologyUpdatesMessageV2.java |   87 +
 .../hornetq/core/remoting/CloseListener.java    |   28 +
 .../hornetq/core/remoting/FailureListener.java  |   41 +
 .../impl/netty/HornetQChannelHandler.java       |  122 +
 .../impl/netty/HornetQFrameDecoder2.java        |   39 +
 .../remoting/impl/netty/NettyConnection.java    |  389 ++
 .../remoting/impl/netty/NettyConnector.java     | 1239 ++++
 .../impl/netty/NettyConnectorFactory.java       |   52 +
 .../netty/PartialPooledByteBufAllocator.java    |  152 +
 .../impl/netty/SharedNioEventLoopGroup.java     |  150 +
 .../remoting/impl/netty/TransportConstants.java |  281 +
 .../core/remoting/impl/ssl/SSLSupport.java      |  202 +
 .../org/hornetq/core/remoting/package-info.java |   19 +
 .../hornetq/core/security/HornetQPrincipal.java |   41 +
 .../java/org/hornetq/core/security/Role.java    |  199 +
 .../hornetq/core/server/QueueQueryResult.java   |  124 +
 .../core/server/management/Notification.java    |   59 +
 .../server/management/NotificationListener.java |   28 +
 .../server/management/NotificationService.java  |   41 +
 .../settings/impl/AddressFullMessagePolicy.java |   25 +
 .../hornetq/core/transaction/impl/XidImpl.java  |  218 +
 .../java/org/hornetq/core/version/Version.java  |   39 +
 .../hornetq/core/version/impl/VersionImpl.java  |  202 +
 .../spi/core/protocol/ConnectionEntry.java      |   45 +
 .../spi/core/protocol/RemotingConnection.java   |  177 +
 .../spi/core/remoting/AbstractConnector.java    |   40 +
 .../spi/core/remoting/BufferDecoder.java        |   34 +
 .../spi/core/remoting/BufferHandler.java        |   33 +
 .../core/remoting/ClientProtocolManager.java    |   72 +
 .../remoting/ClientProtocolManagerFactory.java  |   23 +
 .../hornetq/spi/core/remoting/Connection.java   |   85 +
 .../remoting/ConnectionLifeCycleListener.java   |   56 +
 .../hornetq/spi/core/remoting/Connector.java    |   63 +
 .../spi/core/remoting/ConnectorFactory.java     |   63 +
 .../core/remoting/ProtocolResponseHandler.java  |   37 +
 .../spi/core/remoting/ReadyListener.java        |   26 +
 .../spi/core/remoting/SessionContext.java       |  269 +
 .../hornetq/spi/core/remoting/package-info.java |   20 +
 .../java/org/hornetq/utils/BufferHelper.java    |  193 +
 .../org/hornetq/utils/ConfigurationHelper.java  |  250 +
 .../utils/ConfirmationWindowWarning.java        |   36 +
 .../java/org/hornetq/utils/DeflaterReader.java  |  138 +
 .../java/org/hornetq/utils/ExecutorFactory.java |   27 +
 .../java/org/hornetq/utils/FutureLatch.java     |   49 +
 .../hornetq/utils/HornetQBufferInputStream.java |  181 +
 .../java/org/hornetq/utils/IDGenerator.java     |   31 +
 .../java/org/hornetq/utils/InflaterReader.java  |  139 +
 .../java/org/hornetq/utils/InflaterWriter.java  |  110 +
 .../main/java/org/hornetq/utils/JNDIUtil.java   |  122 +
 .../main/java/org/hornetq/utils/LinkedList.java |   35 +
 .../java/org/hornetq/utils/LinkedListImpl.java  |  456 ++
 .../org/hornetq/utils/LinkedListIterator.java   |   32 +
 .../main/java/org/hornetq/utils/MemorySize.java |  140 +
 .../utils/ObjectInputStreamWithClassLoader.java |  195 +
 .../hornetq/utils/OrderedExecutorFactory.java   |  143 +
 .../org/hornetq/utils/PriorityLinkedList.java   |   38 +
 .../hornetq/utils/PriorityLinkedListImpl.java   |  277 +
 .../src/main/java/org/hornetq/utils/Random.java |   46 +
 .../org/hornetq/utils/SecurityFormatter.java    |   73 +
 .../org/hornetq/utils/SimpleIDGenerator.java    |   54 +
 .../org/hornetq/utils/SizeFormatterUtil.java    |   70 +
 .../org/hornetq/utils/SoftValueHashMap.java     |  434 ++
 .../utils/TimeAndCounterIDGenerator.java        |  167 +
 .../org/hornetq/utils/TokenBucketLimiter.java   |   34 +
 .../hornetq/utils/TokenBucketLimiterImpl.java   |  119 +
 .../java/org/hornetq/utils/VersionLoader.java   |  252 +
 .../main/java/org/hornetq/utils/XMLUtil.java    |  523 ++
 .../java/org/hornetq/utils/XidCodecSupport.java |   70 +
 .../java/org/hornetq/utils/json/JSONArray.java  | 1034 +++
 .../org/hornetq/utils/json/JSONException.java   |   73 +
 .../java/org/hornetq/utils/json/JSONObject.java | 1751 +++++
 .../java/org/hornetq/utils/json/JSONString.java |   56 +
 .../org/hornetq/utils/json/JSONTokener.java     |  476 ++
 .../java/org/hornetq/utils/package-info.java    |   19 +
 .../resources/HornetQDefaultConfiguration.txt   |  116 +
 .../main/resources/hornetq-version.properties   |    9 +
 .../src/main/resources/hqDefaults.xsl           |  128 +
 .../org/hornetq/tests/CoreUnitTestCase.java     |   85 +
 .../java/org/hornetq/tests/util/RandomUtil.java |  169 +
 .../org/hornetq/tests/util/SilentTestCase.java  |   55 +
 .../org/hornetq/util/CompressionUtilTest.java   |  201 +
 .../org/hornetq/util/ConcurrentHashSetTest.java |  157 +
 .../util/TimeAndCounterIDGeneratorTest.java     |  201 +
 .../util/TypedPropertiesConversionTest.java     |  372 ++
 .../org/hornetq/util/TypedPropertiesTest.java   |  248 +
 .../test/java/org/hornetq/util/XMLUtilTest.java |  276 +
 hornetq-jms-client/pom.xml                      |   76 +
 .../org/hornetq/api/jms/HornetQJMSClient.java   |  234 +
 .../hornetq/api/jms/HornetQJMSConstants.java    |   38 +
 .../org/hornetq/api/jms/JMSFactoryType.java     |   83 +
 .../management/ConnectionFactoryControl.java    |  389 ++
 .../api/jms/management/DestinationControl.java  |   71 +
 .../api/jms/management/JMSConnectionInfo.java   |  102 +
 .../api/jms/management/JMSConsumerInfo.java     |  134 +
 .../api/jms/management/JMSManagementHelper.java |  168 +
 .../api/jms/management/JMSQueueControl.java     |  280 +
 .../api/jms/management/JMSServerControl.java    |  355 +
 .../api/jms/management/JMSSessionInfo.java      |   62 +
 .../api/jms/management/SubscriptionInfo.java    |  142 +
 .../api/jms/management/TopicControl.java        |  149 +
 .../api/jms/management/package-info.java        |   20 +
 .../java/org/hornetq/api/jms/package-info.java  |   21 +
 .../hornetq/jms/client/HornetQBytesMessage.java |  459 ++
 .../hornetq/jms/client/HornetQConnection.java   |  861 +++
 .../jms/client/HornetQConnectionFactory.java    |  821 +++
 .../jms/client/HornetQConnectionForContext.java |   34 +
 .../client/HornetQConnectionForContextImpl.java |   91 +
 .../jms/client/HornetQConnectionMetaData.java   |   97 +
 .../hornetq/jms/client/HornetQDestination.java  |  376 ++
 .../jms/client/HornetQJMSClientBundle.java      |   97 +
 .../jms/client/HornetQJMSClientLogger.java      |   79 +
 .../jms/client/HornetQJMSConnectionFactory.java |   67 +
 .../hornetq/jms/client/HornetQJMSConsumer.java  |  198 +
 .../hornetq/jms/client/HornetQJMSContext.java   |  769 +++
 .../hornetq/jms/client/HornetQJMSProducer.java  |  800 +++
 .../hornetq/jms/client/HornetQMapMessage.java   |  451 ++
 .../org/hornetq/jms/client/HornetQMessage.java  | 1160 ++++
 .../jms/client/HornetQMessageConsumer.java      |  253 +
 .../jms/client/HornetQMessageProducer.java      |  601 ++
 .../jms/client/HornetQObjectMessage.java        |  202 +
 .../org/hornetq/jms/client/HornetQQueue.java    |   90 +
 .../hornetq/jms/client/HornetQQueueBrowser.java |  169 +
 .../client/HornetQQueueConnectionFactory.java   |   69 +
 .../org/hornetq/jms/client/HornetQSession.java  | 1276 ++++
 .../jms/client/HornetQStreamMessage.java        |  582 ++
 .../jms/client/HornetQTemporaryQueue.java       |   67 +
 .../jms/client/HornetQTemporaryTopic.java       |   53 +
 .../hornetq/jms/client/HornetQTextMessage.java  |  147 +
 .../org/hornetq/jms/client/HornetQTopic.java    |   85 +
 .../client/HornetQTopicConnectionFactory.java   |   70 +
 .../hornetq/jms/client/HornetQXAConnection.java |   70 +
 .../jms/client/HornetQXAConnectionFactory.java  |   76 +
 .../hornetq/jms/client/HornetQXAJMSContext.java |   23 +
 .../client/HornetQXAQueueConnectionFactory.java |   71 +
 .../hornetq/jms/client/HornetQXASession.java    |   47 +
 .../client/HornetQXATopicConnectionFactory.java |   69 +
 .../hornetq/jms/client/JMSExceptionHelper.java  |   91 +
 .../jms/client/JMSMessageListenerWrapper.java   |  152 +
 .../hornetq/jms/client/JmsExceptionUtils.java   |  100 +
 .../hornetq/jms/client/SelectorTranslator.java  |  149 +
 .../hornetq/jms/client/ThreadAwareContext.java  |  152 +
 .../org/hornetq/jms/client/package-info.java    |   22 +
 .../ConnectionFactoryObjectFactory.java         |   43 +
 .../referenceable/DestinationObjectFactory.java |   43 +
 .../SerializableObjectRefAddr.java              |   79 +
 hornetq-jms-server/pom.xml                      |   99 +
 .../jms/bridge/ConnectionFactoryFactory.java    |   25 +
 .../hornetq/jms/bridge/DestinationFactory.java  |   27 +
 .../java/org/hornetq/jms/bridge/JMSBridge.java  |  115 +
 .../hornetq/jms/bridge/JMSBridgeControl.java    |   93 +
 .../jms/bridge/QualityOfServiceMode.java        |  100 +
 .../jms/bridge/impl/JMSBridgeControlImpl.java   |  256 +
 .../hornetq/jms/bridge/impl/JMSBridgeImpl.java  | 2351 +++++++
 .../impl/JNDIConnectionFactoryFactory.java      |   40 +
 .../jms/bridge/impl/JNDIDestinationFactory.java |   40 +
 .../jms/bridge/impl/JNDIFactorySupport.java     |   67 +
 .../impl/JMSConnectionFactoryControlImpl.java   |  471 ++
 .../management/impl/JMSQueueControlImpl.java    |  384 ++
 .../management/impl/JMSServerControlImpl.java   | 1044 +++
 .../management/impl/JMSTopicControlImpl.java    |  409 ++
 .../jms/persistence/JMSStorageManager.java      |   54 +
 .../config/PersistedConnectionFactory.java      |  111 +
 .../config/PersistedDestination.java            |  128 +
 .../jms/persistence/config/PersistedJNDI.java   |  167 +
 .../jms/persistence/config/PersistedType.java   |   53 +
 .../journal/JMSJournalStorageManagerImpl.java   |  362 +
 .../impl/nullpm/NullJMSStorageManagerImpl.java  |  108 +
 .../jms/server/HornetQJMSServerBundle.java      |   62 +
 .../jms/server/HornetQJMSServerLogger.java      |  170 +
 .../jms/server/JMSServerConfigParser.java       |   65 +
 .../hornetq/jms/server/JMSServerManager.java    |  315 +
 .../config/ConnectionFactoryConfiguration.java  |  171 +
 .../jms/server/config/JMSConfiguration.java     |   39 +
 .../server/config/JMSQueueConfiguration.java    |   31 +
 .../jms/server/config/TopicConfiguration.java   |   25 +
 .../ConnectionFactoryConfigurationImpl.java     |  825 +++
 .../config/impl/JMSConfigurationImpl.java       |   91 +
 .../config/impl/JMSQueueConfigurationImpl.java  |   88 +
 .../config/impl/TopicConfigurationImpl.java     |   69 +
 .../TransportConfigurationEncodingSupport.java  |  153 +
 .../jms/server/embedded/EmbeddedJMS.java        |  124 +
 .../server/impl/JMSServerConfigParserImpl.java  |  505 ++
 .../jms/server/impl/JMSServerDeployer.java      |  185 +
 .../jms/server/impl/JMSServerManagerImpl.java   | 1893 ++++++
 .../jms/server/impl/StandaloneNamingServer.java |  161 +
 .../server/management/JMSManagementService.java |   47 +
 .../impl/JMSManagementServiceImpl.java          |  163 +
 .../recovery/HornetQRecoveryRegistry.java       |  250 +
 .../server/recovery/HornetQRegistryBase.java    |   71 +
 .../recovery/HornetQXAResourceRecovery.java     |  231 +
 .../recovery/HornetQXAResourceWrapper.java      |  531 ++
 .../jms/server/recovery/RecoveryDiscovery.java  |  232 +
 .../jms/server/recovery/XARecoveryConfig.java   |  167 +
 .../jms/server/recovery/package-info.java       |   22 +
 .../jms/transaction/JMSTransactionDetail.java   |   78 +
 .../src/main/resources/schema/hornetq-jms.xsd   |  267 +
 hornetq-journal/pom.xml                         |   92 +
 .../org/hornetq/core/asyncio/AIOCallback.java   |   31 +
 .../hornetq/core/asyncio/AsynchronousFile.java  |   59 +
 .../hornetq/core/asyncio/BufferCallback.java    |   27 +
 .../core/asyncio/IOExceptionListener.java       |   25 +
 .../core/asyncio/impl/AsynchronousFileImpl.java |  819 +++
 .../core/asyncio/impl/HornetQFileLock.java      |   47 +
 .../hornetq/core/journal/EncodingSupport.java   |   33 +
 .../org/hornetq/core/journal/IOAsyncTask.java   |   27 +
 .../org/hornetq/core/journal/IOCompletion.java  |   25 +
 .../core/journal/IOCriticalErrorListener.java   |   25 +
 .../java/org/hornetq/core/journal/Journal.java  |  227 +
 .../core/journal/JournalLoadInformation.java    |  116 +
 .../hornetq/core/journal/LoaderCallback.java    |   29 +
 .../core/journal/PreparedTransactionInfo.java   |   42 +
 .../org/hornetq/core/journal/RecordInfo.java    |   86 +
 .../hornetq/core/journal/SequentialFile.java    |  131 +
 .../core/journal/SequentialFileFactory.java     |   88 +
 .../hornetq/core/journal/TestableJournal.java   |   70 +
 .../journal/TransactionFailureCallback.java     |   31 +
 .../core/journal/impl/AIOSequentialFile.java    |  329 +
 .../journal/impl/AIOSequentialFileFactory.java  |  358 +
 .../journal/impl/AbstractJournalUpdateTask.java |  253 +
 .../journal/impl/AbstractSequentialFile.java    |  408 ++
 .../impl/AbstractSequentialFileFactory.java     |  220 +
 .../core/journal/impl/CompactJournal.java       |   66 +
 .../core/journal/impl/DummyCallback.java        |   51 +
 .../core/journal/impl/ExportJournal.java        |  206 +
 .../core/journal/impl/FileWrapperJournal.java   |  337 +
 .../core/journal/impl/ImportJournal.java        |  388 ++
 .../hornetq/core/journal/impl/JournalBase.java  |  217 +
 .../core/journal/impl/JournalCompactor.java     |  639 ++
 .../core/journal/impl/JournalConstants.java     |   23 +
 .../hornetq/core/journal/impl/JournalFile.java  |   67 +
 .../core/journal/impl/JournalFileImpl.java      |  206 +
 .../journal/impl/JournalFilesRepository.java    |  755 +++
 .../hornetq/core/journal/impl/JournalImpl.java  | 3252 +++++++++
 .../journal/impl/JournalReaderCallback.java     |   79 +
 .../impl/JournalReaderCallbackAbstract.java     |   67 +
 .../core/journal/impl/JournalRecord.java        |   96 +
 .../journal/impl/JournalRecordProvider.java     |   33 +
 .../core/journal/impl/JournalTransaction.java   |  456 ++
 .../core/journal/impl/NIOSequentialFile.java    |  415 ++
 .../journal/impl/NIOSequentialFileFactory.java  |  171 +
 .../hornetq/core/journal/impl/Reclaimer.java    |  118 +
 .../core/journal/impl/SimpleWaitIOCallback.java |   92 +
 .../core/journal/impl/SyncIOCompletion.java     |   47 +
 .../core/journal/impl/SyncSpeedTest.java        |  354 +
 .../hornetq/core/journal/impl/TimedBuffer.java  |  560 ++
 .../core/journal/impl/TimedBufferObserver.java  |   55 +
 .../core/journal/impl/TransactionCallback.java  |  116 +
 .../impl/dataformat/ByteArrayEncoding.java      |   51 +
 .../impl/dataformat/JournalAddRecord.java       |   85 +
 .../impl/dataformat/JournalAddRecordTX.java     |   96 +
 .../dataformat/JournalCompleteRecordTX.java     |  114 +
 .../impl/dataformat/JournalDeleteRecord.java    |   56 +
 .../impl/dataformat/JournalDeleteRecordTX.java  |   77 +
 .../impl/dataformat/JournalInternalRecord.java  |   73 +
 .../dataformat/JournalRollbackRecordTX.java     |   50 +
 .../hornetq/journal/HornetQJournalBundle.java   |   48 +
 .../hornetq/journal/HornetQJournalLogger.java   |  271 +
 .../asyncio/LibaioDependencyCheckTest.java      |   57 +
 hornetq-native/README                           |   45 +
 hornetq-native/bin/libHornetQAIO32.so           |  Bin 0 -> 44488 bytes
 hornetq-native/bin/libHornetQAIO64.so           |  Bin 0 -> 51654 bytes
 hornetq-native/compile-native.sh                |    1 +
 hornetq-native/pom.xml                          |  126 +
 hornetq-native/src/main/c/AIOController.cpp     |   59 +
 hornetq-native/src/main/c/AIOController.h       |   47 +
 hornetq-native/src/main/c/AIOException.h        |   71 +
 hornetq-native/src/main/c/AsyncFile.cpp         |  344 +
 hornetq-native/src/main/c/AsyncFile.h           |   89 +
 hornetq-native/src/main/c/CallbackAdapter.h     |   38 +
 hornetq-native/src/main/c/JAIODatatypes.h       |   24 +
 .../src/main/c/JNICallbackAdapter.cpp           |   58 +
 hornetq-native/src/main/c/JNICallbackAdapter.h  |   62 +
 .../src/main/c/JNI_AsynchronousFileImpl.cpp     |  373 ++
 hornetq-native/src/main/c/JavaUtilities.cpp     |   58 +
 hornetq-native/src/main/c/JavaUtilities.h       |   22 +
 hornetq-native/src/main/c/LockClass.h           |   35 +
 hornetq-native/src/main/c/Version.h             |    8 +
 .../java/org/hornetq/core/libaio/Native.java    |   74 +
 hornetq-protocols/hornetq-amqp-protocol/pom.xml |   45 +
 .../HornetQAMQPProtocolMessageBundle.java       |   82 +
 .../core/protocol/proton/ProtonConsumer.java    |  314 +
 .../protocol/proton/ProtonDeliveryHandler.java  |   31 +
 .../core/protocol/proton/ProtonProducer.java    |  142 +
 .../protocol/proton/ProtonProtocolManager.java  |  332 +
 .../proton/ProtonProtocolManagerFactory.java    |   43 +
 .../proton/ProtonRemotingConnection.java        |  670 ++
 .../core/protocol/proton/ProtonSession.java     |  327 +
 .../core/protocol/proton/ProtonUtils.java       |  633 ++
 .../protocol/proton/TransactionHandler.java     |   83 +
 .../proton/exceptions/HornetQAMQPException.java |   40 +
 .../HornetQAMQPIllegalStateException.java       |   28 +
 .../HornetQAMQPInternalErrorException.java      |   28 +
 .../HornetQAMQPInvalidFieldException.java       |   28 +
 .../HornetQAMQPNotImplementedException.java     |   28 +
 ...etq.spi.core.protocol.ProtocolManagerFactory |    1 +
 .../hornetq-stomp-protocol/pom.xml              |   36 +
 .../core/protocol/stomp/FrameEventListener.java |   26 +
 .../protocol/stomp/HornetQStompException.java   |  134 +
 .../stomp/HornetQStompProtocolLogger.java       |   54 +
 .../HornetQStompProtocolMessageBundle.java      |  152 +
 .../core/protocol/stomp/SimpleBytes.java        |   56 +
 .../org/hornetq/core/protocol/stomp/Stomp.java  |  208 +
 .../core/protocol/stomp/StompCommands.java      |   46 +
 .../core/protocol/stomp/StompConnection.java    |  823 +++
 .../core/protocol/stomp/StompDecoder.java       |  721 ++
 .../hornetq/core/protocol/stomp/StompFrame.java |  266 +
 .../protocol/stomp/StompProtocolManager.java    |  489 ++
 .../stomp/StompProtocolManagerFactory.java      |   46 +
 .../core/protocol/stomp/StompSession.java       |  400 ++
 .../core/protocol/stomp/StompSubscription.java  |   68 +
 .../hornetq/core/protocol/stomp/StompUtils.java |  140 +
 .../core/protocol/stomp/StompVersions.java      |   37 +
 .../stomp/VersionedStompFrameHandler.java       |  409 ++
 .../stomp/v10/StompFrameHandlerV10.java         |  181 +
 .../core/protocol/stomp/v10/StompFrameV10.java  |   28 +
 .../stomp/v11/StompFrameHandlerV11.java         |  903 +++
 .../core/protocol/stomp/v11/StompFrameV11.java  |  101 +
 .../stomp/v12/StompFrameHandlerV12.java         |  364 +
 .../core/protocol/stomp/v12/StompFrameV12.java  |  152 +
 ...etq.spi.core.protocol.ProtocolManagerFactory |    1 +
 hornetq-protocols/pom.xml                       |   24 +
 hornetq-ra/pom.xml                              |   57 +
 .../hornetq/ra/ConnectionFactoryProperties.java |  841 +++
 .../java/org/hornetq/ra/HornetQRABundle.java    |   70 +
 .../org/hornetq/ra/HornetQRABytesMessage.java   |  455 ++
 .../hornetq/ra/HornetQRAConnectionFactory.java  |   65 +
 .../ra/HornetQRAConnectionFactoryImpl.java      |  570 ++
 .../hornetq/ra/HornetQRAConnectionManager.java  |   90 +
 .../hornetq/ra/HornetQRAConnectionMetaData.java |  153 +
 .../ra/HornetQRAConnectionRequestInfo.java      |  306 +
 .../org/hornetq/ra/HornetQRACredential.java     |  241 +
 .../org/hornetq/ra/HornetQRAJMSContext.java     |   57 +
 .../hornetq/ra/HornetQRALocalTransaction.java   |  121 +
 .../java/org/hornetq/ra/HornetQRALogger.java    |  122 +
 .../org/hornetq/ra/HornetQRAMCFProperties.java  |  204 +
 .../hornetq/ra/HornetQRAManagedConnection.java  |  917 +++
 .../ra/HornetQRAManagedConnectionFactory.java   |  805 +++
 .../org/hornetq/ra/HornetQRAMapMessage.java     |  452 ++
 .../java/org/hornetq/ra/HornetQRAMessage.java   |  897 +++
 .../hornetq/ra/HornetQRAMessageConsumer.java    |  334 +
 .../hornetq/ra/HornetQRAMessageListener.java    |   65 +
 .../hornetq/ra/HornetQRAMessageProducer.java    |  473 ++
 .../java/org/hornetq/ra/HornetQRAMetaData.java  |  107 +
 .../org/hornetq/ra/HornetQRAObjectMessage.java  |   76 +
 .../org/hornetq/ra/HornetQRAProperties.java     |  358 +
 .../org/hornetq/ra/HornetQRAQueueReceiver.java  |   61 +
 .../org/hornetq/ra/HornetQRAQueueSender.java    |  138 +
 .../java/org/hornetq/ra/HornetQRAService.java   |   82 +
 .../java/org/hornetq/ra/HornetQRASession.java   | 1887 ++++++
 .../org/hornetq/ra/HornetQRASessionFactory.java |   51 +
 .../hornetq/ra/HornetQRASessionFactoryImpl.java | 1046 +++
 .../org/hornetq/ra/HornetQRAStreamMessage.java  |  408 ++
 .../org/hornetq/ra/HornetQRATextMessage.java    |   74 +
 .../org/hornetq/ra/HornetQRATopicPublisher.java |  211 +
 .../hornetq/ra/HornetQRATopicSubscriber.java    |   77 +
 .../org/hornetq/ra/HornetQRAXAJMSContext.java   |   26 +
 .../org/hornetq/ra/HornetQRAXAResource.java     |  250 +
 .../java/org/hornetq/ra/HornetQRaUtils.java     |  354 +
 .../org/hornetq/ra/HornetQResourceAdapter.java  | 2364 +++++++
 .../hornetq/ra/inflow/HornetQActivation.java    |  806 +++
 .../ra/inflow/HornetQActivationSpec.java        |  900 +++
 .../ra/inflow/HornetQMessageHandler.java        |  423 ++
 .../src/main/java/org/hornetq/ra/package.html   |   24 +
 .../hornetq/ra/recovery/RecoveryManager.java    |  134 +
 hornetq-rest/pom.xml                            |  109 +
 .../org/hornetq/rest/HornetQRestBundle.java     |   31 +
 .../org/hornetq/rest/HornetQRestLogger.java     |   85 +
 .../src/main/java/org/hornetq/rest/Hornetq.java |  191 +
 .../org/hornetq/rest/HttpHeaderProperty.java    |   44 +
 .../src/main/java/org/hornetq/rest/Jms.java     |  197 +
 .../rest/MessageServiceConfiguration.java       |  157 +
 .../org/hornetq/rest/MessageServiceManager.java |  221 +
 .../java/org/hornetq/rest/UnknownMediaType.java |   27 +
 .../org/hornetq/rest/UnmarshalException.java    |   32 +
 .../rest/integration/EmbeddedRestHornetQ.java   |   92 +
 .../integration/EmbeddedRestHornetQJMS.java     |   36 +
 .../integration/HornetqBootstrapListener.java   |   55 +
 .../RestMessagingBootstrapListener.java         |   63 +
 .../ServletContextBindingRegistry.java          |   61 +
 .../rest/queue/AcknowledgedQueueConsumer.java   |  276 +
 .../org/hornetq/rest/queue/Acknowledgement.java |   66 +
 .../hornetq/rest/queue/ConsumedHttpMessage.java |   51 +
 .../org/hornetq/rest/queue/ConsumedMessage.java |   74 +
 .../rest/queue/ConsumedObjectMessage.java       |   61 +
 .../hornetq/rest/queue/ConsumersResource.java   |  327 +
 .../hornetq/rest/queue/DestinationResource.java |   54 +
 .../rest/queue/DestinationServiceManager.java   |  185 +
 .../hornetq/rest/queue/DestinationSettings.java |   63 +
 .../org/hornetq/rest/queue/PostMessage.java     |  300 +
 .../hornetq/rest/queue/PostMessageDupsOk.java   |  101 +
 .../hornetq/rest/queue/PostMessageNoDups.java   |   41 +
 .../org/hornetq/rest/queue/QueueConsumer.java   |  288 +
 .../org/hornetq/rest/queue/QueueDeployment.java |   43 +
 .../rest/queue/QueueDestinationsResource.java   |  207 +
 .../org/hornetq/rest/queue/QueueResource.java   |  209 +
 .../hornetq/rest/queue/QueueServiceManager.java |  119 +
 .../hornetq/rest/queue/push/FilePushStore.java  |  120 +
 .../rest/queue/push/HornetQPushStrategy.java    |   87 +
 .../hornetq/rest/queue/push/PushConsumer.java   |  161 +
 .../queue/push/PushConsumerMessageHandler.java  |   81 +
 .../rest/queue/push/PushConsumerResource.java   |  163 +
 .../org/hornetq/rest/queue/push/PushStore.java  |   34 +
 .../hornetq/rest/queue/push/PushStrategy.java   |   39 +
 .../hornetq/rest/queue/push/UriStrategy.java    |  239 +
 .../rest/queue/push/UriTemplateStrategy.java    |   29 +
 .../rest/queue/push/xml/Authentication.java     |   51 +
 .../rest/queue/push/xml/AuthenticationType.java |   26 +
 .../hornetq/rest/queue/push/xml/BasicAuth.java  |   58 +
 .../hornetq/rest/queue/push/xml/DigestAuth.java |   25 +
 .../rest/queue/push/xml/PushRegistration.java   |  211 +
 .../rest/queue/push/xml/XmlHttpHeader.java      |   65 +
 .../hornetq/rest/queue/push/xml/XmlLink.java    |  103 +
 .../topic/AcknowledgedSubscriptionResource.java |   66 +
 .../hornetq/rest/topic/FileTopicPushStore.java  |   46 +
 .../hornetq/rest/topic/PushSubscription.java    |   67 +
 .../rest/topic/PushSubscriptionsResource.java   |  257 +
 .../rest/topic/PushTopicRegistration.java       |   45 +
 .../org/hornetq/rest/topic/Subscription.java    |   32 +
 .../rest/topic/SubscriptionResource.java        |   66 +
 .../rest/topic/SubscriptionsResource.java       |  519 ++
 .../org/hornetq/rest/topic/TopicDeployment.java |   44 +
 .../rest/topic/TopicDestinationsResource.java   |  201 +
 .../org/hornetq/rest/topic/TopicPushStore.java  |   26 +
 .../org/hornetq/rest/topic/TopicResource.java   |  214 +
 .../hornetq/rest/topic/TopicServiceManager.java |  122 +
 .../java/org/hornetq/rest/util/Constants.java   |   23 +
 .../rest/util/CustomHeaderLinkStrategy.java     |   45 +
 .../hornetq/rest/util/HttpMessageHelper.java    |  173 +
 .../rest/util/LinkHeaderLinkStrategy.java       |   56 +
 .../org/hornetq/rest/util/LinkStrategy.java     |   24 +
 .../java/org/hornetq/rest/util/TimeoutTask.java |  198 +
 .../src/main/resources/schema/hornetq-rest.xsd  |  103 +
 .../org/hornetq/rest/test/AutoAckQueueTest.java |   86 +
 .../org/hornetq/rest/test/AutoAckTopicTest.java |  230 +
 .../hornetq/rest/test/ClientAckQueueTest.java   |  387 ++
 .../hornetq/rest/test/ClientAckTopicTest.java   |  338 +
 .../rest/test/CreateDestinationTest.java        |  186 +
 .../org/hornetq/rest/test/DupQueueTest.java     |  155 +
 .../java/org/hornetq/rest/test/Embedded.java    |  104 +
 .../org/hornetq/rest/test/EmbeddedTest.java     |  154 +
 .../hornetq/rest/test/FindDestinationTest.java  |  126 +
 .../java/org/hornetq/rest/test/JMSTest.java     |  298 +
 .../org/hornetq/rest/test/MessageTestBase.java  |   89 +
 .../test/PersistentPushQueueConsumerTest.java   |  213 +
 .../test/PersistentPushTopicConsumerTest.java   |  257 +
 .../rest/test/PushQueueConsumerTest.java        |  375 ++
 .../rest/test/PushTopicConsumerTest.java        |  372 ++
 .../java/org/hornetq/rest/test/RawAckTest.java  |  161 +
 .../hornetq/rest/test/RepostingQueueTest.java   |  575 ++
 .../hornetq/rest/test/RepostingTopicTest.java   |  712 ++
 .../hornetq/rest/test/RoundtripTimeTest.java    |   72 +
 .../org/hornetq/rest/test/SelectorTest.java     |  334 +
 .../java/org/hornetq/rest/test/SessionTest.java |  313 +
 .../org/hornetq/rest/test/TransformTest.java    |  264 +
 .../test/java/org/hornetq/rest/test/Util.java   |   49 +
 .../java/org/hornetq/rest/test/XmlTest.java     |   46 +
 .../test/resources/hornetq-configuration.xml    |   34 +
 hornetq-rest/src/test/resources/hornetq-jms.xml |   19 +
 .../src/test/resources/hornetq-rest.xml         |    3 +
 .../src/test/resources/hornetq-users.xml        |    7 +
 hornetq-selector/pom.xml                        |   96 +
 .../java/org/hornetq/selector/LRUCache.java     |  100 +
 .../org/hornetq/selector/SelectorParser.java    |  123 +
 .../selector/filter/ArithmeticExpression.java   |  258 +
 .../selector/filter/BinaryExpression.java       |  105 +
 .../selector/filter/BooleanExpression.java      |   36 +
 .../selector/filter/ComparisonExpression.java   |  651 ++
 .../selector/filter/ConstantExpression.java     |  191 +
 .../org/hornetq/selector/filter/Expression.java |   34 +
 .../selector/filter/FilterException.java        |   45 +
 .../org/hornetq/selector/filter/Filterable.java |   54 +
 .../selector/filter/LogicExpression.java        |  102 +
 .../selector/filter/PropertyExpression.java     |   75 +
 .../selector/filter/UnaryExpression.java        |  320 +
 .../selector/filter/XPathExpression.java        |   90 +
 .../selector/filter/XQueryExpression.java       |   54 +
 .../selector/filter/XalanXPathEvaluator.java    |   86 +
 .../org/hornetq/selector/filter/package.html    |   27 +
 .../src/main/javacc/HyphenatedParser.jj         |  563 ++
 .../src/main/javacc/StrictParser.jj             |  563 ++
 .../hornetq/selector/SelectorParserTest.java    |   81 +
 .../java/org/hornetq/selector/SelectorTest.java |  535 ++
 hornetq-server/pom.xml                          |  128 +
 .../api/core/management/MessageCounterInfo.java |  190 +
 .../org/hornetq/core/config/BackupStrategy.java |   20 +
 .../core/config/BridgeConfiguration.java        |  582 ++
 .../config/ClusterConnectionConfiguration.java  |  593 ++
 .../org/hornetq/core/config/Configuration.java  | 1058 +++
 .../hornetq/core/config/ConfigurationUtils.java |   36 +
 .../config/ConnectorServiceConfiguration.java   |   82 +
 .../core/config/CoreQueueConfiguration.java     |  140 +
 .../core/config/DivertConfiguration.java        |  228 +
 .../core/config/impl/ConfigurationImpl.java     | 1541 +++++
 .../core/config/impl/FileConfiguration.java     |  104 +
 .../hornetq/core/config/impl/Validators.java    |  169 +
 .../org/hornetq/core/deployers/Deployer.java    |   53 +
 .../core/deployers/DeploymentManager.java       |   37 +
 .../deployers/impl/AddressSettingsDeployer.java |  102 +
 .../impl/BasicUserCredentialsDeployer.java      |  145 +
 .../deployers/impl/FileConfigurationParser.java | 1698 +++++
 .../deployers/impl/FileDeploymentManager.java   |  333 +
 .../core/deployers/impl/QueueDeployer.java      |   93 +
 .../core/deployers/impl/SecurityDeployer.java   |  113 +
 .../core/deployers/impl/XmlDeployer.java        |  330 +
 .../java/org/hornetq/core/filter/Filter.java    |   30 +
 .../hornetq/core/filter/impl/FilterImpl.java    |  246 +
 .../core/management/impl/AbstractControl.java   |   99 +
 .../management/impl/AcceptorControlImpl.java    |  151 +
 .../management/impl/AddressControlImpl.java     |  281 +
 .../core/management/impl/BridgeControlImpl.java |  267 +
 .../impl/BroadcastGroupControlImpl.java         |  232 +
 .../impl/ClusterConnectionControlImpl.java      |  294 +
 .../core/management/impl/DivertControlImpl.java |  163 +
 .../impl/HornetQServerControlImpl.java          | 2032 ++++++
 .../core/management/impl/MBeanInfoHelper.java   |  156 +
 .../core/management/impl/QueueControlImpl.java  | 1006 +++
 .../core/messagecounter/MessageCounter.java     |  602 ++
 .../messagecounter/MessageCounterManager.java   |   44 +
 .../impl/MessageCounterHelper.java              |  227 +
 .../impl/MessageCounterManagerImpl.java         |  230 +
 .../core/paging/PageTransactionInfo.java        |   66 +
 .../org/hornetq/core/paging/PagedMessage.java   |   36 +
 .../org/hornetq/core/paging/PagingManager.java  |   87 +
 .../org/hornetq/core/paging/PagingStore.java    |  174 +
 .../hornetq/core/paging/PagingStoreFactory.java |   40 +
 .../core/paging/cursor/LivePageCache.java       |   28 +
 .../hornetq/core/paging/cursor/PageCache.java   |   60 +
 .../core/paging/cursor/PageCursorProvider.java  |   78 +
 .../core/paging/cursor/PagePosition.java        |   41 +
 .../core/paging/cursor/PageSubscription.java    |  158 +
 .../paging/cursor/PageSubscriptionCounter.java  |   59 +
 .../core/paging/cursor/PagedReference.java      |   28 +
 .../core/paging/cursor/PagedReferenceImpl.java  |  265 +
 .../paging/cursor/impl/LivePageCacheImpl.java   |  124 +
 .../core/paging/cursor/impl/PageCacheImpl.java  |  128 +
 .../cursor/impl/PageCursorProviderImpl.java     |  677 ++
 .../paging/cursor/impl/PagePositionImpl.java    |  154 +
 .../impl/PageSubscriptionCounterImpl.java       |  421 ++
 .../cursor/impl/PageSubscriptionImpl.java       | 1478 ++++
 .../java/org/hornetq/core/paging/impl/Page.java |  422 ++
 .../hornetq/core/paging/impl/PageSyncTimer.java |  114 +
 .../paging/impl/PageTransactionInfoImpl.java    |  352 +
 .../core/paging/impl/PagedMessageImpl.java      |  160 +
 .../core/paging/impl/PagingManagerImpl.java     |  330 +
 .../core/paging/impl/PagingStoreFactoryNIO.java |  213 +
 .../core/paging/impl/PagingStoreImpl.java       | 1243 ++++
 .../hornetq/core/persistence/GroupingInfo.java  |   28 +
 .../core/persistence/OperationContext.java      |   46 +
 .../core/persistence/QueueBindingInfo.java      |   42 +
 .../core/persistence/StorageManager.java        |  406 ++
 .../config/PersistedAddressSetting.java         |  130 +
 .../core/persistence/config/PersistedRoles.java |  335 +
 .../core/persistence/impl/PageCountPending.java |   25 +
 .../impl/journal/AddMessageRecord.java          |   44 +
 .../impl/journal/BatchingIDGenerator.java       |  149 +
 .../impl/journal/DescribeJournal.java           |  749 +++
 .../impl/journal/JournalRecordIds.java          |   81 +
 .../impl/journal/JournalStorageManager.java     | 3838 +++++++++++
 .../impl/journal/LargeServerMessageImpl.java    |  531 ++
 .../impl/journal/LargeServerMessageInSync.java  |  158 +
 .../impl/journal/OperationContextImpl.java      |  369 +
 .../nullpm/NullStorageLargeServerMessage.java   |  108 +
 .../impl/nullpm/NullStorageManager.java         |  630 ++
 .../org/hornetq/core/postoffice/Address.java    |   38 +
 .../hornetq/core/postoffice/AddressManager.java |   49 +
 .../org/hornetq/core/postoffice/Binding.java    |   68 +
 .../hornetq/core/postoffice/BindingType.java    |   56 +
 .../org/hornetq/core/postoffice/Bindings.java   |   42 +
 .../core/postoffice/BindingsFactory.java        |   25 +
 .../core/postoffice/DuplicateIDCache.java       |   44 +
 .../org/hornetq/core/postoffice/PostOffice.java |   94 +
 .../hornetq/core/postoffice/QueueBinding.java   |   31 +
 .../org/hornetq/core/postoffice/QueueInfo.java  |  158 +
 .../core/postoffice/impl/AddressImpl.java       |  176 +
 .../core/postoffice/impl/BindingsImpl.java      |  674 ++
 .../core/postoffice/impl/DivertBinding.java     |  166 +
 .../postoffice/impl/DuplicateIDCacheImpl.java   |  364 +
 .../core/postoffice/impl/LocalQueueBinding.java |  171 +
 .../core/postoffice/impl/PostOfficeImpl.java    | 1516 +++++
 .../postoffice/impl/SimpleAddressManager.java   |  211 +
 .../postoffice/impl/WildcardAddressManager.java |  257 +
 .../hornetq/core/protocol/ProtocolHandler.java  |  203 +
 .../core/protocol/ServerPacketDecoder.java      |  236 +
 .../core/ServerSessionPacketHandler.java        |  688 ++
 .../protocol/core/impl/CoreProtocolManager.java |  376 ++
 .../core/impl/CoreProtocolManagerFactory.java   |   44 +
 .../protocol/core/impl/CoreSessionCallback.java |  126 +
 .../core/impl/HornetQPacketHandler.java         |  297 +
 .../wireformat/BackupRegistrationMessage.java   |  136 +
 .../BackupReplicationStartFailedMessage.java    |  113 +
 .../impl/wireformat/BackupRequestMessage.java   |  128 +
 .../impl/wireformat/BackupResponseMessage.java  |   63 +
 .../impl/wireformat/ClusterConnectMessage.java  |   61 +
 .../wireformat/ClusterConnectReplyMessage.java  |   63 +
 .../impl/wireformat/NodeAnnounceMessage.java    |  251 +
 .../core/impl/wireformat/QuorumVoteMessage.java |   71 +
 .../impl/wireformat/QuorumVoteReplyMessage.java |   75 +
 .../impl/wireformat/ReplicationAddMessage.java  |  163 +
 .../wireformat/ReplicationAddTXMessage.java     |  182 +
 .../wireformat/ReplicationCommitMessage.java    |  117 +
 .../wireformat/ReplicationDeleteMessage.java    |   97 +
 .../wireformat/ReplicationDeleteTXMessage.java  |  149 +
 .../ReplicationLargeMessageBeginMessage.java    |   84 +
 .../ReplicationLargeMessageEndMessage.java      |   84 +
 .../ReplicationLargeMessageWriteMessage.java    |  108 +
 .../ReplicationLiveIsStoppingMessage.java       |   93 +
 .../wireformat/ReplicationPageEventMessage.java |  129 +
 .../wireformat/ReplicationPageWriteMessage.java |  112 +
 .../wireformat/ReplicationPrepareMessage.java   |  145 +
 .../wireformat/ReplicationResponseMessage.java  |   27 +
 .../wireformat/ReplicationStartSyncMessage.java |  224 +
 .../wireformat/ReplicationSyncFileMessage.java  |  280 +
 .../wireformat/ScaleDownAnnounceMessage.java    |   59 +
 .../protocol/stomp/WebSocketServerHandler.java  |  185 +
 .../core/registry/JndiBindingRegistry.java      |  149 +
 .../core/registry/MapBindingRegistry.java       |   57 +
 .../core/remoting/impl/invm/InVMAcceptor.java   |  302 +
 .../remoting/impl/invm/InVMAcceptorFactory.java |   52 +
 .../core/remoting/impl/invm/InVMConnection.java |  260 +
 .../core/remoting/impl/invm/InVMConnector.java  |  242 +
 .../impl/invm/InVMConnectorFactory.java         |   56 +
 .../core/remoting/impl/invm/InVMRegistry.java   |   62 +
 .../remoting/impl/invm/TransportConstants.java  |   57 +
 .../remoting/impl/netty/ConnectionCreator.java  |   21 +
 .../impl/netty/HttpAcceptorHandler.java         |  252 +
 .../impl/netty/HttpKeepAliveRunnable.java       |   75 +
 .../core/remoting/impl/netty/NettyAcceptor.java |  773 +++
 .../impl/netty/NettyAcceptorFactory.java        |   50 +
 .../impl/netty/NettyServerConnection.java       |   37 +
 .../core/remoting/server/RemotingService.java   |   81 +
 .../server/impl/RemotingServiceImpl.java        |  750 +++
 .../core/replication/ReplicatedJournal.java     |  559 ++
 .../replication/ReplicatedLargeMessage.java     |   52 +
 .../core/replication/ReplicationEndpoint.java   |  951 +++
 .../core/replication/ReplicationManager.java    |  695 ++
 .../org/hornetq/core/security/CheckType.java    |   82 +
 .../hornetq/core/security/SecurityStore.java    |   30 +
 .../core/security/impl/SecurityStoreImpl.java   |  248 +
 .../hornetq/core/server/ActivateCallback.java   |   29 +
 .../hornetq/core/server/ActivationParams.java   |   18 +
 .../java/org/hornetq/core/server/Bindable.java  |   29 +
 .../hornetq/core/server/BindingQueryResult.java |   48 +
 .../hornetq/core/server/ConnectorService.java   |   22 +
 .../core/server/ConnectorServiceFactory.java    |   36 +
 .../java/org/hornetq/core/server/Consumer.java  |   73 +
 .../java/org/hornetq/core/server/Divert.java    |   36 +
 .../org/hornetq/core/server/HandleStatus.java   |   31 +
 .../core/server/HornetQMessageBundle.java       |  359 +
 .../org/hornetq/core/server/HornetQServer.java  |  272 +
 .../core/server/HornetQServerLogger.java        | 1333 ++++
 .../org/hornetq/core/server/HornetQServers.java |  123 +
 .../org/hornetq/core/server/JournalType.java    |   25 +
 .../hornetq/core/server/LargeServerMessage.java |   53 +
 .../hornetq/core/server/LiveNodeLocator.java    |   93 +
 .../org/hornetq/core/server/MemoryManager.java  |  157 +
 .../hornetq/core/server/MessageReference.java   |   75 +
 .../org/hornetq/core/server/NodeManager.java    |  280 +
 .../java/org/hornetq/core/server/Queue.java     |  261 +
 .../org/hornetq/core/server/QueueFactory.java   |   45 +
 .../hornetq/core/server/RouteContextList.java   |   38 +
 .../org/hornetq/core/server/RoutingContext.java |   52 +
 .../core/server/ScheduledDeliveryHandler.java   |   33 +
 .../org/hornetq/core/server/ServerConsumer.java |   61 +
 .../org/hornetq/core/server/ServerMessage.java  |   77 +
 .../org/hornetq/core/server/ServerSession.java  |  157 +
 .../core/server/TransientQueueManager.java      |   25 +
 .../core/server/cluster/BackupManager.java      |  416 ++
 .../org/hornetq/core/server/cluster/Bridge.java |   57 +
 .../core/server/cluster/BroadcastGroup.java     |   42 +
 .../cluster/ClusterConfigurationUtil.java       |   93 +
 .../core/server/cluster/ClusterConnection.java  |   78 +
 .../core/server/cluster/ClusterControl.java     |  214 +
 .../core/server/cluster/ClusterController.java  |  494 ++
 .../core/server/cluster/ClusterManager.java     |  919 +++
 .../core/server/cluster/MessageFlowRecord.java  |   43 +
 .../core/server/cluster/RemoteQueueBinding.java |   40 +
 .../core/server/cluster/Transformer.java        |   29 +
 .../core/server/cluster/ha/HAManager.java       |  585 ++
 .../core/server/cluster/ha/HAPolicy.java        |  355 +
 .../server/cluster/ha/HAPolicyTemplate.java     |  118 +
 .../core/server/cluster/impl/BridgeImpl.java    | 1279 ++++
 .../server/cluster/impl/BroadcastGroupImpl.java |  245 +
 .../cluster/impl/ClusterConnectionBridge.java   |  335 +
 .../cluster/impl/ClusterConnectionImpl.java     | 1741 +++++
 .../core/server/cluster/impl/Redistributor.java |  309 +
 .../cluster/impl/RemoteQueueBindingImpl.java    |  383 ++
 .../core/server/cluster/qourum/BooleanVote.java |   60 +
 .../core/server/cluster/qourum/Quorum.java      |   47 +
 .../server/cluster/qourum/QuorumManager.java    |  372 ++
 .../core/server/cluster/qourum/QuorumVote.java  |   77 +
 .../cluster/qourum/QuorumVoteHandler.java       |   37 +
 .../cluster/qourum/QuorumVoteServerConnect.java |  138 +
 .../qourum/SharedNothingBackupQuorum.java       |  301 +
 .../core/server/cluster/qourum/Vote.java        |   47 +
 .../core/server/embedded/EmbeddedHornetQ.java   |  118 +
 .../core/server/group/GroupingHandler.java      |   57 +
 .../core/server/group/UnproposalListener.java   |   25 +
 .../core/server/group/impl/GroupBinding.java    |   83 +
 .../group/impl/GroupHandlingAbstract.java       |  125 +
 .../impl/GroupingHandlerConfiguration.java      |  188 +
 .../server/group/impl/LocalGroupingHandler.java |  532 ++
 .../core/server/group/impl/Proposal.java        |   49 +
 .../group/impl/RemoteGroupingHandler.java       |  332 +
 .../core/server/group/impl/Response.java        |   93 +
 .../server/impl/AIOFileLockNodeManager.java     |  127 +
 .../impl/AnyLiveNodeLocatorForReplication.java  |  183 +
 .../impl/AnyLiveNodeLocatorForScaleDown.java    |  182 +
 .../impl/BackupRecoveryJournalLoader.java       |  104 +
 .../server/impl/BackupTopologyListener.java     |   59 +
 .../core/server/impl/ConnectorsService.java     |  142 +
 .../hornetq/core/server/impl/DivertImpl.java    |  163 +
 .../core/server/impl/FileLockNodeManager.java   |  353 +
 .../core/server/impl/HornetQServerImpl.java     | 3379 ++++++++++
 .../core/server/impl/InVMNodeManager.java       |  164 +
 .../hornetq/core/server/impl/JournalLoader.java |   54 +
 .../core/server/impl/LastValueQueue.java        |  351 +
 .../core/server/impl/MessageReferenceImpl.java  |  239 +
 .../NamedLiveNodeLocatorForReplication.java     |  140 +
 .../impl/NamedLiveNodeLocatorForScaleDown.java  |  186 +
 .../server/impl/NamedNodeIdNodeLocator.java     |   70 +
 .../server/impl/PostOfficeJournalLoader.java    |  506 ++
 .../core/server/impl/QueueFactoryImpl.java      |  112 +
 .../org/hornetq/core/server/impl/QueueImpl.java | 3340 +++++++++
 .../core/server/impl/ReplicationError.java      |   82 +
 .../core/server/impl/RoutingContextImpl.java    |  171 +
 .../core/server/impl/ScaleDownHandler.java      |  503 ++
 .../impl/ScheduledDeliveryHandlerImpl.java      |  352 +
 .../core/server/impl/ServerConsumerImpl.java    | 1260 ++++
 .../hornetq/core/server/impl/ServerInfo.java    |   90 +
 .../core/server/impl/ServerMessageImpl.java     |  374 ++
 .../core/server/impl/ServerSessionImpl.java     | 1755 +++++
 .../server/impl/TransientQueueManagerImpl.java  |   85 +
 .../server/management/ManagementService.java    |  130 +
 .../management/impl/ManagementServiceImpl.java  |  847 +++
 .../core/settings/HierarchicalRepository.java   |   90 +
 .../HierarchicalRepositoryChangeListener.java   |   21 +
 .../org/hornetq/core/settings/Mergeable.java    |   23 +
 .../core/settings/impl/AddressSettings.java     |  640 ++
 .../impl/HierarchicalObjectRepository.java      |  459 ++
 .../org/hornetq/core/settings/impl/Match.java   |  128 +
 .../core/transaction/ResourceManager.java       |   51 +
 .../hornetq/core/transaction/Transaction.java   |   73 +
 .../core/transaction/TransactionDetail.java     |  123 +
 .../core/transaction/TransactionOperation.java  |   59 +
 .../TransactionOperationAbstract.java           |   86 +
 .../transaction/TransactionPropertyIndexes.java |   42 +
 .../impl/BindingsTransactionImpl.java           |   51 +
 .../transaction/impl/CoreTransactionDetail.java |   66 +
 .../transaction/impl/ResourceManagerImpl.java   |  267 +
 .../core/transaction/impl/TransactionImpl.java  |  530 ++
 .../spi/core/naming/BindingRegistry.java        |   41 +
 .../spi/core/protocol/ProtocolManager.java      |   39 +
 .../core/protocol/ProtocolManagerFactory.java   |   32 +
 .../spi/core/protocol/SessionCallback.java      |   45 +
 .../org/hornetq/spi/core/remoting/Acceptor.java |   59 +
 .../spi/core/remoting/AcceptorFactory.java      |   63 +
 .../ServerConnectionLifeCycleListener.java      |   30 +
 .../core/security/HornetQSecurityManager.java   |   78 +
 .../security/HornetQSecurityManagerImpl.java    |  212 +
 .../spi/core/security/JAASSecurityManager.java  |  304 +
 .../hornetq/spi/core/security/package-info.java |   21 +
 .../org/hornetq/utils/XMLConfigurationUtil.java |  139 +
 .../resources/schema/hornetq-configuration.xsd  | 2017 ++++++
 .../src/main/resources/schema/hornetq-users.xsd |   29 +
 .../core/config/impl/ConfigurationImplTest.java |  544 ++
 .../impl/DefaultsFileConfigurationTest.java     |  180 +
 .../impl/FileConfigurationParserTest.java       |  202 +
 .../core/config/impl/FileConfigurationTest.java |  387 ++
 .../core/config/impl/ValidatorsTest.java        |  138 +
 .../WrongRoleFileConfigurationParserTest.java   |  130 +
 .../hornetq/core/filter/impl/FilterTest.java    |  764 +++
 .../core/list/PriorityLinkedListTest.java       |  914 +++
 .../core/message/impl/MessagePropertyTest.java  |  119 +
 .../org/hornetq/core/security/RoleTest.java     |  114 +
 .../group/impl/ClusteredResetMockTest.java      |  424 ++
 .../core/server/impl/EmbeddedServerTest.java    |   78 +
 .../impl/ScheduledDeliveryHandlerTest.java      | 1498 +++++
 .../core/version/impl/VersionImplTest.java      |  106 +
 .../tests/logging/AssertionLoggerHandler.java   |  152 +
 .../tests/util/ColocatedHornetQServer.java      |   98 +
 .../util/CountDownSessionFailureListener.java   |   68 +
 .../tests/util/InVMNodeManagerServer.java       |   73 +
 .../org/hornetq/tests/util/ServiceTestBase.java | 1203 ++++
 .../hornetq/tests/util/SimpleStringTest.java    |  458 ++
 .../tests/util/SingleServerTestBase.java        |   65 +
 .../org/hornetq/tests/util/UnitTestCase.java    | 2086 ++++++
 .../resources/ConfigurationTest-defaults.xml    |    6 +
 .../resources/ConfigurationTest-full-config.xml |  286 +
 .../resources/InvalidConfigurationTest0.xml     |  235 +
 .../resources/InvalidConfigurationTest1.xml     |  235 +
 .../resources/InvalidConfigurationTest2.xml     |  235 +
 .../resources/InvalidConfigurationTest3.xml     |  236 +
 .../resources/InvalidConfigurationTest4.xml     |  234 +
 .../resources/InvalidConfigurationTest5.xml     |  237 +
 .../resources/divertRoutingNameNotRequired.xml  |   94 +
 .../src/test/resources/logging.properties       |   61 +
 hornetq-service-sar/pom.xml                     |   49 +
 .../HornetQFileConfigurationService.java        |   50 +
 .../HornetQFileConfigurationServiceMBean.java   |   32 +
 .../service/HornetQJMSStarterService.java       |   46 +
 .../service/HornetQJMSStarterServiceMBean.java  |   27 +
 .../hornetq/service/HornetQServiceBundle.java   |   31 +
 .../hornetq/service/HornetQServiceLogger.java   |   38 +
 .../hornetq/service/HornetQStarterService.java  |  118 +
 .../service/HornetQStarterServiceMBean.java     |   36 +
 .../service/JBossASSecurityManagerService.java  |   35 +
 .../JBossASSecurityManagerServiceMBean.java     |   26 +
 hornetq-tools/pom.xml                           |   73 +
 .../main/java/org/hornetq/tools/DataTool.java   |  232 +
 .../org/hornetq/tools/HornetQToolsLogger.java   |   42 +
 .../src/main/java/org/hornetq/tools/Main.java   |   98 +
 .../main/java/org/hornetq/tools/PrintData.java  |   82 +
 .../main/java/org/hornetq/tools/PrintPages.java |  313 +
 .../org/hornetq/tools/XmlDataConstants.java     |  120 +
 .../java/org/hornetq/tools/XmlDataExporter.java | 1121 ++++
 .../java/org/hornetq/tools/XmlDataImporter.java | 1065 +++
 .../hornetq-aerogear-integration/pom.xml        |   52 +
 .../aerogear/AeroGearConnectorService.java      |  400 ++
 .../AeroGearConnectorServiceFactory.java        |   44 +
 .../integration/aerogear/AeroGearConstants.java |   75 +
 .../aerogear/HornetQAeroGearBundle.java         |   46 +
 .../aerogear/HornetQAeroGearLogger.java         |   66 +
 .../hornetq-jboss-as-integration/pom.xml        |   61 +
 .../integration/jboss/HornetQJBossBundle.java   |   31 +
 .../integration/jboss/HornetQJBossLogger.java   |   58 +
 .../jboss/security/AS4SecurityActions.java      |  126 +
 .../jboss/security/JBossASSecurityManager.java  |  309 +
 .../jboss/security/SecurityActions.java         |  163 +
 .../tm/JBoss4TransactionManagerLocator.java     |   28 +
 .../tm/JBoss5TransactionManagerLocator.java     |   28 +
 integration/hornetq-spring-integration/pom.xml  |   74 +
 .../spring/SpringBindingRegistry.java           |   71 +
 .../integration/spring/SpringJmsBootstrap.java  |   31 +
 .../org/hornetq/spring/HornetQSpringBundle.java |   31 +
 .../org/hornetq/spring/HornetQSpringLogger.java |   37 +
 integration/hornetq-twitter-integration/pom.xml |   44 +
 .../integration/twitter/TwitterConstants.java   |   95 +
 .../TwitterIncomingConnectorServiceFactory.java |   48 +
 .../TwitterOutgoingConnectorServiceFactory.java |   45 +
 .../twitter/impl/IncomingTweetsHandler.java     |  230 +
 .../twitter/impl/OutgoingTweetsHandler.java     |  262 +
 .../hornetq/twitter/HornetQTwitterBundle.java   |   31 +
 .../hornetq/twitter/HornetQTwitterLogger.java   |   54 +
 integration/hornetq-vertx-integration/pom.xml   |  127 +
 .../integration/vertx/HornetQVertxLogger.java   |   53 +
 .../vertx/IncomingVertxEventHandler.java        |  319 +
 .../vertx/OutgoingVertxEventHandler.java        |  328 +
 .../integration/vertx/VertxConstants.java       |   80 +
 .../VertxIncomingConnectorServiceFactory.java   |   50 +
 .../VertxOutgoingConnectorServiceFactory.java   |   48 +
 pom.xml                                         |  980 +++
 scripts/README                                  |    2 +
 scripts/replace-wildfly.sh                      |   34 +
 tests/byteman-tests/pom.xml                     |  229 +
 .../hornetq/byteman/tests/BMFailoverTest.java   |  319 +
 .../BridgeServerLocatorConfigurationTest.java   |  172 +
 .../byteman/tests/ClusteredGroupingTest.java    |  469 ++
 .../org/hornetq/byteman/tests/GroupingTest.java |  198 +
 .../tests/HornetQMessageHandlerTest.java        |  427 ++
 .../org/hornetq/byteman/tests/LatencyTest.java  |   65 +
 .../hornetq/byteman/tests/MessageCopyTest.java  |  202 +
 .../byteman/tests/ScaleDownFailoverTest.java    |  187 +
 .../byteman/tests/ScaleDownFailureTest.java     |  110 +
 .../tests/ScaleDownGroupedFailoverTest.java     |   21 +
 .../tests/ScaleDownGroupedFailureTest.java      |   21 +
 .../byteman/tests/StartStopDeadlockTest.java    |  164 +
 .../byteman/tests/StompInternalStateTest.java   |  142 +
 .../impl/HierarchicalObjectRepositoryTest.java  |  152 +
 tests/concurrent-tests/pom.xml                  |   97 +
 .../tests/concurrent/server/impl/QueueTest.java |  226 +
 .../concurrent/stomp/ConcurrentStompTest.java   |  156 +
 tests/config/logging.properties                 |   66 +
 .../config/server-start-stop-backup-config1.xml |   41 +
 .../server-start-stop-backup-jms-config1.xml    |   16 +
 tests/config/server-start-stop-live-config1.xml |   45 +
 .../server-start-stop-live-jms-config1.xml      |   18 +
 tests/integration-tests/pom.xml                 |  246 +
 .../integration/DuplicateDetectionTest.java     | 2274 +++++++
 .../integration/IntegrationTestLogger.java      |   31 +
 .../tests/integration/InterceptorTest.java      | 1125 ++++
 .../integration/SimpleNotificationService.java  |   93 +
 .../tests/integration/String64KLimitTest.java   |  219 +
 .../aerogear/AeroGearBasicServerTest.java       |  384 ++
 .../integration/client/AckBatchSizeTest.java    |  140 +
 .../integration/client/AcknowledgeTest.java     |  814 +++
 .../integration/client/AddressSettingsTest.java |  372 ++
 .../integration/client/AutoCloseCoreTest.java   |   48 +
 .../integration/client/AutogroupIdTest.java     |  229 +
 .../integration/client/BlockingSendTest.java    |   83 +
 .../integration/client/CommitRollbackTest.java  |  293 +
 .../ConcurrentCreateDeleteProduceTest.java      |  170 +
 .../integration/client/ConsumerCloseTest.java   |  326 +
 .../integration/client/ConsumerFilterTest.java  |  304 +
 .../client/ConsumerRoundRobinTest.java          |   85 +
 .../tests/integration/client/ConsumerTest.java  |  660 ++
 .../client/ConsumerWindowSizeTest.java          | 1582 +++++
 .../integration/client/CoreClientTest.java      |  127 +
 .../client/CreateQueueIdempotentTest.java       |  181 +
 .../client/DeadLetterAddressTest.java           |  529 ++
 .../integration/client/DeliveryOrderTest.java   |  195 +
 .../integration/client/DurableQueueTest.java    |  157 +
 .../client/ExpireTestOnRestartTest.java         |  162 +
 .../integration/client/ExpiryAddressTest.java   |  395 ++
 .../client/ExpiryLargeMessageTest.java          |  412 ++
 .../integration/client/FailureDeadlockTest.java |  198 +
 ...FlowControlOnIgnoreLargeMessageBodyTest.java |  420 ++
 .../integration/client/HangConsumerTest.java    |  715 ++
 .../integration/client/HeuristicXATest.java     |  505 ++
 .../integration/client/HornetQCrashTest.java    |  158 +
 .../InVMNonPersistentMessageBufferTest.java     |  286 +
 .../client/InVMPersistentMessageBufferTest.java |   35 +
 .../client/IncompatibleVersionTest.java         |  304 +
 .../client/InterruptedLargeMessageTest.java     |  772 +++
 .../client/JMSMessageCounterTest.java           |   76 +
 .../client/JMSPagingFileDeleteTest.java         |  282 +
 .../client/JmsNettyNioStressTest.java           |  331 +
 .../integration/client/JournalCrashTest.java    |  249 +
 .../LargeMessageAvoidLargeMessagesTest.java     |  415 ++
 .../client/LargeMessageCompressTest.java        |  415 ++
 .../integration/client/LargeMessageTest.java    | 3213 +++++++++
 .../client/LibaioDependencyCheckTest.java       |   60 +
 .../client/MessageConcurrencyTest.java          |  261 +
 .../client/MessageConsumerRollbackTest.java     |  286 +
 .../integration/client/MessageCounterTest.java  |  101 +
 .../client/MessageDurabilityTest.java           |  222 +
 .../client/MessageExpirationTest.java           |  260 +
 .../MessageGroupingConnectionFactoryTest.java   |  176 +
 .../integration/client/MessageGroupingTest.java |  668 ++
 .../integration/client/MessageHandlerTest.java  |  408 ++
 .../integration/client/MessagePriorityTest.java |  368 +
 .../integration/client/MessageRateTest.java     |  224 +
 .../client/MultipleThreadFilterOneTest.java     |  324 +
 .../tests/integration/client/NIOvsOIOTest.java  |  335 +
 .../integration/client/NettyConnectorTest.java  |   75 +
 .../integration/client/NettyConsumerTest.java   |   29 +
 .../client/NettyConsumerWindowSizeTest.java     |   49 +
 .../NettyNonPersistentMessageBufferTest.java    |   35 +
 .../NettyPersistentMessageBufferTest.java       |   35 +
 .../client/NettyProducerFlowControlTest.java    |   30 +
 .../client/NewDeadLetterAddressTest.java        |  113 +
 .../tests/integration/client/OrderTest.java     |  301 +
 .../integration/client/PagingOrderTest.java     |  873 +++
 .../integration/client/PagingSyncTest.java      |  122 +
 .../tests/integration/client/PagingTest.java    | 6311 ++++++++++++++++++
 .../integration/client/ProducerCloseTest.java   |   84 +
 .../client/ProducerFlowControlTest.java         |  871 +++
 .../tests/integration/client/ProducerTest.java  |  168 +
 .../integration/client/QueueBrowserTest.java    |  401 ++
 .../client/ReceiveImmediateTest.java            |  265 +
 .../tests/integration/client/ReceiveTest.java   |  171 +
 .../client/RedeliveryConsumerTest.java          |  378 ++
 .../tests/integration/client/RequestorTest.java |  325 +
 .../tests/integration/client/RoutingTest.java   |  242 +
 .../client/SelfExpandingBufferTest.java         |  147 +
 .../client/ServerLocatorConnectTest.java        |  184 +
 .../client/ServerLocatorSerializationTest.java  |  127 +
 .../client/SessionCloseOnGCTest.java            |  252 +
 .../integration/client/SessionCloseTest.java    |  296 +
 ...onClosedOnRemotingConnectionFailureTest.java |  123 +
 .../client/SessionCreateAndDeleteQueueTest.java |  162 +
 .../client/SessionCreateConsumerTest.java       |  125 +
 .../client/SessionCreateProducerTest.java       |   92 +
 .../integration/client/SessionFactoryTest.java  |  591 ++
 .../SessionSendAcknowledgementHandlerTest.java  |  196 +
 .../client/SessionStopStartTest.java            |  708 ++
 .../tests/integration/client/SessionTest.java   |  504 ++
 .../client/SimpleSendMultipleQueuesTest.java    |  138 +
 .../integration/client/TemporaryQueueTest.java  |  694 ++
 .../client/TransactionDurabilityTest.java       |  191 +
 .../client/TransactionalSendTest.java           |  108 +
 .../integration/client/TransientQueueTest.java  |  244 +
 .../integration/client/WildCardRoutingTest.java |  826 +++
 .../clientcrash/ClientCrashTest.java            |  178 +
 .../integration/clientcrash/ClientExitTest.java |  119 +
 .../integration/clientcrash/ClientTestBase.java |   77 +
 .../integration/clientcrash/CrashClient.java    |   93 +
 .../integration/clientcrash/CrashClient2.java   |  105 +
 .../clientcrash/DummyInterceptor.java           |   69 +
 .../clientcrash/DummyInterceptorB.java          |   51 +
 .../integration/clientcrash/GracefulClient.java |   98 +
 .../integration/cluster/NodeManagerAction.java  |  146 +
 .../integration/cluster/NodeManagerTest.java    |  206 +
 .../cluster/RealNodeManagerTest.java            |   65 +
 .../cluster/bridge/BridgeFailoverTest.java      |  296 +
 .../cluster/bridge/BridgeReconnectTest.java     |  797 +++
 .../cluster/bridge/BridgeStartTest.java         |  828 +++
 .../integration/cluster/bridge/BridgeTest.java  | 1930 ++++++
 .../cluster/bridge/BridgeTestBase.java          |  147 +
 .../BridgeWithDiscoveryGroupStartTest.java      |  259 +
 .../bridge/NettyBridgeReconnectTest.java        |   28 +
 .../cluster/bridge/NettyBridgeStartTest.java    |   31 +
 .../cluster/bridge/NettyBridgeTest.java         |   30 +
 .../NettyBridgeWithDiscoveryGroupStartTest.java |   29 +
 .../cluster/bridge/SimpleTransformer.java       |   62 +
 .../distribution/ClusterHeadersRemovedTest.java |   94 +
 .../cluster/distribution/ClusterTestBase.java   | 2221 ++++++
 .../distribution/ClusterWithBackupTest.java     |  125 +
 .../distribution/ClusteredGroupingTest.java     | 1804 +++++
 .../ClusteredRequestResponseTest.java           |  159 +
 .../LargeMessageRedistributionTest.java         |   30 +
 .../distribution/MessageRedistributionTest.java | 1177 ++++
 .../MessageRedistributionWithDiscoveryTest.java |  196 +
 .../NettyFileStorageSymmetricClusterTest.java   |   40 +
 ...leStorageSymmetricClusterWithBackupTest.java |   36 +
 ...torageSymmetricClusterWithDiscoveryTest.java |   41 +
 .../NettyOneWayChainClusterTest.java            |   33 +
 .../NettyOneWayTwoNodeClusterTest.java          |   31 +
 .../distribution/NettySymmetricClusterTest.java |   31 +
 .../NettySymmetricClusterWithBackupTest.java    |   32 +
 .../NettySymmetricClusterWithDiscoveryTest.java |   32 +
 .../distribution/OneWayChainClusterTest.java    |  407 ++
 .../distribution/OnewayTwoNodeClusterTest.java  | 1257 ++++
 .../SimpleSymmetricClusterTest.java             |  400 ++
 .../distribution/SymmetricClusterTest.java      | 1812 +++++
 .../SymmetricClusterWithBackupTest.java         |  575 ++
 .../SymmetricClusterWithDiscoveryTest.java      |  104 +
 .../distribution/TemporaryQueueClusterTest.java |  111 +
 .../distribution/TwoWayTwoNodeClusterTest.java  |  205 +
 .../TwoWayTwoNodeClusterWithDiscoveryTest.java  |   61 +
 .../AlmostLargeAsynchronousFailoverTest.java    |   51 +
 .../failover/AsynchronousFailoverTest.java      |  622 ++
 .../AutomaticColocatedQuorumVoteTest.java       |  333 +
 .../failover/BackupAuthenticationTest.java      |  101 +
 .../cluster/failover/BackupSyncJournalTest.java |  414 ++
 .../failover/BackupSyncLargeMessageTest.java    |  195 +
 .../cluster/failover/BackupSyncPagingTest.java  |   71 +
 .../ClusterWithBackupFailoverTestBase.java      |  440 ++
 ...ColocatedFailoverCheckPairingsNettyTest.java |  113 +
 .../ColocatedFailoverCheckPairingsTest.java     |  160 +
 .../cluster/failover/ColocatedFailoverTest.java | 1403 ++++
 .../cluster/failover/DelayInterceptor.java      |   42 +
 .../cluster/failover/DelayInterceptor2.java     |   59 +
 .../cluster/failover/DelayInterceptor3.java     |   43 +
 .../DiscoveryClusterWithBackupFailoverTest.java |   60 +
 .../cluster/failover/FailBackAutoTest.java      |  343 +
 .../cluster/failover/FailBackManualTest.java    |  234 +
 .../cluster/failover/FailoverListenerTest.java  |  300 +
 .../failover/FailoverOnFlowControlTest.java     |  149 +
 .../cluster/failover/FailoverTest.java          | 2406 +++++++
 .../cluster/failover/FailoverTestBase.java      |  369 +
 .../GroupingFailoverReplicationTest.java        |   27 +
 .../GroupingFailoverSharedServerTest.java       |   28 +
 .../failover/GroupingFailoverTestBase.java      |  227 +
 .../failover/LargeMessageFailoverTest.java      |   73 +
 .../failover/LiveToLiveFailoverTest.java        |  437 ++
 .../MultipleBackupsFailoverTestBase.java        |  187 +
 ...ultipleLivesMultipleBackupsFailoverTest.java |  242 +
 .../MultipleServerFailoverTestBase.java         |  290 +
 .../failover/NettyAsynchronousFailoverTest.java |   37 +
 .../failover/NettyAsynchronousReattachTest.java |   42 +
 ...yDiscoveryClusterWithBackupFailoverTest.java |   29 +
 .../cluster/failover/NettyFailoverTest.java     |   93 +
 ...eDiscoveryClusterWithBackupFailoverTest.java |   29 +
 ...rageStaticClusterWithBackupFailoverTest.java |   29 +
 .../failover/NettyReplicatedFailoverTest.java   |   63 +
 ...ettyStaticClusterWithBackupFailoverTest.java |   29 +
 .../cluster/failover/PagingFailoverTest.java    |  262 +
 .../cluster/failover/QuorumFailOverTest.java    |  132 +
 .../failover/QuorumVoteServerConnectTest.java   |   82 +
 .../ReplicatedAsynchronousFailoverTest.java     |   28 +
 .../failover/ReplicatedDistributionTest.java    |  252 +
 .../failover/ReplicatedFailoverTest.java        |  130 +
 ...eplicatedFailoverUsingNodeGroupNameTest.java |   24 +
 .../ReplicatedLargeMessageFailoverTest.java     |   65 +
 ...icatedLargeMessageWithDelayFailoverTest.java |   57 +
 ...ltipleServerFailoverNoNodeGroupNameTest.java |   27 +
 ...eplicatedManyMultipleServerFailoverTest.java |   33 +
 ...dMultipleServerFailoverExtraBackupsTest.java |  148 +
 ...ltipleServerFailoverNoGroupNodeNameTest.java |   27 +
 .../ReplicatedMultipleServerFailoverTest.java   |  237 +
 ...ReplicatedNettyAsynchronousFailoverTest.java |   30 +
 .../failover/ReplicatedPagedFailoverTest.java   |   40 +
 .../failover/ReplicatedPagingFailoverTest.java  |   31 +
 .../ReplicatedWithDelayFailoverTest.java        |   52 +
 .../cluster/failover/SecurityFailoverTest.java  |  148 +
 .../failover/SharedStoreDistributionTest.java   |   26 +
 .../SingleLiveMultipleBackupsFailoverTest.java  |  215 +
 .../StaticClusterWithBackupFailoverTest.java    |   93 +
 .../remote/FailoverWithSharedStoreTest.java     |   50 +
 .../ha/HAAutomaticBackupSharedStore.java        |   72 +
 .../reattach/MultiThreadRandomReattachTest.java |   53 +
 .../MultiThreadRandomReattachTestBase.java      | 1490 +++++
 .../MultiThreadReattachSupportTestBase.java     |  270 +
 .../NettyMultiThreadRandomReattachTest.java     |   53 +
 .../cluster/reattach/OrderReattachTest.java     |  315 +
 .../cluster/reattach/RandomReattachTest.java    | 1589 +++++
 .../cluster/reattach/ReattachTest.java          | 1159 ++++
 .../cluster/restart/ClusterRestartTest.java     |  177 +
 .../cluster/topology/HAClientTopologyTest.java  |   64 +
 .../HAClientTopologyWithDiscoveryTest.java      |   71 +
 .../cluster/topology/IsolatedTopologyTest.java  |  222 +
 .../topology/NettyHAClientTopologyTest.java     |   29 +
 .../NettyHAClientTopologyWithDiscoveryTest.java |   31 +
 .../cluster/topology/NonHATopologyTest.java     |  134 +
 .../topology/TopologyClusterTestBase.java       |  473 ++
 .../cluster/util/BackupSyncDelay.java           |  378 ++
 .../cluster/util/MultiServerTestBase.java       |  321 +
 .../cluster/util/RemoteServerConfiguration.java |   34 +
 .../cluster/util/SameProcessHornetQServer.java  |  111 +
 .../cluster/util/TestableServer.java            |   43 +
 .../core/deployers/impl/QueueDeployerTest.java  |   92 +
 .../integration/discovery/DiscoveryTest.java    | 1391 ++++
 .../tests/integration/divert/DivertTest.java    | 1350 ++++
 .../divert/PersistentDivertTest.java            |  490 ++
 .../integration/embedded/ValidateAIOTest.java   |   48 +
 .../http/CoreClientOverHttpTest.java            |  180 +
 .../tests/integration/jms/FloodServerTest.java  |  328 +
 .../jms/HornetQConnectionFactoryTest.java       |  740 ++
 .../tests/integration/jms/JMSSecurityTest.java  |   80 +
 .../tests/integration/jms/JmsProducerTest.java  |  430 ++
 .../ManualReconnectionToSingleServerTest.java   |  304 +
 .../integration/jms/bridge/BridgeTestBase.java  |  603 ++
 .../jms/bridge/ClusteredBridgeTestBase.java     |  310 +
 .../jms/bridge/JMSBridgeClusteredTest.java      |  272 +
 .../jms/bridge/JMSBridgeReconnectionTest.java   |  329 +
 .../integration/jms/bridge/JMSBridgeTest.java   | 2457 +++++++
 .../jms/client/AutoGroupingTest.java            |   51 +
 .../integration/jms/client/ConnectionTest.java  |  183 +
 .../integration/jms/client/CreateQueueTest.java |  148 +
 .../jms/client/ExpiryMessageTest.java           |  111 +
 .../integration/jms/client/GroupIDTest.java     |   56 +
 .../integration/jms/client/GroupingTest.java    |  285 +
 .../jms/client/MessageProducerTest.java         |  102 +
 .../integration/jms/client/MessageTest.java     |  374 ++
 .../jms/client/NewQueueRequestorTest.java       |  111 +
 .../jms/client/NoLocalSubscriberTest.java       |  269 +
 .../integration/jms/client/PreACKJMSTest.java   |  218 +
 .../jms/client/ReSendMessageTest.java           |  328 +
 .../jms/client/ReceiveNoWaitTest.java           |  112 +
 .../jms/client/RemoteConnectionStressTest.java  |  113 +
 ...onClosedOnRemotingConnectionFailureTest.java |  178 +
 .../integration/jms/client/SessionTest.java     |  162 +
 .../integration/jms/client/StoreConfigTest.java |  368 +
 .../integration/jms/client/TextMessageTest.java |  248 +
 .../jms/client/TopicCleanupTest.java            |  109 +
 .../jms/cluster/BindingsClusterTest.java        |  485 ++
 .../jms/cluster/JMSFailoverListenerTest.java    |  397 ++
 .../jms/cluster/JMSFailoverTest.java            |  626 ++
 .../jms/cluster/JMSReconnectTest.java           |  368 +
 .../jms/cluster/LargeMessageOverBridgeTest.java |  233 +
 .../jms/cluster/MultipleThreadsOpeningTest.java |   96 +
 .../jms/cluster/ReplicatedJMSFailoverTest.java  |   88 +
 .../jms/cluster/TemporaryQueueClusterTest.java  |  185 +
 .../jms/cluster/TopicClusterTest.java           |  128 +
 .../CloseConnectionFactoryOnGCest.java          |   72 +
 .../jms/connection/CloseConnectionOnGCTest.java |  183 +
 .../CloseDestroyedConnectionTest.java           |  172 +
 .../connection/ConcurrentSessionCloseTest.java  |  119 +
 .../ConnectionFactorySerializationTest.java     |  133 +
 .../jms/connection/ExceptionListenerTest.java   |  174 +
 .../jms/connection/InvalidConnectorTest.java    |  113 +
 .../integration/jms/consumer/ConsumerTest.java  |  801 +++
 .../jms/divert/DivertAndACKClientTest.java      |  169 +
 .../integration/jms/jms2client/BodyTest.java    |   80 +
 .../jms/jms2client/InvalidDestinationTest.java  |  383 ++
 .../jms/jms2client/JmsContextTest.java          |  723 ++
 .../JmsProducerCompletionListenerTest.java      |  232 +
 .../jms/jms2client/NonExistentQueueTest.java    |   95 +
 .../jms/jms2client/SharedConsumerTest.java      |  306 +
 .../jms/largemessage/JMSLargeMessageTest.java   |  364 +
 .../server/ColocatedJMSServerStartStopTest.java |  166 +
 .../jms/server/JMSServerDeployerTest.java       |  377 ++
 .../jms/server/JMSServerStartStopTest.java      |  216 +
 .../jms/server/config/JMSConfigurationTest.java |  119 +
 .../config/JMSServerConfigParserTest.java       |  124 +
 .../ConnectionFactoryControlTest.java           |  160 +
 .../server/management/JMSMessagingProxy.java    |   96 +
 .../server/management/JMSQueueControlTest.java  | 1332 ++++
 .../management/JMSQueueControlUsingJMSTest.java |  305 +
 .../management/JMSServerControl2Test.java       | 1028 +++
 .../management/JMSServerControlRestartTest.java |  177 +
 .../server/management/JMSServerControlTest.java | 1134 ++++
 .../JMSServerControlUsingJMSTest.java           |  509 ++
 .../jms/server/management/JMSUtil.java          |  346 +
 .../server/management/NullInitialContext.java   |   58 +
 .../management/TopicControlClusterTest.java     |   82 +
 .../jms/server/management/TopicControlTest.java |  577 ++
 .../management/TopicControlUsingJMSTest.java    |  501 ++
 .../journal/AIOImportExportTest.java            |   44 +
 .../journal/AIOJournalCompactTest.java          |   51 +
 .../integration/journal/AIOJournalImplTest.java |   80 +
 .../journal/AIOSequentialFileFactoryTest.java   |   57 +
 .../journal/JournalPerfTuneTest.java            |  238 +
 .../journal/NIOBufferedJournalCompactTest.java  |   42 +
 .../journal/NIOImportExportTest.java            |  219 +
 .../journal/NIOJournalCompactTest.java          | 1952 ++++++
 .../integration/journal/NIOJournalImplTest.java |   53 +
 .../journal/NIONoBufferJournalImplTest.java     |   53 +
 ...NIONonBufferedSequentialFileFactoryTest.java |   34 +
 .../journal/NIOSequentialFileFactoryTest.java   |   34 +
 .../integration/journal/OldFormatTest.java      |  149 +
 .../journal/ValidateTransactionHealthTest.java  |  473 ++
 .../largemessage/LargeMessageTestBase.java      |  816 +++
 .../largemessage/ServerLargeMessageTest.java    |  125 +
 .../management/AcceptorControlTest.java         |  180 +
 .../AcceptorControlUsingCoreTest.java           |  109 +
 .../management/AddressControlTest.java          |  337 +
 .../management/AddressControlUsingCoreTest.java |  226 +
 .../management/BridgeControlTest.java           |  199 +
 .../management/BridgeControlUsingCoreTest.java  |  201 +
 .../management/BroadcastGroupControlTest.java   |  133 +
 .../BroadcastGroupControlUsingCoreTest.java     |   95 +
 .../ClusterConnectionControl2Test.java          |  185 +
 .../ClusterConnectionControlTest.java           |  281 +
 .../ClusterConnectionControlUsingCoreTest.java  |  180 +
 .../management/CoreMessagingProxy.java          |  114 +
 .../management/DivertControlTest.java           |  139 +
 .../management/DivertControlUsingCoreTest.java  |  133 +
 .../management/HornetQServerControlTest.java    | 1003 +++
 .../HornetQServerControlUsingCoreTest.java      |  683 ++
 .../integration/management/JMXDomainTest.java   |  186 +
 .../management/ManagementActivationTest.java    |  294 +
 .../management/ManagementControlHelper.java     |  164 +
 .../management/ManagementHelperTest.java        |  327 +
 .../management/ManagementServiceImplTest.java   |  181 +
 .../management/ManagementTestBase.java          |  129 +
 .../ManagementWithPagingServerTest.java         |  398 ++
 .../management/ManagementWithStompTest.java     |  269 +
 .../management/NotificationTest.java            |  341 +
 .../management/QueueControlTest.java            | 1899 ++++++
 .../management/QueueControlUsingCoreTest.java   |  339 +
 .../management/SecurityManagementTestBase.java  |  134 +
 ...tyManagementWithConfiguredAdminUserTest.java |  119 +
 ...yManagementWithDefaultConfigurationTest.java |   73 +
 ...ManagementWithModifiedConfigurationTest.java |   91 +
 .../management/SecurityNotificationTest.java    |  245 +
 .../paging/MultipleProducersPagingTest.java     |  208 +
 .../integration/paging/NettyPagingSendTest.java |   29 +
 .../paging/PageCountSyncOnNonTXTest.java        |  202 +
 .../integration/paging/PageCountSyncServer.java |   77 +
 .../integration/paging/PagingCounterTest.java   |  355 +
 .../integration/paging/PagingReceiveTest.java   |  149 +
 .../integration/paging/PagingSendTest.java      |  223 +
 .../PagingWithFailoverAndCountersTest.java      |  471 ++
 .../paging/PagingWithFailoverBackup.java        |   31 +
 .../paging/PagingWithFailoverServer.java        |   85 +
 .../paging/SpawnedServerSupport.java            |  144 +
 ...AddressSettingsConfigurationStorageTest.java |  122 +
 .../DeleteMessagesOnStartupTest.java            |   95 +
 .../persistence/DeleteQueueRestartTest.java     |  128 +
 .../persistence/DuplicateCacheTest.java         |  102 +
 .../persistence/ExportFormatTest.java           |  160 +
 ...nnectionFactoryConfigurationStorageTest.java |  180 +
 .../persistence/JMSDynamicConfigTest.java       |   97 +
 .../persistence/JMSStorageManagerTest.java      |   79 +
 .../integration/persistence/RestartSMTest.java  |  134 +
 .../RolesConfigurationStorageTest.java          |  143 +
 .../persistence/StorageManagerTestBase.java     |  139 +
 ...ansportConfigurationEncodingSupportTest.java |  132 +
 .../persistence/XmlImportExportTest.java        | 1073 +++
 .../tests/integration/proton/ProtonTest.java    |  402 ++
 .../tests/integration/ra/DummyTransaction.java  |   69 +
 .../integration/ra/DummyTransactionManager.java |   84 +
 .../integration/ra/HornetQActivationTest.java   |   67 +
 .../integration/ra/HornetQClusteredTest.java    |  110 +
 .../ra/HornetQMessageHandlerSecurityTest.java   |   93 +
 .../ra/HornetQMessageHandlerTest.java           |  682 ++
 .../ra/HornetQMessageHandlerXATest.java         |  172 +
 .../ra/HornetQRAClusteredTestBase.java          |  112 +
 .../tests/integration/ra/HornetQRATestBase.java |  234 +
 .../tests/integration/ra/JMSContextTest.java    |  166 +
 .../integration/ra/OutgoingConnectionTest.java  |  514 ++
 .../integration/ra/ResourceAdapterTest.java     |  762 +++
 .../integration/remoting/BatchDelayTest.java    |  127 +
 .../remoting/DestroyConsumerTest.java           |   78 +
 .../integration/remoting/DirectDeliverTest.java |  165 +
 .../remoting/NettyNetworkAddressTest.java       |   56 +
 .../remoting/NettySynchronousCloseTest.java     |   29 +
 .../remoting/NetworkAddressTestBase.java        |  278 +
 .../tests/integration/remoting/PingTest.java    |  459 ++
 .../integration/remoting/ReconnectTest.java     |  286 +
 .../remoting/SynchronousCloseTest.java          |  106 +
 .../replication/ReplicationOrderTest.java       |  136 +
 .../replication/ReplicationTest.java            |  905 +++
 .../scheduling/DelayedMessageTest.java          |  303 +
 .../MultipliedDelayedMessageTest.java           |  151 +
 .../scheduling/ScheduledMessageTest.java        | 1022 +++
 .../security/NettySecurityClientTest.java       |  118 +
 .../integration/security/SecurityTest.java      | 1429 ++++
 .../integration/security/SimpleClient.java      |  106 +
 .../server/AIOFileLockTimeoutTest.java          |   29 +
 .../server/AddressFullLoggingTest.java          |  142 +
 .../integration/server/ExpiryRunnerTest.java    |  361 +
 .../integration/server/FakeStorageManager.java  |   59 +
 .../integration/server/FileLockTimeoutTest.java |  115 +
 .../integration/server/LVQRecoveryTest.java     |  265 +
 .../tests/integration/server/LVQTest.java       |  697 ++
 .../server/NIOFileLockTimeoutTest.java          |   29 +
 .../integration/server/PredefinedQueueTest.java |  510 ++
 .../integration/server/ScaleDown3NodeTest.java  |  408 ++
 .../tests/integration/server/ScaleDownTest.java |  559 ++
 .../integration/spring/ExampleListener.java     |   45 +
 .../tests/integration/spring/MessageSender.java |   67 +
 .../spring/SpringIntegrationTest.java           |   84 +
 .../ssl/CoreClientOverOneWaySSLTest.java        |  534 ++
 .../ssl/CoreClientOverTwoWaySSLTest.java        |  168 +
 .../tests/integration/stomp/ExtraStompTest.java |  805 +++
 .../stomp/StompConnectionCleanupTest.java       |  133 +
 .../integration/stomp/StompOverHttpTest.java    |   83 +
 .../stomp/StompOverWebsocketTest.java           |  145 +
 .../tests/integration/stomp/StompTest.java      | 1372 ++++
 .../tests/integration/stomp/StompTestBase.java  |  391 ++
 .../integration/stomp/StompWebSocketTest.java   |   97 +
 .../stomp/util/AbstractClientStompFrame.java    |  220 +
 .../util/AbstractStompClientConnection.java     |  394 ++
 .../stomp/util/ClientStompFrame.java            |   50 +
 .../stomp/util/ClientStompFrameV10.java         |   51 +
 .../stomp/util/ClientStompFrameV11.java         |   73 +
 .../stomp/util/ClientStompFrameV12.java         |   80 +
 .../stomp/util/StompClientConnection.java       |   59 +
 .../util/StompClientConnectionFactory.java      |   56 +
 .../stomp/util/StompClientConnectionV10.java    |  104 +
 .../stomp/util/StompClientConnectionV11.java    |  142 +
 .../stomp/util/StompClientConnectionV12.java    |  116 +
 .../stomp/util/StompFrameFactory.java           |   29 +
 .../stomp/util/StompFrameFactoryFactory.java    |   42 +
 .../stomp/util/StompFrameFactoryV10.java        |   77 +
 .../stomp/util/StompFrameFactoryV11.java        |  181 +
 .../stomp/util/StompFrameFactoryV12.java        |  200 +
 .../integration/stomp/v11/ExtraStompTest.java   |  396 ++
 .../integration/stomp/v11/StompV11Test.java     | 2377 +++++++
 .../integration/stomp/v11/StompV11TestBase.java |  194 +
 .../integration/stomp/v12/StompV12Test.java     | 2664 ++++++++
 .../netty/HornetQFrameDecoder2Test.java         |  130 +
 .../NettyConnectorWithHTTPUpgradeTest.java      |  222 +
 .../tests/integration/twitter/TwitterTest.java  |  607 ++
 .../integration/vertx/HornetQVertxUnitTest.java |  852 +++
 .../integration/xa/BasicXaRecoveryTest.java     | 1360 ++++
 .../tests/integration/xa/BasicXaTest.java       |  998 +++
 .../tests/integration/xa/XaTimeoutTest.java     |  787 +++
 .../largemessage/LargeMessageTestBase.java      |  701 ++
 .../tests/util/JMSClusteredTestBase.java        |  309 +
 .../org/hornetq/tests/util/JMSTestBase.java     |  303 +
 .../org/hornetq/tests/util/JournalExample.java  |  156 +
 .../tests/util/NonSerializableFactory.java      |  107 +
 .../tests/util/ReplicatedBackupUtils.java       |   60 +
 .../tests/util/TransportConfigurationUtils.java |  125 +
 .../colocated-server-start-stop-config1.xml     |   61 +
 .../colocated-server-start-stop-config2.xml     |   62 +
 .../colocated-server-start-stop-jms-config1.xml |   18 +
 .../colocated-server-start-stop-jms-config2.xml |   18 +
 .../hornetq-jms-for-JMSServerDeployerTest.xml   |   53 +
 .../hornetq-jms-for-JMSServerDeployerTest2.xml  |   53 +
 .../resources/restricted-security-client.policy |   25 +
 .../resources/server-start-stop-config1.xml     |   33 +
 .../resources/server-start-stop-jms-config1.xml |   18 +
 .../test/resources/spring-hornetq-config.xml    |   34 +
 .../src/test/resources/spring-hornetq-jms.xml   |   19 +
 .../src/test/resources/spring-jms-beans.xml     |   27 +
 .../test/resources/test-jgroups-file_ping.xml   |   52 +
 tests/jms-tests/pom.xml                         |  155 +
 .../hornetq/jms/tests/AcknowledgementTest.java  | 1421 ++++
 .../jms/tests/AutoAckMesageListenerTest.java    |  164 +
 .../java/org/hornetq/jms/tests/BrowserTest.java |  248 +
 .../hornetq/jms/tests/CTSMiscellaneousTest.java |  160 +
 .../hornetq/jms/tests/ConnectionClosedTest.java |  401 ++
 .../jms/tests/ConnectionFactoryTest.java        |  503 ++
 .../org/hornetq/jms/tests/ConnectionTest.java   |  343 +
 .../hornetq/jms/tests/ConsumerClosedTest.java   |   90 +
 .../hornetq/jms/tests/DeliveryOrderTest.java    |  160 +
 .../jms/tests/DurableSubscriptionTest.java      |  469 ++
 .../jms/tests/HornetQServerTestCase.java        |  567 ++
 .../java/org/hornetq/jms/tests/JMSTest.java     |  367 +
 .../java/org/hornetq/jms/tests/JMSTestCase.java |  249 +
 .../org/hornetq/jms/tests/JmsTestLogger.java    |   31 +
 .../hornetq/jms/tests/MessageConsumerTest.java  | 4595 +++++++++++++
 .../hornetq/jms/tests/MessageProducerTest.java  |  925 +++
 .../jms/tests/MessageWithReadResolveTest.java   |  141 +
 .../hornetq/jms/tests/MiscellaneousTest.java    |  310 +
 .../jms/tests/NonDurableSubscriberTest.java     |  113 +
 .../org/hornetq/jms/tests/PersistenceTest.java  |  553 ++
 .../hornetq/jms/tests/QueueReceiverTest.java    |   76 +
 .../java/org/hornetq/jms/tests/QueueTest.java   |  231 +
 .../hornetq/jms/tests/ReferenceableTest.java    |  165 +
 .../org/hornetq/jms/tests/SecurityTest.java     |  190 +
 .../java/org/hornetq/jms/tests/SessionTest.java |  438 ++
 .../jms/tests/TemporaryDestinationTest.java     |  513 ++
 .../java/org/hornetq/jms/tests/TopicTest.java   |  199 +
 .../jms/tests/TransactedSessionTest.java        | 1213 ++++
 .../org/hornetq/jms/tests/XARecoveryTest.java   | 3048 +++++++++
 .../test/java/org/hornetq/jms/tests/XATest.java | 2332 +++++++
 .../tests/message/BodyIsAssignableFromTest.java |  179 +
 .../jms/tests/message/BytesMessageTest.java     |  101 +
 .../jms/tests/message/ExpiredMessageTest.java   |  120 +
 .../message/JMSCorrelationIDHeaderTest.java     |   96 +
 .../message/JMSDeliveryModeHeaderTest.java      |   75 +
 .../tests/message/JMSDestinationHeaderTest.java |   50 +
 .../tests/message/JMSExpirationHeaderTest.java  |  340 +
 .../tests/message/JMSMessageIDHeaderTest.java   |   90 +
 .../tests/message/JMSPriorityHeaderTest.java    |  248 +
 .../jms/tests/message/JMSReplyToHeaderTest.java |   73 +
 .../tests/message/JMSTimestampHeaderTest.java   |   68 +
 .../jms/tests/message/JMSTypeHeaderTest.java    |   63 +
 .../tests/message/JMSXDeliveryCountTest.java    |  789 +++
 .../jms/tests/message/MapMessageTest.java       |  119 +
 .../jms/tests/message/MessageBodyTest.java      | 1597 +++++
 .../jms/tests/message/MessageBodyTestCase.java  |   54 +
 .../jms/tests/message/MessageHeaderTest.java    | 1461 ++++
 .../tests/message/MessageHeaderTestBase.java    |  469 ++
 .../message/MessagePropertyConversionTest.java  | 1410 ++++
 .../jms/tests/message/MessageTestBase.java      |  228 +
 .../message/ObjectMessageDeliveryTest.java      |  138 +
 .../jms/tests/message/ObjectMessageTest.java    |  228 +
 .../tests/message/SimpleJMSBytesMessage.java    |  569 ++
 .../jms/tests/message/SimpleJMSMapMessage.java  |  592 ++
 .../jms/tests/message/SimpleJMSMessage.java     |  394 ++
 .../tests/message/SimpleJMSObjectMessage.java   |   57 +
 .../tests/message/SimpleJMSStreamMessage.java   |  736 ++
 .../jms/tests/message/SimpleJMSTextMessage.java |   65 +
 .../hornetq/jms/tests/message/SomeObject.java   |   71 +
 .../jms/tests/message/StreamMessageTest.java    |  122 +
 .../jms/tests/message/TextMessageTest.java      |   91 +
 .../foreign/ForeignBytesMessageTest.java        |   61 +
 .../message/foreign/ForeignMapMessageTest.java  |   71 +
 .../message/foreign/ForeignMessageTest.java     |  140 +
 .../foreign/ForeignObjectMessageTest.java       |   76 +
 .../foreign/ForeignStreamMessageTest.java       |   79 +
 .../message/foreign/ForeignTestObject.java      |   78 +
 .../message/foreign/ForeignTextMessageTest.java |   49 +
 .../jms/tests/selector/SelectorTest.java        | 1124 ++++
 .../tests/stress/ConcurrentCloseStressTest.java |  293 +
 .../tests/stress/CorruptMessageStressTest.java  |  160 +
 .../jms/tests/stress/JMSStressTestBase.java     |  102 +
 .../tests/stress/ManyConnectionsStressTest.java |  214 +
 .../jms/tests/stress/OpenCloseStressTest.java   |  441 ++
 .../jms/tests/stress/QueueStressTest.java       |  267 +
 .../org/hornetq/jms/tests/stress/Receiver.java  |  293 +
 .../jms/tests/stress/RecoveringReceiver.java    |  191 +
 .../jms/tests/stress/RelayStressTest.java       |  252 +
 .../org/hornetq/jms/tests/stress/Runner.java    |   60 +
 .../org/hornetq/jms/tests/stress/Sender.java    |   68 +
 .../tests/stress/SeveralClientsStressTest.java  |  543 ++
 .../jms/tests/stress/TopicStressTest.java       |  293 +
 .../tests/stress/Transactional2PCReceiver.java  |  227 +
 .../tests/stress/Transactional2PCSender.java    |  116 +
 .../jms/tests/stress/TransactionalReceiver.java |  196 +
 .../jms/tests/stress/TransactionalSender.java   |   89 +
 .../jms/tests/tools/ConfigurationHelper.java    |   69 +
 .../jms/tests/tools/ServerManagement.java       |  142 +
 .../jms/tests/tools/WrappedJNDIServer.java      |   88 +
 .../jms/tests/tools/container/Constants.java    |   41 +
 .../jms/tests/tools/container/InVMContext.java  |  375 ++
 .../container/InVMInitialContextFactory.java    |  135 +
 .../InVMInitialContextFactoryBuilder.java       |  106 +
 .../tests/tools/container/InVMNameParser.java   |   70 +
 .../tests/tools/container/LocalTestServer.java  |  457 ++
 .../tools/container/NonSerializableFactory.java |  106 +
 .../jms/tests/tools/container/Server.java       |  189 +
 .../hornetq/jms/tests/util/JNDIUtilTest.java    |  120 +
 .../jms/tests/util/ProxyAssertSupport.java      |  476 ++
 .../src/test/resources/hornetq-beans.xml        |   60 +
 .../test/resources/hornetq-configuration.xml    |   38 +
 .../src/test/resources/hornetq-jms.xml          |  126 +
 .../src/test/resources/hornetq-queues.xml       |   16 +
 .../src/test/resources/hornetq-users.xml        |   10 +
 .../src/test/resources/jbossjta-properties.xml  |  233 +
 .../src/test/resources/jndi.properties          |    2 +
 .../jms-tests/src/test/resources/test-beans.xml |   60 +
 tests/joram-tests/pom.xml                       |  123 +
 .../java/org/hornetq/jms/AbstractAdmin.java     |  105 +
 .../test/java/org/hornetq/jms/GenericAdmin.java |  127 +
 .../test/java/org/hornetq/jms/HornetQAdmin.java |  336 +
 .../org/hornetq/jms/JoramAggregationTest.java   |   98 +
 .../java/org/hornetq/jms/SpawnedJMSServer.java  |  138 +
 .../org/objectweb/jtests/jms/admin/Admin.java   |  139 +
 .../jtests/jms/admin/AdminFactory.java          |   52 +
 .../org/objectweb/jtests/jms/admin/package.html |    9 +
 .../jms/conform/connection/ConnectionTest.java  |  229 +
 .../conform/connection/TopicConnectionTest.java |  159 +
 .../jtests/jms/conform/connection/package.html  |    3 +
 .../jms/conform/message/MessageBodyTest.java    |  104 +
 .../jms/conform/message/MessageDefaultTest.java |   53 +
 .../jms/conform/message/MessageTypeTest.java    |  408 ++
 .../message/headers/MessageHeaderTest.java      |  290 +
 .../jms/conform/message/headers/package.html    |    3 +
 .../jtests/jms/conform/message/package.html     |    3 +
 .../message/properties/JMSXPropertyTest.java    |  188 +
 .../MessagePropertyConversionTest.java          | 1616 +++++
 .../message/properties/MessagePropertyTest.java |  379 ++
 .../jms/conform/message/properties/package.html |    3 +
 .../jms/conform/queue/QueueBrowserTest.java     |  186 +
 .../jms/conform/queue/TemporaryQueueTest.java   |   74 +
 .../jtests/jms/conform/queue/package.html       |    3 +
 .../conform/selector/SelectorSyntaxTest.java    |  432 ++
 .../jms/conform/selector/SelectorTest.java      |  457 ++
 .../jtests/jms/conform/selector/package.html    |    3 +
 .../jms/conform/session/QueueSessionTest.java   |  191 +
 .../jtests/jms/conform/session/SessionTest.java |  321 +
 .../jms/conform/session/TopicSessionTest.java   |  233 +
 .../jms/conform/session/UnifiedSessionTest.java |  303 +
 .../jtests/jms/conform/session/package.html     |    4 +
 .../jms/conform/topic/TemporaryTopicTest.java   |   74 +
 .../jtests/jms/conform/topic/package.html       |    3 +
 .../jtests/jms/framework/JMSTestCase.java       |  114 +
 .../jtests/jms/framework/PTPTestCase.java       |  177 +
 .../jtests/jms/framework/PubSubTestCase.java    |  178 +
 .../jtests/jms/framework/TestConfig.java        |   58 +
 .../jtests/jms/framework/UnifiedTestCase.java   |  245 +
 .../objectweb/jtests/jms/framework/package.html |    3 +
 .../src/test/resources/provider.properties      |   36 +
 .../src/test/resources/test.properties          |   29 +
 tests/performance-tests/pom.xml                 |  126 +
 .../journal/FakeJournalImplTest.java            |   32 +
 .../journal/JournalImplTestUnit.java            |  300 +
 .../journal/RealJournalImplAIOTest.java         |   61 +
 .../journal/RealJournalImplNIOTest.java         |   47 +
 .../paging/MeasurePagingMultiThreadTest.java    |  230 +
 tests/pom.xml                                   |   55 +
 tests/soak-tests/pom.xml                        |  145 +
 .../tests/soak/client/ClientAbstract.java       |  221 +
 .../soak/client/ClientNonDivertedSoakTest.java  |  160 +
 .../tests/soak/client/ClientSoakTest.java       |  203 +
 .../org/hornetq/tests/soak/client/Receiver.java |  182 +
 .../org/hornetq/tests/soak/client/Sender.java   |  125 +
 .../soak/client/SimpleSendReceiveSoakTest.java  |  139 +
 .../soak/failover/RandomFailoverSoakTest.java   |   35 +
 tests/stress-tests/pom.xml                      |  145 +
 .../stress/chunk/LargeMessageStressTest.java    |   69 +
 .../tests/stress/client/SendStressTest.java     |  147 +
 .../MultiThreadRandomReattachStressTest.java    |   31 +
 .../failover/RandomReattachStressTest.java      |   53 +
 .../AIOAllPossibilitiesCompactStressTest.java   |   64 +
 .../AIOMultiThreadCompactorStressTest.java      |   44 +
 .../stress/journal/AddAndRemoveStressTest.java  |  247 +
 .../AllPossibilitiesCompactStressTest.java      |  111 +
 ...ibilitiesCompactWithAddDeleteStressTest.java |   72 +
 .../stress/journal/CompactingStressTest.java    |  465 ++
 .../JournalCleanupCompactStressTest.java        |  618 ++
 .../journal/JournalRestartStressTest.java       |  219 +
 .../stress/journal/LargeJournalStressTest.java  |  346 +
 .../stress/journal/MixupCompactorTestBase.java  |  244 +
 .../journal/MultiThreadConsumerStressTest.java  |  360 +
 .../NIOMultiThreadCompactorStressTest.java      |  568 ++
 .../journal/XmlImportExportStressTest.java      |  124 +
 .../paging/MultipleConsumersPageStressTest.java |  513 ++
 .../stress/paging/PageCursorStressTest.java     |  967 +++
 .../tests/stress/paging/PageStressTest.java     |  296 +
 .../tests/stress/remote/PingStressTest.java     |  213 +
 .../tests/stress/stomp/StompStressTest.java     |  188 +
 tests/timing-tests/pom.xml                      |  120 +
 .../core/journal/impl/AIOJournalImplTest.java   |   47 +
 .../core/journal/impl/FakeJournalImplTest.java  |   32 +
 .../core/journal/impl/JournalImplTestUnit.java  |  185 +
 .../core/journal/impl/NIOJournalImplTest.java   |   49 +
 .../timing/core/server/impl/QueueImplTest.java  |  286 +
 .../jms/bridge/impl/JMSBridgeImplTest.java      |  638 ++
 .../tests/timing/util/ReusableLatchTest.java    |   40 +
 .../timing/util/TokenBucketLimiterImplTest.java |  271 +
 .../org/hornetq/tests/timing/util/UTF8Test.java |  114 +
 .../org/hornetq/tests/timing/util/UUIDTest.java |   49 +
 tests/unit-tests/pom.xml                        |  104 +
 .../org/hornetq/tests/unit/UnitTestLogger.java  |   32 +
 .../tests/unit/core/asyncio/AIOTestBase.java    |  153 +
 .../unit/core/asyncio/AsynchronousFileTest.java | 1013 +++
 .../core/asyncio/LibaioDependencyCheckTest.java |   57 +
 .../MultiThreadAsynchronousFileTest.java        |  323 +
 .../client/impl/LargeMessageBufferTest.java     |  936 +++
 .../impl/ConfigurationValidationTest.java       |   67 +
 .../config/impl/TransportConfigurationTest.java |   83 +
 .../impl/AddressSettingsDeployerTest.java       |  132 +
 .../impl/BasicUserCredentialsDeployerTest.java  |  542 ++
 .../deployers/impl/FakeDeploymentManager.java   |   47 +
 .../impl/FileDeploymentManagerTest.java         |  435 ++
 .../deployers/impl/SecurityDeployerTest.java    |  313 +
 .../core/deployers/impl/XMLDeployerTest.java    |  263 +
 .../journal/impl/AlignedJournalImplTest.java    | 1427 ++++
 .../unit/core/journal/impl/CleanBufferTest.java |  123 +
 .../core/journal/impl/FakeJournalImplTest.java  |   39 +
 .../impl/FakeSequentialFileFactoryTest.java     |   34 +
 .../core/journal/impl/FileFactoryTestBase.java  |   76 +
 .../core/journal/impl/JournalAsyncTest.java     |  248 +
 .../core/journal/impl/JournalImplTestBase.java  |  630 ++
 .../core/journal/impl/JournalImplTestUnit.java  | 3229 +++++++++
 .../unit/core/journal/impl/ReclaimerTest.java   | 1029 +++
 .../impl/SequentialFileFactoryTestBase.java     |  442 ++
 .../unit/core/journal/impl/TimedBufferTest.java |  405 ++
 .../impl/fakes/FakeSequentialFileFactory.java   |  739 ++
 .../core/journal/impl/fakes/SimpleEncoding.java |   71 +
 .../unit/core/message/impl/MessageImplTest.java |  369 +
 .../unit/core/paging/impl/PagePositionTest.java |   53 +
 .../tests/unit/core/paging/impl/PageTest.java   |  249 +
 .../core/paging/impl/PagingManagerImplTest.java |  136 +
 .../core/paging/impl/PagingStoreImplTest.java   |  959 +++
 .../impl/BatchIDGeneratorUnitTest.java          |  158 +
 .../impl/OperationContextUnitTest.java          |  244 +
 .../core/postoffice/impl/AddressImplTest.java   |  301 +
 .../core/postoffice/impl/BindingsImplTest.java  |  417 ++
 .../impl/DuplicateDetectionUnitTest.java        |  193 +
 .../unit/core/postoffice/impl/FakeQueue.java    |  622 ++
 .../postoffice/impl/QueueComparatorTest.java    |   52 +
 .../impl/WildcardAddressManagerUnitTest.java    |  253 +
 .../core/remoting/HornetQBufferTestBase.java    |  357 +
 .../impl/netty/ChannelBufferWrapper2Test.java   |   54 +
 .../impl/netty/NettyAcceptorFactoryTest.java    |   87 +
 .../remoting/impl/netty/NettyAcceptorTest.java  |  128 +
 .../impl/netty/NettyConnectionTest.java         |  107 +
 .../remoting/impl/netty/NettyConnectorTest.java |  339 +
 .../core/remoting/impl/ssl/SSLSupportTest.java  |  180 +
 .../impl/HornetQSecurityManagerImplTest.java    |  181 +
 .../security/impl/JAASSecurityManagerTest.java  |  212 +
 .../cluster/impl/RemoteQueueBindImplTest.java   |   82 +
 .../group/impl/SystemPropertyOverrideTest.java  |   44 +
 .../unit/core/server/impl/FileLockTest.java     |  106 +
 .../unit/core/server/impl/QueueImplTest.java    | 1634 +++++
 .../core/server/impl/fakes/FakeConsumer.java    |  180 +
 .../unit/core/server/impl/fakes/FakeFilter.java |   69 +
 .../server/impl/fakes/FakeJournalLoader.java    |   89 +
 .../core/server/impl/fakes/FakePostOffice.java  |  196 +
 .../server/impl/fakes/FakeQueueFactory.java     |   77 +
 .../core/settings/impl/AddressSettingsTest.java |  143 +
 .../unit/core/settings/impl/RepositoryTest.java |  271 +
 .../tests/unit/jms/HornetQDestinationTest.java  |  102 +
 .../unit/jms/client/HornetQMapMessageTest.java  |  795 +++
 .../jms/client/HornetQStreamMessageTest.java    | 1059 +++
 .../unit/jms/client/JMSExceptionHelperTest.java |  123 +
 .../unit/jms/client/SelectorTranslatorTest.java |  277 +
 .../tests/unit/jms/misc/ManifestTest.java       |   93 +
 .../ConnectionFactoryObjectFactoryTest.java     |   61 +
 .../DestinationObjectFactoryTest.java           |   64 +
 .../tests/unit/microcontainer/DummyBean.java    |   31 +
 .../HornetQBootstrapServerTest.java             |   95 +
 .../hornetq/tests/unit/ra/BootstrapContext.java |   77 +
 .../ra/ConnectionFactoryPropertiesTest.java     |  112 +
 .../ra/HornetQResourceAdapterConfigTest.java    |  483 ++
 .../tests/unit/ra/MessageEndpointFactory.java   |   35 +
 .../tests/unit/ra/ResourceAdapterTest.java      |  568 ++
 .../tests/unit/util/FakePagingManager.java      |  194 +
 .../unit/util/HornetQBufferInputStreamTest.java |   69 +
 .../hornetq/tests/unit/util/InVMContext.java    |  376 ++
 .../hornetq/tests/unit/util/InVMNameParser.java |   70 +
 .../tests/unit/util/InVMNamingContext.java      |  375 ++
 .../hornetq/tests/unit/util/LinkedListTest.java | 1305 ++++
 .../hornetq/tests/unit/util/MemorySizeTest.java |   52 +
 .../tests/unit/util/NonSerializableFactory.java |  106 +
 .../ObjectInputStreamWithClassLoaderTest.java   |  297 +
 .../tests/unit/util/ReusableLatchTest.java      |  322 +
 .../tests/unit/util/SoftValueMapTest.java       |  159 +
 .../org/hornetq/tests/unit/util/UTF8Test.java   |  185 +
 .../tests/unit/util/UUIDGeneratorTest.java      |   78 +
 .../org/hornetq/tests/unit/util/UUIDTest.java   |   70 +
 .../tests/unit/util/VersionLoaderTest.java      |   70 +
 .../org/hornetq/tests/util/CreateMessage.java   |   61 +
 .../hornetq/tests/util/SpawnedVMSupport.java    |  218 +
 tests/unit-tests/src/test/resources/beans1.xml  |    5 +
 .../src/test/resources/client-side.keystore     |  Bin 0 -> 1300 bytes
 .../src/test/resources/client-side.truststore   |  Bin 0 -> 670 bytes
 .../src/test/resources/server-side.keystore     |  Bin 0 -> 1375 bytes
 .../src/test/resources/server-side.truststore   |  Bin 0 -> 893 bytes
 3183 files changed, 607124 insertions(+)
----------------------------------------------------------------------



Mime
View raw message