You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2015/08/13 06:14:06 UTC
[48/48] activemq-artemis git commit: renaming broker-features ->
features on examples
renaming broker-features -> features on examples
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/6b17d966
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/6b17d966
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/6b17d966
Branch: refs/heads/master
Commit: 6b17d966cee6f9ecc918e123db937c2cb90f8543
Parents: 800cc46
Author: Clebert Suconic <cl...@apache.org>
Authored: Thu Aug 13 00:11:56 2015 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Thu Aug 13 00:11:56 2015 -0400
----------------------------------------------------------------------
.../client-side-load-balancing/pom.xml | 196 ---------
.../client-side-load-balancing/readme.html | 49 ---
.../example/ClientSideLoadBalancingExample.java | 138 -------
.../src/main/resources/jndi.properties | 20 -
.../clustered-durable-subscription/pom.xml | 158 -------
.../clustered-durable-subscription/readme.html | 66 ---
.../ClusteredDurableSubscriptionExample.java | 130 ------
.../main/resources/activemq/server0/broker.xml | 96 -----
.../main/resources/activemq/server1/broker.xml | 96 -----
.../clustered/clustered-grouping/pom.xml | 194 ---------
.../clustered/clustered-grouping/readme.html | 81 ----
.../jms/example/ClusteredGroupingExample.java | 153 -------
.../main/resources/activemq/server0/broker.xml | 105 -----
.../main/resources/activemq/server1/broker.xml | 102 -----
.../main/resources/activemq/server2/broker.xml | 102 -----
.../clustered/clustered-jgroups/pom.xml | 161 --------
.../clustered/clustered-jgroups/readme.html | 67 ---
.../jms/example/ClusteredJgroupsExample.java | 140 -------
.../main/resources/activemq/server0/broker.xml | 97 -----
.../activemq/server0/client-jndi.properties | 19 -
.../activemq/server0/test-jgroups-file_ping.xml | 73 ----
.../main/resources/activemq/server1/broker.xml | 96 -----
.../activemq/server1/client-jndi.properties | 19 -
.../activemq/server1/test-jgroups-file_ping.xml | 73 ----
.../clustered/clustered-queue/pom.xml | 154 -------
.../clustered/clustered-queue/readme.html | 56 ---
.../jms/example/ClusteredQueueExample.java | 117 ------
.../main/resources/activemq/server0/broker.xml | 95 -----
.../main/resources/activemq/server1/broker.xml | 96 -----
.../clustered-static-discovery/pom.xml | 239 -----------
.../clustered-static-discovery/readme.html | 58 ---
.../example/StaticClusteredQueueExample.java | 173 --------
.../main/resources/activemq/server0/broker.xml | 82 ----
.../main/resources/activemq/server1/broker.xml | 82 ----
.../main/resources/activemq/server2/broker.xml | 79 ----
.../main/resources/activemq/server3/broker.xml | 79 ----
.../clustered/clustered-static-oneway/pom.xml | 198 ---------
.../clustered-static-oneway/readme.html | 64 ---
.../jms/example/ClusterStaticOnewayExample.java | 159 -------
.../main/resources/activemq/server0/broker.xml | 79 ----
.../main/resources/activemq/server1/broker.xml | 79 ----
.../main/resources/activemq/server2/broker.xml | 74 ----
.../clustered/clustered-topic/pom.xml | 153 -------
.../clustered/clustered-topic/readme.html | 55 ---
.../jms/example/ClusteredTopicExample.java | 129 ------
.../main/resources/activemq/server0/broker.xml | 97 -----
.../main/resources/activemq/server1/broker.xml | 95 -----
examples/broker-features/clustered/pom.xml | 77 ----
.../queue-message-redistribution/pom.xml | 155 -------
.../queue-message-redistribution/readme.html | 61 ---
.../QueueMessageRedistributionExample.java | 145 -------
.../main/resources/activemq/server0/broker.xml | 106 -----
.../main/resources/activemq/server1/broker.xml | 107 -----
.../clustered/symmetric-cluster/pom.xml | 320 ---------------
.../clustered/symmetric-cluster/readme.html | 74 ----
.../jms/example/SymmetricClusterExample.java | 222 ----------
.../main/resources/activemq/server0/broker.xml | 99 -----
.../main/resources/activemq/server1/broker.xml | 97 -----
.../main/resources/activemq/server2/broker.xml | 97 -----
.../main/resources/activemq/server3/broker.xml | 97 -----
.../main/resources/activemq/server4/broker.xml | 96 -----
.../main/resources/activemq/server5/broker.xml | 96 -----
.../ha/application-layer-failover/pom.xml | 102 -----
.../ha/application-layer-failover/readme.html | 169 --------
.../ApplicationLayerFailoverExample.java | 221 ----------
.../ha/client-side-failoverlistener/pom.xml | 109 -----
.../ha/client-side-failoverlistener/readme.html | 37 --
.../ClientSideFailoverListerExample.java | 129 ------
.../src/main/resources/jndi.properties | 20 -
.../ha/colocated-failover-scale-down/pom.xml | 103 -----
.../colocated-failover-scale-down/readme.html | 65 ---
.../ColocatedFailoverScaleDownExample.java | 140 -------
.../main/resources/activemq/server0/broker.xml | 129 ------
.../main/resources/activemq/server1/broker.xml | 127 ------
.../ha/colocated-failover/pom.xml | 102 -----
.../ha/colocated-failover/readme.html | 56 ---
.../jms/example/ColocatedFailoverExample.java | 147 -------
.../main/resources/activemq/server0/broker.xml | 115 ------
.../main/resources/activemq/server1/broker.xml | 114 ------
.../ha/ha-policy-autobackup/pom.xml | 103 -----
.../jms/example/HAPolicyAutoBackupExample.java | 155 -------
.../main/resources/activemq/server0/broker.xml | 108 -----
.../main/resources/activemq/server1/broker.xml | 108 -----
.../ha/multiple-failover-failback/pom.xml | 121 ------
.../MultipleFailoverFailbackExample.java | 142 -------
.../src/main/resources/jndi.properties | 20 -
.../ha/multiple-failover/pom.xml | 121 ------
.../jms/example/MultipleFailoverExample.java | 142 -------
.../src/main/resources/jndi.properties | 20 -
.../ha/non-transaction-failover/pom.xml | 109 -----
.../ha/non-transaction-failover/readme.html | 157 -------
.../example/NonTransactionFailoverExample.java | 128 ------
.../src/main/resources/jndi.properties | 20 -
examples/broker-features/ha/pom.xml | 95 -----
.../ha/replicated-failback-static/pom.xml | 104 -----
.../ha/replicated-failback-static/readme.html | 38 --
.../ReplicatedFailbackStaticExample.java | 149 -------
.../main/resources/activemq/server0/broker.xml | 87 ----
.../main/resources/activemq/server1/broker.xml | 89 ----
.../src/main/resources/jndi.properties | 20 -
.../ha/replicated-failback/pom.xml | 103 -----
.../ha/replicated-failback/readme.html | 38 --
.../jms/example/ReplicatedFailbackExample.java | 149 -------
.../main/resources/activemq/server0/broker.xml | 101 -----
.../main/resources/activemq/server1/broker.xml | 102 -----
.../src/main/resources/jndi.properties | 20 -
.../ha/replicated-multiple-failover/pom.xml | 118 ------
.../ha/replicated-multiple-failover/readme.html | 45 --
.../ReplicatedMultipleFailoverExample.java | 149 -------
.../main/resources/activemq/server0/broker.xml | 95 -----
.../main/resources/activemq/server1/broker.xml | 95 -----
.../main/resources/activemq/server2/broker.xml | 95 -----
.../src/main/resources/jndi.properties | 20 -
.../ha/replicated-transaction-failover/pom.xml | 104 -----
.../replicated-transaction-failover/readme.html | 148 -------
.../ReplicatedTransactionFailoverExample.java | 168 --------
.../main/resources/activemq/server0/broker.xml | 96 -----
.../main/resources/activemq/server1/broker.xml | 97 -----
.../src/main/resources/jndi.properties | 20 -
examples/broker-features/ha/scale-down/pom.xml | 105 -----
.../broker-features/ha/scale-down/readme.html | 51 ---
.../artemis/jms/example/ScaleDownExample.java | 132 ------
.../main/resources/activemq/server0/broker.xml | 117 ------
.../main/resources/activemq/server1/broker.xml | 108 -----
.../ha/stop-server-failover/pom.xml | 160 --------
.../ha/stop-server-failover/readme.html | 44 --
.../jms/example/StopServerFailoverExample.java | 117 ------
.../src/main/resources/jndi.properties | 20 -
.../ha/transaction-failover/pom.xml | 104 -----
.../ha/transaction-failover/readme.html | 46 ---
.../jms/example/TransactionFailoverExample.java | 167 --------
.../main/resources/activemq/server0/broker.xml | 98 -----
.../main/resources/activemq/server1/broker.xml | 98 -----
.../src/main/resources/jndi.properties | 20 -
examples/broker-features/perf/perf/pom.xml | 156 -------
examples/broker-features/perf/perf/readme.html | 39 --
.../activemq/artemis/jms/example/PerfBase.java | 409 -------------------
.../artemis/jms/example/PerfListener.java | 46 ---
.../artemis/jms/example/PerfParams.java | 158 -------
.../artemis/jms/example/PerfSender.java | 46 ---
.../activemq/artemis/jms/example/Server.java | 27 --
.../main/resources/activemq/server0/broker.xml | 46 ---
.../perf/src/main/resources/jndi.properties | 20 -
.../perf/src/main/resources/perf.properties | 30 --
examples/broker-features/perf/pom.xml | 50 ---
examples/broker-features/perf/soak/README | 85 ----
examples/broker-features/perf/soak/pom.xml | 162 --------
.../perf/soak/server0/broker.xml | 49 ---
.../broker-features/perf/soak/soak.properties | 30 --
.../artemis/jms/soak/example/SoakBase.java | 116 ------
.../artemis/jms/soak/example/SoakParams.java | 158 -------
.../artemis/jms/soak/example/SoakReceiver.java | 190 ---------
.../artemis/jms/soak/example/SoakSender.java | 195 ---------
.../soak/src/main/resources/jndi.properties | 20 -
examples/broker-features/pom.xml | 68 ---
examples/broker-features/standard/README.md | 32 --
.../broker-features/standard/bridge/pom.xml | 167 --------
.../broker-features/standard/bridge/readme.html | 74 ----
.../artemis/jms/example/BridgeExample.java | 175 --------
.../jms/example/HatColourChangeTransformer.java | 38 --
.../main/resources/activemq/server0/broker.xml | 88 ----
.../main/resources/activemq/server1/broker.xml | 59 ---
.../broker-features/standard/browser/pom.xml | 110 -----
.../standard/browser/readme.html | 40 --
.../jms/example/QueueBrowserExample.java | 103 -----
.../browser/src/main/resources/jndi.properties | 20 -
.../standard/client-kickoff/pom.xml | 112 -----
.../standard/client-kickoff/readme.html | 54 ---
.../jms/example/ClientKickoffExample.java | 106 -----
.../main/resources/activemq/server0/broker.xml | 47 ---
.../src/main/resources/jndi.properties | 19 -
.../standard/consumer-rate-limit/pom.xml | 109 -----
.../standard/consumer-rate-limit/readme.html | 47 ---
.../jms/example/ConsumerRateLimitExample.java | 115 ------
.../src/main/resources/jndi.properties | 20 -
.../standard/dead-letter/pom.xml | 110 -----
.../standard/dead-letter/readme.html | 66 ---
.../artemis/jms/example/DeadLetterExample.java | 136 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 71 ----
.../src/main/resources/jndi.properties | 21 -
.../standard/delayed-redelivery/pom.xml | 110 -----
.../standard/delayed-redelivery/readme.html | 56 ---
.../jms/example/DelayedRedeliveryExample.java | 126 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 70 ----
.../src/main/resources/jndi.properties | 20 -
.../broker-features/standard/divert/pom.xml | 159 -------
.../broker-features/standard/divert/readme.html | 119 ------
.../example/AddForwardingTimeTransformer.java | 31 --
.../artemis/jms/example/DivertExample.java | 212 ----------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 121 ------
.../activemq/server1/artemis-roles.properties | 17 -
.../activemq/server1/artemis-users.properties | 17 -
.../main/resources/activemq/server1/broker.xml | 64 ---
.../standard/durable-subscription/pom.xml | 110 -----
.../standard/durable-subscription/readme.html | 39 --
.../jms/example/DurableSubscriptionExample.java | 116 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 61 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/embedded-simple/pom.xml | 84 ----
.../standard/embedded-simple/readme.html | 96 -----
.../artemis/jms/example/EmbeddedExample.java | 86 ----
.../src/main/resources/broker.xml | 52 ---
.../broker-features/standard/embedded/pom.xml | 84 ----
.../standard/embedded/readme.html | 38 --
.../artemis/jms/example/EmbeddedExample.java | 107 -----
.../broker-features/standard/expiry/pom.xml | 110 -----
.../broker-features/standard/expiry/readme.html | 61 ---
.../artemis/jms/example/ExpiryExample.java | 120 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 70 ----
.../expiry/src/main/resources/jndi.properties | 21 -
.../standard/http-transport/pom.xml | 110 -----
.../standard/http-transport/readme.html | 52 ---
.../jms/example/HttpTransportExample.java | 81 ----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 61 ---
.../instantiate-connection-factory/pom.xml | 111 -----
.../instantiate-connection-factory/readme.html | 49 ---
.../InstantiateConnectionFactoryExample.java | 81 ----
.../standard/interceptor/pom.xml | 111 -----
.../standard/interceptor/readme.html | 72 ----
.../artemis/jms/example/InterceptorExample.java | 88 ----
.../artemis/jms/example/SimpleInterceptor.java | 48 ---
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 65 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/jms-auto-closeable/pom.xml | 106 -----
.../standard/jms-auto-closeable/readme.html | 96 -----
.../jms/example/JMSAutoCloseableExample.java | 51 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/jms-bridge/jms-bridge.png | Bin 93885 -> 0 bytes
.../broker-features/standard/jms-bridge/pom.xml | 159 -------
.../standard/jms-bridge/readme.html | 246 -----------
.../artemis/jms/example/JMSBridgeExample.java | 136 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 53 ---
.../activemq/server1/artemis-roles.properties | 17 -
.../activemq/server1/artemis-users.properties | 17 -
.../main/resources/activemq/server1/broker.xml | 53 ---
.../standard/jms-completion-listener/pom.xml | 110 -----
.../jms-completion-listener/readme.html | 112 -----
.../example/JMSCompletionListenerExample.java | 82 ----
.../src/main/resources/jndi.properties | 20 -
.../standard/jms-context/pom.xml | 109 -----
.../standard/jms-context/readme.html | 35 --
.../artemis/jms/example/JMSContextExample.java | 51 ---
.../standard/jms-shared-consumer/pom.xml | 111 -----
.../standard/jms-shared-consumer/readme.html | 119 ------
.../jms/example/JMSSharedConsumerExample.java | 87 ----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 61 ---
.../src/main/resources/jndi.properties | 20 -
examples/broker-features/standard/jmx/pom.xml | 117 ------
.../broker-features/standard/jmx/readme.html | 181 --------
.../artemis/jms/example/JMXExample.java | 121 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 64 ---
.../jmx/src/main/resources/jndi.properties | 20 -
.../standard/large-message/pom.xml | 88 ----
.../standard/large-message/readme.html | 200 ---------
.../jms/example/LargeMessageExample.java | 193 ---------
.../src/main/resources/jndi.properties | 20 -
.../standard/last-value-queue/pom.xml | 109 -----
.../standard/last-value-queue/readme.html | 162 --------
.../jms/example/LastValueQueueExample.java | 104 -----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 67 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/management-notifications/pom.xml | 109 -----
.../management-notifications/readme.html | 215 ----------
.../example/ManagementNotificationExample.java | 109 -----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 81 ----
.../src/main/resources/jndi.properties | 21 -
.../broker-features/standard/management/pom.xml | 109 -----
.../standard/management/readme.html | 208 ----------
.../artemis/jms/example/ManagementExample.java | 133 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 76 ----
.../src/main/resources/jndi.properties | 20 -
.../standard/message-counters/pom.xml | 116 ------
.../standard/message-counters/readme.html | 197 ---------
.../jms/example/MessageCounterExample.java | 134 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 86 ----
.../src/main/resources/jndi.properties | 21 -
.../standard/message-group/pom.xml | 109 -----
.../standard/message-group/readme.html | 152 -------
.../jms/example/MessageGroupExample.java | 122 ------
.../src/main/resources/jndi.properties | 20 -
.../standard/message-group2/pom.xml | 109 -----
.../standard/message-group2/readme.html | 161 --------
.../jms/example/MessageGroup2Example.java | 129 ------
.../standard/message-priority/pom.xml | 109 -----
.../standard/message-priority/readme.html | 159 -------
.../jms/example/MessagePriorityExample.java | 134 ------
.../standard/no-consumer-buffering/pom.xml | 108 -----
.../standard/no-consumer-buffering/readme.html | 205 ----------
.../jms/example/NoConsumerBufferingExample.java | 110 -----
.../src/main/resources/jndi.properties | 20 -
.../broker-features/standard/paging/pom.xml | 109 -----
.../broker-features/standard/paging/readme.html | 187 ---------
.../artemis/jms/example/PagingExample.java | 135 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 93 -----
.../paging/src/main/resources/jndi.properties | 21 -
examples/broker-features/standard/pom.xml | 171 --------
.../standard/pre-acknowledge/pom.xml | 109 -----
.../standard/pre-acknowledge/readme.html | 154 -------
.../jms/example/PreacknowledgeExample.java | 126 ------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 63 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/producer-rate-limit/pom.xml | 109 -----
.../standard/producer-rate-limit/readme.html | 176 --------
.../jms/example/ProducerRateLimitExample.java | 106 -----
.../src/main/resources/jndi.properties | 20 -
.../standard/queue-requestor/pom.xml | 104 -----
.../standard/queue-requestor/readme.html | 46 ---
.../jms/example/QueueRequestorExample.java | 96 -----
.../jms/example/TextReverserService.java | 113 -----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 67 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/queue-selector/pom.xml | 109 -----
.../standard/queue-selector/readme.html | 52 ---
.../jms/example/QueueSelectorExample.java | 143 -------
.../src/main/resources/jndi.properties | 20 -
examples/broker-features/standard/queue/pom.xml | 109 -----
.../broker-features/standard/queue/readme.html | 38 --
.../artemis/jms/example/QueueExample.java | 84 ----
.../queue/src/main/resources/jndi.properties | 20 -
.../standard/reattach-node/pom.xml | 111 -----
.../standard/reattach-node/readme.html | 55 ---
.../artemis/jms/example/ReattachExample.java | 150 -------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 82 ----
.../src/main/resources/jndi.properties | 20 -
.../standard/request-reply/pom.xml | 112 -----
.../standard/request-reply/readme.html | 180 --------
.../jms/example/RequestReplyExample.java | 202 ---------
.../src/main/resources/jndi.properties | 20 -
.../standard/rest/dup-send/README.txt | 41 --
.../standard/rest/dup-send/pom.xml | 170 --------
.../rest/dup-send/src/main/java/Order.java | 69 ----
.../rest/dup-send/src/main/java/PostOrder.java | 69 ----
.../dup-send/src/main/java/PostOrderWithId.java | 45 --
.../dup-send/src/main/java/ReceiveOrder.java | 51 ---
.../src/main/resources/activemq-client.xml | 36 --
.../src/main/resources/activemq-rest.xml | 23 --
.../src/main/resources/artemis-roles.properties | 17 -
.../src/main/resources/artemis-users.properties | 17 -
.../rest/dup-send/src/main/resources/broker.xml | 59 ---
.../dup-send/src/main/webapp/WEB-INF/web.xml | 55 ---
.../standard/rest/javascript-chat/README.txt | 16 -
.../standard/rest/javascript-chat/pom.xml | 184 ---------
.../src/main/resources/artemis-roles.properties | 17 -
.../src/main/resources/artemis-users.properties | 17 -
.../src/main/resources/broker.xml | 58 ---
.../src/main/webapp/WEB-INF/web.xml | 51 ---
.../javascript-chat/src/main/webapp/index.html | 189 ---------
.../messaging/test/AutoAckTopicTest.java | 88 ----
.../standard/rest/jms-to-rest/README.txt | 49 ---
.../standard/rest/jms-to-rest/pom.xml | 170 --------
.../standard/rest/jms-to-rest/postOrder.py | 44 --
.../standard/rest/jms-to-rest/receiveOrder.py | 68 ---
.../jms-to-rest/src/main/java/JmsHelper.java | 38 --
.../jms-to-rest/src/main/java/JmsReceive.java | 55 ---
.../rest/jms-to-rest/src/main/java/JmsSend.java | 47 ---
.../rest/jms-to-rest/src/main/java/Order.java | 69 ----
.../jms-to-rest/src/main/java/RestReceive.java | 52 ---
.../jms-to-rest/src/main/java/RestSend.java | 40 --
.../src/main/resources/activemq-client.xml | 36 --
.../src/main/resources/artemis-roles.properties | 17 -
.../src/main/resources/artemis-users.properties | 17 -
.../jms-to-rest/src/main/resources/broker.xml | 59 ---
.../jms-to-rest/src/main/webapp/WEB-INF/web.xml | 51 ---
examples/broker-features/standard/rest/pom.xml | 45 --
.../standard/rest/push/README.txt | 32 --
.../broker-features/standard/rest/push/pom.xml | 176 --------
.../rest/push/src/main/java/JmsHelper.java | 37 --
.../standard/rest/push/src/main/java/Order.java | 69 ----
.../rest/push/src/main/java/PostOrder.java | 47 ---
.../rest/push/src/main/java/PushReg.java | 52 ---
.../push/src/main/java/ReceiveShipping.java | 54 ---
.../push/src/main/resources/activemq-client.xml | 36 --
.../src/main/resources/artemis-roles.properties | 17 -
.../src/main/resources/artemis-users.properties | 17 -
.../rest/push/src/main/resources/broker.xml | 60 ---
.../src/main/resources/test-realm.properties | 18 -
.../rest/push/src/main/webapp/WEB-INF/web.xml | 70 ----
.../standard/scheduled-message/pom.xml | 114 ------
.../standard/scheduled-message/readme.html | 134 ------
.../jms/example/ScheduledMessageExample.java | 94 -----
.../src/main/resources/jndi.properties | 20 -
.../broker-features/standard/security/pom.xml | 111 -----
.../standard/security/readme.html | 326 ---------------
.../artemis/jms/example/SecurityExample.java | 282 -------------
.../activemq/server0/artemis-roles.properties | 20 -
.../activemq/server0/artemis-users.properties | 20 -
.../main/resources/activemq/server0/broker.xml | 81 ----
.../security/src/main/resources/jndi.properties | 22 -
.../standard/send-acknowledgements/pom.xml | 104 -----
.../standard/send-acknowledgements/readme.html | 140 -------
.../example/SendAcknowledgementsExample.java | 104 -----
.../src/main/resources/jndi.properties | 20 -
.../standard/spring-integration/pom.xml | 82 ----
.../standard/spring-integration/readme.html | 36 --
.../artemis/jms/example/ExampleListener.java | 37 --
.../artemis/jms/example/MessageSender.java | 71 ----
.../artemis/jms/example/SpringExample.java | 32 --
.../src/main/resources/artemis-roles.properties | 17 -
.../src/main/resources/artemis-users.properties | 17 -
.../src/main/resources/broker.xml | 53 ---
.../src/main/resources/spring-jms-beans.xml | 80 ----
.../standard/ssl-enabled/pom.xml | 109 -----
.../standard/ssl-enabled/readme.html | 56 ---
.../artemis/jms/example/SSLExample.java | 86 ----
.../activemq/server0/activemq.example.keystore | Bin 1273 -> 0 bytes
.../server0/activemq.example.truststore | Bin 866 -> 0 bytes
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 60 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/static-selector/pom.xml | 109 -----
.../standard/static-selector/readme.html | 60 ---
.../jms/example/StaticSelectorExample.java | 137 -------
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 67 ---
.../src/main/resources/jndi.properties | 20 -
.../broker-features/standard/temp-queue/pom.xml | 109 -----
.../standard/temp-queue/readme.html | 40 --
.../jms/example/TemporaryQueueExample.java | 118 ------
.../main/resources/activemq/server0/broker.xml | 65 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/topic-hierarchies/pom.xml | 109 -----
.../standard/topic-hierarchies/readme.html | 42 --
.../jms/example/TopicHierarchyExample.java | 121 ------
.../main/resources/activemq/server0/broker.xml | 71 ----
.../src/main/resources/jndi.properties | 19 -
.../standard/topic-selector-example1/pom.xml | 109 -----
.../topic-selector-example1/readme.html | 38 --
.../jms/example/TopicSelectorExample1.java | 145 -------
.../main/resources/activemq/server0/broker.xml | 60 ---
.../src/main/resources/jndi.properties | 20 -
.../standard/topic-selector-example2/pom.xml | 109 -----
.../topic-selector-example2/readme.html | 47 ---
.../jms/example/TopicSelectorExample2.java | 145 -------
.../main/resources/activemq/server0/broker.xml | 60 ---
.../src/main/resources/jndi.properties | 20 -
examples/broker-features/standard/topic/pom.xml | 108 -----
.../broker-features/standard/topic/readme.html | 36 --
.../artemis/jms/example/TopicExample.java | 94 -----
.../main/resources/activemq/server0/broker.xml | 59 ---
.../topic/src/main/resources/jndi.properties | 20 -
.../standard/transactional/pom.xml | 109 -----
.../standard/transactional/readme.html | 40 --
.../jms/example/TransactionalExample.java | 126 ------
.../src/main/resources/jndi.properties | 20 -
.../standard/xa-heuristic/pom.xml | 111 -----
.../standard/xa-heuristic/readme.html | 48 ---
.../activemq/artemis/jms/example/DummyXid.java | 184 ---------
.../artemis/jms/example/XAHeuristicExample.java | 219 ----------
.../src/main/resources/jndi.properties | 21 -
.../broker-features/standard/xa-receive/pom.xml | 109 -----
.../standard/xa-receive/readme.html | 48 ---
.../activemq/artemis/jms/example/DummyXid.java | 184 ---------
.../artemis/jms/example/XAReceiveExample.java | 145 -------
.../src/main/resources/jndi.properties | 21 -
.../broker-features/standard/xa-send/pom.xml | 109 -----
.../standard/xa-send/readme.html | 215 ----------
.../activemq/artemis/jms/example/DummyXid.java | 184 ---------
.../artemis/jms/example/XASendExample.java | 191 ---------
.../xa-send/src/main/resources/jndi.properties | 21 -
.../sub-modules/aerogear/pom.xml | 125 ------
.../sub-modules/aerogear/readme.html | 157 -------
.../artemis/jms/example/AerogearExample.java | 77 ----
.../main/resources/activemq/server0/broker.xml | 77 ----
.../aerogear/src/main/resources/jndi.properties | 20 -
.../sub-modules/artemis-ra-rar/pom.xml | 101 -----
.../artemis-ra-rar/src/main/resources/ra.xml | 308 --------------
examples/broker-features/sub-modules/pom.xml | 58 ---
.../broker-features/sub-modules/vertx/pom.xml | 145 -------
.../sub-modules/vertx/readme.html | 103 -----
.../artemis/core/example/ExampleVerticle.java | 54 ---
.../core/example/VertxConnectorExample.java | 105 -----
.../main/resources/activemq/server0/broker.xml | 81 ----
.../client-side-load-balancing/pom.xml | 196 +++++++++
.../client-side-load-balancing/readme.html | 49 +++
.../example/ClientSideLoadBalancingExample.java | 138 +++++++
.../src/main/resources/jndi.properties | 20 +
.../clustered-durable-subscription/pom.xml | 158 +++++++
.../clustered-durable-subscription/readme.html | 66 +++
.../ClusteredDurableSubscriptionExample.java | 130 ++++++
.../main/resources/activemq/server0/broker.xml | 96 +++++
.../main/resources/activemq/server1/broker.xml | 96 +++++
.../clustered/clustered-grouping/pom.xml | 194 +++++++++
.../clustered/clustered-grouping/readme.html | 81 ++++
.../jms/example/ClusteredGroupingExample.java | 153 +++++++
.../main/resources/activemq/server0/broker.xml | 105 +++++
.../main/resources/activemq/server1/broker.xml | 102 +++++
.../main/resources/activemq/server2/broker.xml | 102 +++++
.../clustered/clustered-jgroups/pom.xml | 161 ++++++++
.../clustered/clustered-jgroups/readme.html | 67 +++
.../jms/example/ClusteredJgroupsExample.java | 140 +++++++
.../main/resources/activemq/server0/broker.xml | 97 +++++
.../activemq/server0/client-jndi.properties | 19 +
.../activemq/server0/test-jgroups-file_ping.xml | 73 ++++
.../main/resources/activemq/server1/broker.xml | 96 +++++
.../activemq/server1/client-jndi.properties | 19 +
.../activemq/server1/test-jgroups-file_ping.xml | 73 ++++
.../features/clustered/clustered-queue/pom.xml | 154 +++++++
.../clustered/clustered-queue/readme.html | 56 +++
.../jms/example/ClusteredQueueExample.java | 117 ++++++
.../main/resources/activemq/server0/broker.xml | 95 +++++
.../main/resources/activemq/server1/broker.xml | 96 +++++
.../clustered-static-discovery/pom.xml | 239 +++++++++++
.../clustered-static-discovery/readme.html | 58 +++
.../example/StaticClusteredQueueExample.java | 173 ++++++++
.../main/resources/activemq/server0/broker.xml | 82 ++++
.../main/resources/activemq/server1/broker.xml | 82 ++++
.../main/resources/activemq/server2/broker.xml | 79 ++++
.../main/resources/activemq/server3/broker.xml | 79 ++++
.../clustered/clustered-static-oneway/pom.xml | 198 +++++++++
.../clustered-static-oneway/readme.html | 64 +++
.../jms/example/ClusterStaticOnewayExample.java | 159 +++++++
.../main/resources/activemq/server0/broker.xml | 79 ++++
.../main/resources/activemq/server1/broker.xml | 79 ++++
.../main/resources/activemq/server2/broker.xml | 74 ++++
.../features/clustered/clustered-topic/pom.xml | 153 +++++++
.../clustered/clustered-topic/readme.html | 55 +++
.../jms/example/ClusteredTopicExample.java | 129 ++++++
.../main/resources/activemq/server0/broker.xml | 97 +++++
.../main/resources/activemq/server1/broker.xml | 95 +++++
examples/features/clustered/pom.xml | 77 ++++
.../queue-message-redistribution/pom.xml | 155 +++++++
.../queue-message-redistribution/readme.html | 61 +++
.../QueueMessageRedistributionExample.java | 145 +++++++
.../main/resources/activemq/server0/broker.xml | 106 +++++
.../main/resources/activemq/server1/broker.xml | 107 +++++
.../clustered/symmetric-cluster/pom.xml | 320 +++++++++++++++
.../clustered/symmetric-cluster/readme.html | 74 ++++
.../jms/example/SymmetricClusterExample.java | 222 ++++++++++
.../main/resources/activemq/server0/broker.xml | 99 +++++
.../main/resources/activemq/server1/broker.xml | 97 +++++
.../main/resources/activemq/server2/broker.xml | 97 +++++
.../main/resources/activemq/server3/broker.xml | 97 +++++
.../main/resources/activemq/server4/broker.xml | 96 +++++
.../main/resources/activemq/server5/broker.xml | 96 +++++
.../ha/application-layer-failover/pom.xml | 102 +++++
.../ha/application-layer-failover/readme.html | 169 ++++++++
.../ApplicationLayerFailoverExample.java | 221 ++++++++++
.../ha/client-side-failoverlistener/pom.xml | 109 +++++
.../ha/client-side-failoverlistener/readme.html | 37 ++
.../ClientSideFailoverListerExample.java | 129 ++++++
.../src/main/resources/jndi.properties | 20 +
.../ha/colocated-failover-scale-down/pom.xml | 103 +++++
.../colocated-failover-scale-down/readme.html | 65 +++
.../ColocatedFailoverScaleDownExample.java | 140 +++++++
.../main/resources/activemq/server0/broker.xml | 129 ++++++
.../main/resources/activemq/server1/broker.xml | 127 ++++++
examples/features/ha/colocated-failover/pom.xml | 102 +++++
.../features/ha/colocated-failover/readme.html | 56 +++
.../jms/example/ColocatedFailoverExample.java | 147 +++++++
.../main/resources/activemq/server0/broker.xml | 115 ++++++
.../main/resources/activemq/server1/broker.xml | 114 ++++++
.../features/ha/ha-policy-autobackup/pom.xml | 103 +++++
.../jms/example/HAPolicyAutoBackupExample.java | 155 +++++++
.../main/resources/activemq/server0/broker.xml | 108 +++++
.../main/resources/activemq/server1/broker.xml | 108 +++++
.../ha/multiple-failover-failback/pom.xml | 121 ++++++
.../MultipleFailoverFailbackExample.java | 142 +++++++
.../src/main/resources/jndi.properties | 20 +
examples/features/ha/multiple-failover/pom.xml | 121 ++++++
.../jms/example/MultipleFailoverExample.java | 142 +++++++
.../src/main/resources/jndi.properties | 20 +
.../ha/non-transaction-failover/pom.xml | 109 +++++
.../ha/non-transaction-failover/readme.html | 157 +++++++
.../example/NonTransactionFailoverExample.java | 128 ++++++
.../src/main/resources/jndi.properties | 20 +
examples/features/ha/pom.xml | 95 +++++
.../ha/replicated-failback-static/pom.xml | 104 +++++
.../ha/replicated-failback-static/readme.html | 38 ++
.../ReplicatedFailbackStaticExample.java | 149 +++++++
.../main/resources/activemq/server0/broker.xml | 87 ++++
.../main/resources/activemq/server1/broker.xml | 89 ++++
.../src/main/resources/jndi.properties | 20 +
.../features/ha/replicated-failback/pom.xml | 103 +++++
.../features/ha/replicated-failback/readme.html | 38 ++
.../jms/example/ReplicatedFailbackExample.java | 149 +++++++
.../main/resources/activemq/server0/broker.xml | 101 +++++
.../main/resources/activemq/server1/broker.xml | 102 +++++
.../src/main/resources/jndi.properties | 20 +
.../ha/replicated-multiple-failover/pom.xml | 118 ++++++
.../ha/replicated-multiple-failover/readme.html | 45 ++
.../ReplicatedMultipleFailoverExample.java | 149 +++++++
.../main/resources/activemq/server0/broker.xml | 95 +++++
.../main/resources/activemq/server1/broker.xml | 95 +++++
.../main/resources/activemq/server2/broker.xml | 95 +++++
.../src/main/resources/jndi.properties | 20 +
.../ha/replicated-transaction-failover/pom.xml | 104 +++++
.../replicated-transaction-failover/readme.html | 148 +++++++
.../ReplicatedTransactionFailoverExample.java | 168 ++++++++
.../main/resources/activemq/server0/broker.xml | 96 +++++
.../main/resources/activemq/server1/broker.xml | 97 +++++
.../src/main/resources/jndi.properties | 20 +
examples/features/ha/scale-down/pom.xml | 105 +++++
examples/features/ha/scale-down/readme.html | 51 +++
.../artemis/jms/example/ScaleDownExample.java | 132 ++++++
.../main/resources/activemq/server0/broker.xml | 117 ++++++
.../main/resources/activemq/server1/broker.xml | 108 +++++
.../features/ha/stop-server-failover/pom.xml | 160 ++++++++
.../ha/stop-server-failover/readme.html | 44 ++
.../jms/example/StopServerFailoverExample.java | 117 ++++++
.../src/main/resources/jndi.properties | 20 +
.../features/ha/transaction-failover/pom.xml | 104 +++++
.../ha/transaction-failover/readme.html | 46 +++
.../jms/example/TransactionFailoverExample.java | 167 ++++++++
.../main/resources/activemq/server0/broker.xml | 98 +++++
.../main/resources/activemq/server1/broker.xml | 98 +++++
.../src/main/resources/jndi.properties | 20 +
examples/features/perf/perf/pom.xml | 156 +++++++
examples/features/perf/perf/readme.html | 39 ++
.../activemq/artemis/jms/example/PerfBase.java | 409 +++++++++++++++++++
.../artemis/jms/example/PerfListener.java | 46 +++
.../artemis/jms/example/PerfParams.java | 158 +++++++
.../artemis/jms/example/PerfSender.java | 46 +++
.../activemq/artemis/jms/example/Server.java | 27 ++
.../main/resources/activemq/server0/broker.xml | 46 +++
.../perf/src/main/resources/jndi.properties | 20 +
.../perf/src/main/resources/perf.properties | 30 ++
examples/features/perf/pom.xml | 50 +++
examples/features/perf/soak/README | 85 ++++
examples/features/perf/soak/pom.xml | 162 ++++++++
examples/features/perf/soak/server0/broker.xml | 49 +++
examples/features/perf/soak/soak.properties | 30 ++
.../artemis/jms/soak/example/SoakBase.java | 116 ++++++
.../artemis/jms/soak/example/SoakParams.java | 158 +++++++
.../artemis/jms/soak/example/SoakReceiver.java | 190 +++++++++
.../artemis/jms/soak/example/SoakSender.java | 195 +++++++++
.../soak/src/main/resources/jndi.properties | 20 +
examples/features/pom.xml | 68 +++
examples/features/standard/README.md | 32 ++
examples/features/standard/bridge/pom.xml | 167 ++++++++
examples/features/standard/bridge/readme.html | 74 ++++
.../artemis/jms/example/BridgeExample.java | 175 ++++++++
.../jms/example/HatColourChangeTransformer.java | 38 ++
.../main/resources/activemq/server0/broker.xml | 88 ++++
.../main/resources/activemq/server1/broker.xml | 59 +++
examples/features/standard/browser/pom.xml | 110 +++++
examples/features/standard/browser/readme.html | 40 ++
.../jms/example/QueueBrowserExample.java | 103 +++++
.../browser/src/main/resources/jndi.properties | 20 +
.../features/standard/client-kickoff/pom.xml | 112 +++++
.../standard/client-kickoff/readme.html | 54 +++
.../jms/example/ClientKickoffExample.java | 106 +++++
.../main/resources/activemq/server0/broker.xml | 47 +++
.../src/main/resources/jndi.properties | 19 +
.../standard/consumer-rate-limit/pom.xml | 109 +++++
.../standard/consumer-rate-limit/readme.html | 47 +++
.../jms/example/ConsumerRateLimitExample.java | 115 ++++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/dead-letter/pom.xml | 110 +++++
.../features/standard/dead-letter/readme.html | 66 +++
.../artemis/jms/example/DeadLetterExample.java | 136 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 71 ++++
.../src/main/resources/jndi.properties | 21 +
.../standard/delayed-redelivery/pom.xml | 110 +++++
.../standard/delayed-redelivery/readme.html | 56 +++
.../jms/example/DelayedRedeliveryExample.java | 126 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 70 ++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/divert/pom.xml | 159 +++++++
examples/features/standard/divert/readme.html | 119 ++++++
.../example/AddForwardingTimeTransformer.java | 31 ++
.../artemis/jms/example/DivertExample.java | 212 ++++++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 121 ++++++
.../activemq/server1/artemis-roles.properties | 17 +
.../activemq/server1/artemis-users.properties | 17 +
.../main/resources/activemq/server1/broker.xml | 64 +++
.../standard/durable-subscription/pom.xml | 110 +++++
.../standard/durable-subscription/readme.html | 39 ++
.../jms/example/DurableSubscriptionExample.java | 116 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 61 +++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/embedded-simple/pom.xml | 84 ++++
.../standard/embedded-simple/readme.html | 96 +++++
.../artemis/jms/example/EmbeddedExample.java | 86 ++++
.../src/main/resources/broker.xml | 52 +++
examples/features/standard/embedded/pom.xml | 84 ++++
examples/features/standard/embedded/readme.html | 38 ++
.../artemis/jms/example/EmbeddedExample.java | 107 +++++
examples/features/standard/expiry/pom.xml | 110 +++++
examples/features/standard/expiry/readme.html | 61 +++
.../artemis/jms/example/ExpiryExample.java | 120 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 70 ++++
.../expiry/src/main/resources/jndi.properties | 21 +
.../features/standard/http-transport/pom.xml | 110 +++++
.../standard/http-transport/readme.html | 52 +++
.../jms/example/HttpTransportExample.java | 81 ++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 61 +++
.../instantiate-connection-factory/pom.xml | 111 +++++
.../instantiate-connection-factory/readme.html | 49 +++
.../InstantiateConnectionFactoryExample.java | 81 ++++
examples/features/standard/interceptor/pom.xml | 111 +++++
.../features/standard/interceptor/readme.html | 72 ++++
.../artemis/jms/example/InterceptorExample.java | 88 ++++
.../artemis/jms/example/SimpleInterceptor.java | 48 +++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 65 +++
.../src/main/resources/jndi.properties | 20 +
.../standard/jms-auto-closeable/pom.xml | 106 +++++
.../standard/jms-auto-closeable/readme.html | 96 +++++
.../jms/example/JMSAutoCloseableExample.java | 51 +++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/jms-bridge/jms-bridge.png | Bin 0 -> 93885 bytes
examples/features/standard/jms-bridge/pom.xml | 159 +++++++
.../features/standard/jms-bridge/readme.html | 246 +++++++++++
.../artemis/jms/example/JMSBridgeExample.java | 136 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 53 +++
.../activemq/server1/artemis-roles.properties | 17 +
.../activemq/server1/artemis-users.properties | 17 +
.../main/resources/activemq/server1/broker.xml | 53 +++
.../standard/jms-completion-listener/pom.xml | 110 +++++
.../jms-completion-listener/readme.html | 112 +++++
.../example/JMSCompletionListenerExample.java | 82 ++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/jms-context/pom.xml | 109 +++++
.../features/standard/jms-context/readme.html | 35 ++
.../artemis/jms/example/JMSContextExample.java | 51 +++
.../standard/jms-shared-consumer/pom.xml | 111 +++++
.../standard/jms-shared-consumer/readme.html | 119 ++++++
.../jms/example/JMSSharedConsumerExample.java | 87 ++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 61 +++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/jmx/pom.xml | 117 ++++++
examples/features/standard/jmx/readme.html | 181 ++++++++
.../artemis/jms/example/JMXExample.java | 121 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 64 +++
.../jmx/src/main/resources/jndi.properties | 20 +
.../features/standard/large-message/pom.xml | 88 ++++
.../features/standard/large-message/readme.html | 200 +++++++++
.../jms/example/LargeMessageExample.java | 193 +++++++++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/last-value-queue/pom.xml | 109 +++++
.../standard/last-value-queue/readme.html | 162 ++++++++
.../jms/example/LastValueQueueExample.java | 104 +++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 67 +++
.../src/main/resources/jndi.properties | 20 +
.../standard/management-notifications/pom.xml | 109 +++++
.../management-notifications/readme.html | 215 ++++++++++
.../example/ManagementNotificationExample.java | 109 +++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 81 ++++
.../src/main/resources/jndi.properties | 21 +
examples/features/standard/management/pom.xml | 109 +++++
.../features/standard/management/readme.html | 208 ++++++++++
.../artemis/jms/example/ManagementExample.java | 133 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 76 ++++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/message-counters/pom.xml | 116 ++++++
.../standard/message-counters/readme.html | 197 +++++++++
.../jms/example/MessageCounterExample.java | 134 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 86 ++++
.../src/main/resources/jndi.properties | 21 +
.../features/standard/message-group/pom.xml | 109 +++++
.../features/standard/message-group/readme.html | 152 +++++++
.../jms/example/MessageGroupExample.java | 122 ++++++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/message-group2/pom.xml | 109 +++++
.../standard/message-group2/readme.html | 161 ++++++++
.../jms/example/MessageGroup2Example.java | 129 ++++++
.../features/standard/message-priority/pom.xml | 109 +++++
.../standard/message-priority/readme.html | 159 +++++++
.../jms/example/MessagePriorityExample.java | 134 ++++++
.../standard/no-consumer-buffering/pom.xml | 108 +++++
.../standard/no-consumer-buffering/readme.html | 205 ++++++++++
.../jms/example/NoConsumerBufferingExample.java | 110 +++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/paging/pom.xml | 109 +++++
examples/features/standard/paging/readme.html | 187 +++++++++
.../artemis/jms/example/PagingExample.java | 135 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 93 +++++
.../paging/src/main/resources/jndi.properties | 21 +
examples/features/standard/pom.xml | 171 ++++++++
.../features/standard/pre-acknowledge/pom.xml | 109 +++++
.../standard/pre-acknowledge/readme.html | 154 +++++++
.../jms/example/PreacknowledgeExample.java | 126 ++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 63 +++
.../src/main/resources/jndi.properties | 20 +
.../standard/producer-rate-limit/pom.xml | 109 +++++
.../standard/producer-rate-limit/readme.html | 176 ++++++++
.../jms/example/ProducerRateLimitExample.java | 106 +++++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/queue-requestor/pom.xml | 104 +++++
.../standard/queue-requestor/readme.html | 46 +++
.../jms/example/QueueRequestorExample.java | 96 +++++
.../jms/example/TextReverserService.java | 113 +++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 67 +++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/queue-selector/pom.xml | 109 +++++
.../standard/queue-selector/readme.html | 52 +++
.../jms/example/QueueSelectorExample.java | 143 +++++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/queue/pom.xml | 109 +++++
examples/features/standard/queue/readme.html | 38 ++
.../artemis/jms/example/QueueExample.java | 84 ++++
.../queue/src/main/resources/jndi.properties | 20 +
.../features/standard/reattach-node/pom.xml | 111 +++++
.../features/standard/reattach-node/readme.html | 55 +++
.../artemis/jms/example/ReattachExample.java | 150 +++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 82 ++++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/request-reply/pom.xml | 112 +++++
.../features/standard/request-reply/readme.html | 180 ++++++++
.../jms/example/RequestReplyExample.java | 202 +++++++++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/rest/dup-send/README.txt | 41 ++
.../features/standard/rest/dup-send/pom.xml | 170 ++++++++
.../rest/dup-send/src/main/java/Order.java | 69 ++++
.../rest/dup-send/src/main/java/PostOrder.java | 69 ++++
.../dup-send/src/main/java/PostOrderWithId.java | 45 ++
.../dup-send/src/main/java/ReceiveOrder.java | 51 +++
.../src/main/resources/activemq-client.xml | 36 ++
.../src/main/resources/activemq-rest.xml | 23 ++
.../src/main/resources/artemis-roles.properties | 17 +
.../src/main/resources/artemis-users.properties | 17 +
.../rest/dup-send/src/main/resources/broker.xml | 59 +++
.../dup-send/src/main/webapp/WEB-INF/web.xml | 55 +++
.../standard/rest/javascript-chat/README.txt | 16 +
.../standard/rest/javascript-chat/pom.xml | 184 +++++++++
.../src/main/resources/artemis-roles.properties | 17 +
.../src/main/resources/artemis-users.properties | 17 +
.../src/main/resources/broker.xml | 58 +++
.../src/main/webapp/WEB-INF/web.xml | 51 +++
.../javascript-chat/src/main/webapp/index.html | 189 +++++++++
.../messaging/test/AutoAckTopicTest.java | 88 ++++
.../standard/rest/jms-to-rest/README.txt | 49 +++
.../features/standard/rest/jms-to-rest/pom.xml | 170 ++++++++
.../standard/rest/jms-to-rest/postOrder.py | 44 ++
.../standard/rest/jms-to-rest/receiveOrder.py | 68 +++
.../jms-to-rest/src/main/java/JmsHelper.java | 38 ++
.../jms-to-rest/src/main/java/JmsReceive.java | 55 +++
.../rest/jms-to-rest/src/main/java/JmsSend.java | 47 +++
.../rest/jms-to-rest/src/main/java/Order.java | 69 ++++
.../jms-to-rest/src/main/java/RestReceive.java | 52 +++
.../jms-to-rest/src/main/java/RestSend.java | 40 ++
.../src/main/resources/activemq-client.xml | 36 ++
.../src/main/resources/artemis-roles.properties | 17 +
.../src/main/resources/artemis-users.properties | 17 +
.../jms-to-rest/src/main/resources/broker.xml | 59 +++
.../jms-to-rest/src/main/webapp/WEB-INF/web.xml | 51 +++
examples/features/standard/rest/pom.xml | 45 ++
examples/features/standard/rest/push/README.txt | 32 ++
examples/features/standard/rest/push/pom.xml | 176 ++++++++
.../rest/push/src/main/java/JmsHelper.java | 37 ++
.../standard/rest/push/src/main/java/Order.java | 69 ++++
.../rest/push/src/main/java/PostOrder.java | 47 +++
.../rest/push/src/main/java/PushReg.java | 52 +++
.../push/src/main/java/ReceiveShipping.java | 54 +++
.../push/src/main/resources/activemq-client.xml | 36 ++
.../src/main/resources/artemis-roles.properties | 17 +
.../src/main/resources/artemis-users.properties | 17 +
.../rest/push/src/main/resources/broker.xml | 60 +++
.../src/main/resources/test-realm.properties | 18 +
.../rest/push/src/main/webapp/WEB-INF/web.xml | 70 ++++
.../features/standard/scheduled-message/pom.xml | 114 ++++++
.../standard/scheduled-message/readme.html | 134 ++++++
.../jms/example/ScheduledMessageExample.java | 94 +++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/security/pom.xml | 111 +++++
examples/features/standard/security/readme.html | 326 +++++++++++++++
.../artemis/jms/example/SecurityExample.java | 282 +++++++++++++
.../activemq/server0/artemis-roles.properties | 20 +
.../activemq/server0/artemis-users.properties | 20 +
.../main/resources/activemq/server0/broker.xml | 81 ++++
.../security/src/main/resources/jndi.properties | 22 +
.../standard/send-acknowledgements/pom.xml | 104 +++++
.../standard/send-acknowledgements/readme.html | 140 +++++++
.../example/SendAcknowledgementsExample.java | 104 +++++
.../src/main/resources/jndi.properties | 20 +
.../standard/spring-integration/pom.xml | 82 ++++
.../standard/spring-integration/readme.html | 36 ++
.../artemis/jms/example/ExampleListener.java | 37 ++
.../artemis/jms/example/MessageSender.java | 71 ++++
.../artemis/jms/example/SpringExample.java | 32 ++
.../src/main/resources/artemis-roles.properties | 17 +
.../src/main/resources/artemis-users.properties | 17 +
.../src/main/resources/broker.xml | 53 +++
.../src/main/resources/spring-jms-beans.xml | 80 ++++
examples/features/standard/ssl-enabled/pom.xml | 109 +++++
.../features/standard/ssl-enabled/readme.html | 56 +++
.../artemis/jms/example/SSLExample.java | 86 ++++
.../activemq/server0/activemq.example.keystore | Bin 0 -> 1273 bytes
.../server0/activemq.example.truststore | Bin 0 -> 866 bytes
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 60 +++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/static-selector/pom.xml | 109 +++++
.../standard/static-selector/readme.html | 60 +++
.../jms/example/StaticSelectorExample.java | 137 +++++++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 67 +++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/temp-queue/pom.xml | 109 +++++
.../features/standard/temp-queue/readme.html | 40 ++
.../jms/example/TemporaryQueueExample.java | 118 ++++++
.../main/resources/activemq/server0/broker.xml | 65 +++
.../src/main/resources/jndi.properties | 20 +
.../features/standard/topic-hierarchies/pom.xml | 109 +++++
.../standard/topic-hierarchies/readme.html | 42 ++
.../jms/example/TopicHierarchyExample.java | 121 ++++++
.../main/resources/activemq/server0/broker.xml | 71 ++++
.../src/main/resources/jndi.properties | 19 +
.../standard/topic-selector-example1/pom.xml | 109 +++++
.../topic-selector-example1/readme.html | 38 ++
.../jms/example/TopicSelectorExample1.java | 145 +++++++
.../main/resources/activemq/server0/broker.xml | 60 +++
.../src/main/resources/jndi.properties | 20 +
.../standard/topic-selector-example2/pom.xml | 109 +++++
.../topic-selector-example2/readme.html | 47 +++
.../jms/example/TopicSelectorExample2.java | 145 +++++++
.../main/resources/activemq/server0/broker.xml | 60 +++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/topic/pom.xml | 108 +++++
examples/features/standard/topic/readme.html | 36 ++
.../artemis/jms/example/TopicExample.java | 94 +++++
.../main/resources/activemq/server0/broker.xml | 59 +++
.../topic/src/main/resources/jndi.properties | 20 +
.../features/standard/transactional/pom.xml | 109 +++++
.../features/standard/transactional/readme.html | 40 ++
.../jms/example/TransactionalExample.java | 126 ++++++
.../src/main/resources/jndi.properties | 20 +
examples/features/standard/xa-heuristic/pom.xml | 111 +++++
.../features/standard/xa-heuristic/readme.html | 48 +++
.../activemq/artemis/jms/example/DummyXid.java | 184 +++++++++
.../artemis/jms/example/XAHeuristicExample.java | 219 ++++++++++
.../src/main/resources/jndi.properties | 21 +
examples/features/standard/xa-receive/pom.xml | 109 +++++
.../features/standard/xa-receive/readme.html | 48 +++
.../activemq/artemis/jms/example/DummyXid.java | 184 +++++++++
.../artemis/jms/example/XAReceiveExample.java | 145 +++++++
.../src/main/resources/jndi.properties | 21 +
examples/features/standard/xa-send/pom.xml | 109 +++++
examples/features/standard/xa-send/readme.html | 215 ++++++++++
.../activemq/artemis/jms/example/DummyXid.java | 184 +++++++++
.../artemis/jms/example/XASendExample.java | 191 +++++++++
.../xa-send/src/main/resources/jndi.properties | 21 +
examples/features/sub-modules/aerogear/pom.xml | 125 ++++++
.../features/sub-modules/aerogear/readme.html | 157 +++++++
.../artemis/jms/example/AerogearExample.java | 77 ++++
.../main/resources/activemq/server0/broker.xml | 77 ++++
.../aerogear/src/main/resources/jndi.properties | 20 +
.../features/sub-modules/artemis-ra-rar/pom.xml | 101 +++++
.../artemis-ra-rar/src/main/resources/ra.xml | 308 ++++++++++++++
examples/features/sub-modules/pom.xml | 58 +++
examples/features/sub-modules/vertx/pom.xml | 145 +++++++
examples/features/sub-modules/vertx/readme.html | 103 +++++
.../artemis/core/example/ExampleVerticle.java | 54 +++
.../core/example/VertxConnectorExample.java | 105 +++++
.../main/resources/activemq/server0/broker.xml | 81 ++++
examples/pom.xml | 3 +-
1021 files changed, 42935 insertions(+), 42936 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/clustered/client-side-load-balancing/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/clustered/client-side-load-balancing/pom.xml b/examples/broker-features/clustered/client-side-load-balancing/pom.xml
deleted file mode 100644
index c2993b2..0000000
--- a/examples/broker-features/clustered/client-side-load-balancing/pom.xml
+++ /dev/null
@@ -1,196 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.clustered</groupId>
- <artifactId>broker-clustered</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>client-side-load-balancing</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Client Side Load Balancing Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create0</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <instance>${basedir}/target/server0</instance>
- <clustered>true</clustered>
- </configuration>
- </execution>
- <execution>
- <id>create1</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <instance>${basedir}/target/server1</instance>
- <clustered>true</clustered>
- <portOffset>1</portOffset>
- </configuration>
- </execution>
- <execution>
- <id>create2</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <instance>${basedir}/target/server2</instance>
- <clustered>true</clustered>
- <portOffset>2</portOffset>
- </configuration>
- </execution>
- <execution>
- <id>start0</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <spawn>true</spawn>
- <ignore>${noServer}</ignore>
- <location>${basedir}/target/server0</location>
- <testURI>tcp://localhost:61616</testURI>
- <args>
- <param>run</param>
- </args>
- <name>server0</name>
- </configuration>
- </execution>
- <execution>
- <id>start1</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <spawn>true</spawn>
- <location>${basedir}/target/server1</location>
- <testURI>tcp://localhost:61617</testURI>
- <args>
- <param>run</param>
- </args>
- <name>server1</name>
- </configuration>
- </execution>
- <execution>
- <id>start2</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <spawn>true</spawn>
- <location>${basedir}/target/server2</location>
- <testURI>tcp://localhost:61618</testURI>
- <args>
- <param>run</param>
- </args>
- <name>server2</name>
- </configuration>
- </execution>
- <execution>
- <id>runClient</id>
- <goals>
- <goal>runClient</goal>
- </goals>
- <configuration>
- <clientClass>org.apache.activemq.artemis.jms.example.ClientSideLoadBalancingExample</clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop0</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <location>${basedir}/target/server0</location>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- <execution>
- <id>stop1</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <location>${basedir}/target/server1</location>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- <execution>
- <id>stop2</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <location>${basedir}/target/server2</location>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.clustered</groupId>
- <artifactId>client-side-load-balancing</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/clustered/client-side-load-balancing/readme.html
----------------------------------------------------------------------
diff --git a/examples/broker-features/clustered/client-side-load-balancing/readme.html b/examples/broker-features/clustered/client-side-load-balancing/readme.html
deleted file mode 100644
index 9d3aba5..0000000
--- a/examples/broker-features/clustered/client-side-load-balancing/readme.html
+++ /dev/null
@@ -1,49 +0,0 @@
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<html>
- <head>
- <title>ActiveMQ Artemis JMS Client-Side Load-Balancing Example</title>
- <link rel="stylesheet" type="text/css" href="../../../common/common.css" />
- <link rel="stylesheet" type="text/css" href="../../../common/prettify.css" />
- <script type="text/javascript" src="../../../common/prettify.js"></script>
- </head>
- <body onload="prettyPrint()">
- <h1>JMS Client-Side Load-Balancing Example</h1>
- <pre>To run the example, simply type <b>mvn verify</b> from this directory, <br>or <b>mvn -PnoServer verify</b> if you want to start and create the server manually.</pre>
-
- <p>This example demonstrates how connnections created from a single JMS Connection factory can be created
- to different nodes of the cluster. In other words it demonstrates how ActiveMQ Artemis does <b>client side load balancing</b> of
- connections across the cluster.</p>
- <p>The particular load-balancing policy can be chosen to be random, round-robin or user-defined. Please see the user
- guide for more details of how to configure the specific load-balancing policy. In this example we will use
- the default round-robin load balancing policy.</p>
- <p>The list of servers over which ActiveMQ Artemis will round-robin the connections can either be specified explicitly
- in the connection factory when instantiating it directly, when configuring it on the server or configured
- to use UDP discovery to discover the list of servers over which to round-robin. This example will use UDP
- discovery to obtain the list.</p>
- <p>This example starts three servers which all broadcast their location using UDP discovery. The UDP broadcast configuration
- can be seen in the <code>broker.xml</code> file.</p>
- <p>A JMS ConnectionFactory is deployed on each server specifying the discovery group that will be used by that
- connection factory.</p>
- <p>For more information on ActiveMQ Artemis load balancing, and clustering in general, please see the clustering
- section of the user manual.</p>
-
- </body>
-</html>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
----------------------------------------------------------------------
diff --git a/examples/broker-features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java b/examples/broker-features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
deleted file mode 100644
index 1281017..0000000
--- a/examples/broker-features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
+++ /dev/null
@@ -1,138 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.activemq.artemis.jms.example;
-
-import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
-import javax.jms.JMSException;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-import javax.naming.InitialContext;
-
-/**
- * This example demonstrates how sessions created from a single connection can be load
- * balanced across the different nodes of the cluster.
- *
- * In this example there are three nodes and we use a round-robin client side load-balancing
- * policy.
- */
-public class ClientSideLoadBalancingExample {
-
- public static void main(final String[] args) throws Exception {
- InitialContext initialContext = null;
-
- Connection connectionA = null;
- Connection connectionB = null;
- Connection connectionC = null;
-
- try {
- // Step 1. Get an initial context for looking up JNDI from server 0
- initialContext = new InitialContext();
-
- // Step 2. Look-up the JMS Queue object from JNDI
- Queue queue = (Queue) initialContext.lookup("queue/exampleQueue");
-
- // Step 3. Look-up a JMS Connection Factory object from JNDI on server 0
- ConnectionFactory connectionFactory = (ConnectionFactory) initialContext.lookup("ConnectionFactory");
-
- // Step 4. We create 3 JMS connections from the same connection factory. Since we are using round-robin
- // load-balancing this should result in each sessions being connected to a different node of the cluster
- Connection conn = connectionFactory.createConnection();
- // Wait a little while to make sure broadcasts from all nodes have reached the client
- Thread.sleep(5000);
- connectionA = connectionFactory.createConnection();
- connectionB = connectionFactory.createConnection();
- connectionC = connectionFactory.createConnection();
- conn.close();
-
- // Step 5. We create JMS Sessions
- Session sessionA = connectionA.createSession(false, Session.AUTO_ACKNOWLEDGE);
- Session sessionB = connectionB.createSession(false, Session.AUTO_ACKNOWLEDGE);
- Session sessionC = connectionC.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- System.out.println("Session A - " + ((org.apache.activemq.artemis.core.client.impl.DelegatingSession) ((org.apache.activemq.artemis.jms.client.ActiveMQSession) sessionA).getCoreSession()).getConnection().getRemoteAddress());
- System.out.println("Session B - " + ((org.apache.activemq.artemis.core.client.impl.DelegatingSession) ((org.apache.activemq.artemis.jms.client.ActiveMQSession) sessionB).getCoreSession()).getConnection().getRemoteAddress());
- System.out.println("Session C - " + ((org.apache.activemq.artemis.core.client.impl.DelegatingSession) ((org.apache.activemq.artemis.jms.client.ActiveMQSession) sessionC).getCoreSession()).getConnection().getRemoteAddress());
-
- // Step 6. We create JMS MessageProducer objects on the sessions
- MessageProducer producerA = sessionA.createProducer(queue);
- MessageProducer producerB = sessionB.createProducer(queue);
- MessageProducer producerC = sessionC.createProducer(queue);
-
- // Step 7. We send some messages on each producer
- final int numMessages = 10;
-
- for (int i = 0; i < numMessages; i++) {
- TextMessage messageA = sessionA.createTextMessage("A:This is text message " + i);
- producerA.send(messageA);
- System.out.println("Sent message: " + messageA.getText());
-
- TextMessage messageB = sessionB.createTextMessage("B:This is text message " + i);
- producerB.send(messageB);
- System.out.println("Sent message: " + messageB.getText());
-
- TextMessage messageC = sessionC.createTextMessage("C:This is text message " + i);
- producerC.send(messageC);
- System.out.println("Sent message: " + messageC.getText());
- }
-
- // Step 8. We start the connection to consume messages
- connectionA.start();
- connectionB.start();
- connectionC.start();
-
- // Step 9. We consume messages from the 3 session, one at a time.
- // We try to consume one more message than expected from each session. If
- // the session were not properly load-balanced, we would be missing a
- // message from one of the sessions at the end.
- consume(sessionA, queue, numMessages, "A");
- consume(sessionB, queue, numMessages, "B");
- consume(sessionC, queue, numMessages, "C");
- }
- finally {
- // Step 10. Be sure to close our resources!
-
- if (connectionA != null) {
- connectionA.close();
- }
- if (connectionB != null) {
- connectionB.close();
- }
- if (connectionC != null) {
- connectionC.close();
- }
-
- if (initialContext != null) {
- initialContext.close();
- }
- }
- }
-
- private static void consume(Session session, Queue queue, int numMessages, String node) throws JMSException {
- MessageConsumer consumer = session.createConsumer(queue);
-
- for (int i = 0; i < numMessages; i++) {
- TextMessage message = (TextMessage) consumer.receive(2000);
- System.out.println("Got message: " + message.getText() + " from node " + node);
- }
-
- System.out.println("receive other message from node " + node + ": " + consumer.receive(2000));
- }
-}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/clustered/client-side-load-balancing/src/main/resources/jndi.properties
----------------------------------------------------------------------
diff --git a/examples/broker-features/clustered/client-side-load-balancing/src/main/resources/jndi.properties b/examples/broker-features/clustered/client-side-load-balancing/src/main/resources/jndi.properties
deleted file mode 100644
index d3f932c..0000000
--- a/examples/broker-features/clustered/client-side-load-balancing/src/main/resources/jndi.properties
+++ /dev/null
@@ -1,20 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-
-java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
-connectionFactory.ConnectionFactory=udp://231.7.7.7:9876
-queue.queue/exampleQueue=exampleQueue
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/6b17d966/examples/broker-features/clustered/clustered-durable-subscription/pom.xml
----------------------------------------------------------------------
diff --git a/examples/broker-features/clustered/clustered-durable-subscription/pom.xml b/examples/broker-features/clustered/clustered-durable-subscription/pom.xml
deleted file mode 100644
index 8f28710..0000000
--- a/examples/broker-features/clustered/clustered-durable-subscription/pom.xml
+++ /dev/null
@@ -1,158 +0,0 @@
-<?xml version='1.0'?>
-<!--
-Licensed to the Apache Software Foundation (ASF) under one
-or more contributor license agreements. See the NOTICE file
-distributed with this work for additional information
-regarding copyright ownership. The ASF licenses this file
-to you under the Apache License, Version 2.0 (the
-"License"); you may not use this file except in compliance
-with the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing,
-software distributed under the License is distributed on an
-"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-KIND, either express or implied. See the License for the
-specific language governing permissions and limitations
-under the License.
--->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.activemq.examples.clustered</groupId>
- <artifactId>broker-clustered</artifactId>
- <version>1.0.1-SNAPSHOT</version>
- </parent>
-
- <artifactId>clustered-durable-subscription</artifactId>
- <packaging>jar</packaging>
- <name>ActiveMQ Artemis JMS Clustered Durable Subscription Example</name>
-
- <properties>
- <activemq.basedir>${project.basedir}/../../../..</activemq.basedir>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-jms-client</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.apache.activemq</groupId>
- <artifactId>artemis-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>create0</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <clustered>true</clustered>
- <instance>${basedir}/target/server0</instance>
- <configuration>${basedir}/target/classes/activemq/server0</configuration>
- </configuration>
- </execution>
- <execution>
- <id>create1</id>
- <goals>
- <goal>create</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <clustered>true</clustered>
- <instance>${basedir}/target/server1</instance>
- <configuration>${basedir}/target/classes/activemq/server1</configuration>
- <portOffset>1</portOffset>
- </configuration>
- </execution>
- <execution>
- <id>start0</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <spawn>true</spawn>
- <location>${basedir}/target/server0</location>
- <testURI>tcp://localhost:61616</testURI>
- <args>
- <param>run</param>
- </args>
- <name>server0</name>
- </configuration>
- </execution>
- <execution>
- <id>start1</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <spawn>true</spawn>
- <location>${basedir}/target/server1</location>
- <testURI>tcp://localhost:61617</testURI>
- <args>
- <param>run</param>
- </args>
- <name>server1</name>
- </configuration>
- </execution>
- <execution>
- <id>runClient</id>
- <goals>
- <goal>runClient</goal>
- </goals>
- <configuration>
- <clientClass>org.apache.activemq.artemis.jms.example.ClusteredDurableSubscriptionExample
- </clientClass>
- </configuration>
- </execution>
- <execution>
- <id>stop0</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <location>${basedir}/target/server0</location>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- <execution>
- <id>stop1</id>
- <goals>
- <goal>cli</goal>
- </goals>
- <configuration>
- <ignore>${noServer}</ignore>
- <location>${basedir}/target/server1</location>
- <args>
- <param>stop</param>
- </args>
- </configuration>
- </execution>
- </executions>
- <dependencies>
- <dependency>
- <groupId>org.apache.activemq.examples.clustered</groupId>
- <artifactId>clustered-durable-subscription</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
- </plugin>
- </plugins>
- </build>
-
-</project>