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 <clebertsuco...@apache.org> Authored: Thu Aug 13 00:11:56 2015 -0400 Committer: Clebert Suconic <clebertsuco...@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>
