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/12 05:47:45 UTC
[51/52] [abbrv] [partial] activemq-artemis git commit: This commit
has improvements on the examples including:
This commit has improvements on the examples including:
https://issues.apache.org/jira/browse/ARTEMIS-113 Better organize examples
https://issues.apache.org/jira/browse/ARTEMIS-114 Some openwire 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/21bf4406
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/21bf4406
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/21bf4406
Branch: refs/heads/master
Commit: 21bf440636155d2f7abdd2dfe94c4c9e5aefa08e
Parents: f48fc9b
Author: Clebert Suconic <cl...@apache.org>
Authored: Mon Aug 10 10:41:52 2015 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Tue Aug 11 23:44:43 2015 -0400
----------------------------------------------------------------------
.../activemq/artemis/cli/commands/Create.java | 22 +-
.../apache/activemq/artemis/utils/FileUtil.java | 47 ++
.../src/main/resources/README.html | 19 +-
.../artemis/maven/ArtemisAbstractPlugin.java | 10 +-
.../artemis/maven/ArtemisCLIPlugin.java | 8 +
.../artemis/maven/ArtemisClientPlugin.java | 8 +
.../artemis/maven/ArtemisCreatePlugin.java | 62 ++-
examples/README.md | 32 ++
.../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/pom.xml | 66 +++
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 0 -> 93885 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 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 +
.../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 ++++
examples/common/common.css | 47 ++
examples/common/config/logging.properties | 52 ++
examples/common/config/server.properties | 18 +
examples/common/prettify.css | 20 +
examples/common/prettify.js | 42 ++
examples/core/embedded-remote/pom.xml | 126 -----
examples/core/embedded-remote/readme.html | 104 ----
.../core/example/EmbeddedRemoteExample.java | 104 ----
.../artemis/core/example/EmbeddedServer.java | 68 ---
examples/core/embedded/pom.xml | 84 ----
examples/core/embedded/readme.html | 116 -----
.../artemis/core/example/EmbeddedExample.java | 112 -----
examples/core/perf/perf.properties | 38 --
examples/core/perf/pom.xml | 163 -------
.../activemq/artemis/core/example/PerfBase.java | 474 -------------------
.../artemis/core/example/PerfListener.java | 46 --
.../artemis/core/example/PerfParams.java | 257 ----------
.../artemis/core/example/PerfSender.java | 46 --
.../main/resources/activemq/server0/broker.xml | 69 ---
.../hornetq-configuration-messaging-lab.xml | 53 ---
examples/core/pom.xml | 53 ---
examples/core/vertx-connector/pom.xml | 189 --------
examples/core/vertx-connector/readme.html | 103 ----
.../artemis/core/example/ExampleVerticle.java | 54 ---
.../core/example/VertxConnectorExample.java | 105 ----
.../main/resources/activemq/server0/broker.xml | 81 ----
examples/jms/README.md | 32 --
examples/jms/aerogear/pom.xml | 134 ------
examples/jms/aerogear/readme.html | 157 ------
.../artemis/jms/example/AerogearExample.java | 77 ---
.../main/resources/activemq/server0/broker.xml | 77 ---
.../aerogear/src/main/resources/jndi.properties | 20 -
examples/jms/application-layer-failover/pom.xml | 102 ----
.../jms/application-layer-failover/readme.html | 169 -------
.../ApplicationLayerFailoverExample.java | 221 ---------
examples/jms/artemis-ra-rar/pom.xml | 101 ----
.../artemis-ra-rar/src/main/resources/ra.xml | 308 ------------
examples/jms/bridge/pom.xml | 176 -------
examples/jms/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/jms/browser/pom.xml | 119 -----
examples/jms/browser/readme.html | 40 --
.../jms/example/QueueBrowserExample.java | 103 ----
.../browser/src/main/resources/jndi.properties | 20 -
examples/jms/client-kickoff/pom.xml | 122 -----
examples/jms/client-kickoff/readme.html | 54 ---
.../jms/example/ClientKickoffExample.java | 107 -----
.../main/resources/activemq/server0/broker.xml | 47 --
.../src/main/resources/jndi.properties | 19 -
.../jms/client-side-failoverlistener/pom.xml | 109 -----
.../client-side-failoverlistener/readme.html | 37 --
.../ClientSideFailoverListerExample.java | 129 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/client-side-load-balancing/pom.xml | 205 --------
.../jms/client-side-load-balancing/readme.html | 49 --
.../example/ClientSideLoadBalancingExample.java | 138 ------
.../src/main/resources/jndi.properties | 20 -
.../jms/clustered-durable-subscription/pom.xml | 167 -------
.../clustered-durable-subscription/readme.html | 66 ---
.../ClusteredDurableSubscriptionExample.java | 132 ------
.../main/resources/activemq/server0/broker.xml | 96 ----
.../main/resources/activemq/server1/broker.xml | 96 ----
examples/jms/clustered-grouping/pom.xml | 203 --------
examples/jms/clustered-grouping/readme.html | 81 ----
.../jms/example/ClusteredGroupingExample.java | 154 ------
.../main/resources/activemq/server0/broker.xml | 105 ----
.../main/resources/activemq/server1/broker.xml | 102 ----
.../main/resources/activemq/server2/broker.xml | 102 ----
examples/jms/clustered-jgroups/pom.xml | 170 -------
examples/jms/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 ---
examples/jms/clustered-queue/pom.xml | 163 -------
examples/jms/clustered-queue/readme.html | 56 ---
.../jms/example/ClusteredQueueExample.java | 118 -----
.../main/resources/activemq/server0/broker.xml | 95 ----
.../main/resources/activemq/server1/broker.xml | 96 ----
examples/jms/clustered-static-discovery/pom.xml | 248 ----------
.../jms/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 ----
examples/jms/clustered-static-oneway/pom.xml | 207 --------
.../jms/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 ---
examples/jms/clustered-topic/pom.xml | 162 -------
examples/jms/clustered-topic/readme.html | 55 ---
.../jms/example/ClusteredTopicExample.java | 129 -----
.../main/resources/activemq/server0/broker.xml | 97 ----
.../main/resources/activemq/server1/broker.xml | 95 ----
.../jms/colocated-failover-scale-down/pom.xml | 103 ----
.../colocated-failover-scale-down/readme.html | 65 ---
.../ColocatedFailoverScaleDownExample.java | 141 ------
.../main/resources/activemq/server0/broker.xml | 129 -----
.../main/resources/activemq/server1/broker.xml | 127 -----
examples/jms/colocated-failover/pom.xml | 102 ----
examples/jms/colocated-failover/readme.html | 56 ---
.../jms/example/ColocatedFailoverExample.java | 148 ------
.../main/resources/activemq/server0/broker.xml | 115 -----
.../main/resources/activemq/server1/broker.xml | 114 -----
examples/jms/common/common.css | 47 --
examples/jms/common/config/logging.properties | 52 --
examples/jms/common/config/server.properties | 18 -
examples/jms/common/prettify.css | 20 -
examples/jms/common/prettify.js | 42 --
examples/jms/consumer-rate-limit/pom.xml | 118 -----
examples/jms/consumer-rate-limit/readme.html | 47 --
.../jms/example/ConsumerRateLimitExample.java | 116 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/dead-letter/pom.xml | 119 -----
examples/jms/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 -
examples/jms/delayed-redelivery/pom.xml | 119 -----
examples/jms/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/jms/divert/pom.xml | 168 -------
examples/jms/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 ---
examples/jms/durable-subscription/pom.xml | 119 -----
examples/jms/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 -
examples/jms/embedded-simple/pom.xml | 84 ----
examples/jms/embedded-simple/readme.html | 96 ----
.../artemis/jms/example/EmbeddedExample.java | 86 ----
.../src/main/resources/broker.xml | 52 --
examples/jms/embedded/pom.xml | 84 ----
examples/jms/embedded/readme.html | 38 --
.../artemis/jms/example/EmbeddedExample.java | 107 -----
examples/jms/expiry/pom.xml | 119 -----
examples/jms/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 -
examples/jms/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 -----
examples/jms/http-transport/pom.xml | 119 -----
examples/jms/http-transport/readme.html | 52 --
.../jms/example/HttpTransportExample.java | 82 ----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 61 ---
.../jms/instantiate-connection-factory/pom.xml | 120 -----
.../instantiate-connection-factory/readme.html | 49 --
.../InstantiateConnectionFactoryExample.java | 81 ----
examples/jms/interceptor/pom.xml | 120 -----
examples/jms/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 -
examples/jms/jms-auto-closeable/pom.xml | 115 -----
examples/jms/jms-auto-closeable/readme.html | 96 ----
.../jms/example/JMSAutoCloseableExample.java | 51 --
.../src/main/resources/jndi.properties | 20 -
examples/jms/jms-bridge/jms-bridge.png | Bin 93885 -> 0 bytes
examples/jms/jms-bridge/pom.xml | 168 -------
examples/jms/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 ---
examples/jms/jms-completion-listener/pom.xml | 119 -----
.../jms/jms-completion-listener/readme.html | 112 -----
.../example/JMSCompletionListenerExample.java | 85 ----
.../src/main/resources/jndi.properties | 20 -
examples/jms/jms-context/pom.xml | 118 -----
examples/jms/jms-context/readme.html | 35 --
.../artemis/jms/example/JMSContextExample.java | 51 --
examples/jms/jms-shared-consumer/pom.xml | 120 -----
examples/jms/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/jms/jmx/pom.xml | 127 -----
examples/jms/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 ---
.../jms/jmx/src/main/resources/jndi.properties | 20 -
examples/jms/large-message/pom.xml | 88 ----
examples/jms/large-message/readme.html | 200 --------
.../jms/example/LargeMessageExample.java | 200 --------
.../src/main/resources/jndi.properties | 20 -
examples/jms/last-value-queue/pom.xml | 118 -----
examples/jms/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 -
examples/jms/management-notifications/pom.xml | 118 -----
.../jms/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/jms/management/pom.xml | 118 -----
examples/jms/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 -
examples/jms/message-counters/pom.xml | 126 -----
examples/jms/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 -
examples/jms/message-group/pom.xml | 118 -----
examples/jms/message-group/readme.html | 152 ------
.../jms/example/MessageGroupExample.java | 122 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/message-group2/pom.xml | 118 -----
examples/jms/message-group2/readme.html | 161 -------
.../jms/example/MessageGroup2Example.java | 129 -----
examples/jms/message-priority/pom.xml | 118 -----
examples/jms/message-priority/readme.html | 159 -------
.../jms/example/MessagePriorityExample.java | 135 ------
examples/jms/multiple-failover-failback/pom.xml | 121 -----
.../MultipleFailoverFailbackExample.java | 142 ------
.../src/main/resources/jndi.properties | 20 -
examples/jms/multiple-failover/pom.xml | 121 -----
.../jms/example/MultipleFailoverExample.java | 142 ------
.../src/main/resources/jndi.properties | 20 -
examples/jms/no-consumer-buffering/pom.xml | 117 -----
examples/jms/no-consumer-buffering/readme.html | 205 --------
.../jms/example/NoConsumerBufferingExample.java | 110 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/non-transaction-failover/pom.xml | 109 -----
.../jms/non-transaction-failover/readme.html | 157 ------
.../example/NonTransactionFailoverExample.java | 128 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/paging/pom.xml | 118 -----
examples/jms/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/jms/perf/pom.xml | 160 -------
examples/jms/perf/readme.html | 39 --
.../activemq/artemis/jms/example/PerfBase.java | 400 ----------------
.../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 --
.../jms/perf/src/main/resources/jndi.properties | 20 -
.../jms/perf/src/main/resources/perf.properties | 30 --
examples/jms/pom.xml | 149 ------
examples/jms/pre-acknowledge/pom.xml | 118 -----
examples/jms/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 -
examples/jms/producer-rate-limit/pom.xml | 118 -----
examples/jms/producer-rate-limit/readme.html | 176 -------
.../jms/example/ProducerRateLimitExample.java | 106 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/proton-cpp/compile.sh | 18 -
examples/jms/proton-cpp/pom.xml | 122 -----
examples/jms/proton-cpp/readme.html | 120 -----
examples/jms/proton-cpp/src/main/cpp/hello.cpp | 72 ---
.../artemis/jms/example/ProtonCPPExample.java | 121 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/proton-j/pom.xml | 118 -----
examples/jms/proton-j/readme.html | 95 ----
.../artemis/jms/example/ProtonJExample.java | 64 ---
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 68 ---
examples/jms/proton-ruby/pom.xml | 67 ---
examples/jms/proton-ruby/readme.html | 51 --
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 65 ---
.../jms/proton-ruby/src/main/scripts/receive.rb | 75 ---
.../jms/proton-ruby/src/main/scripts/send.rb | 49 --
.../jms/queue-message-redistribution/pom.xml | 164 -------
.../queue-message-redistribution/readme.html | 61 ---
.../QueueMessageRedistributionExample.java | 147 ------
.../main/resources/activemq/server0/broker.xml | 106 -----
.../main/resources/activemq/server1/broker.xml | 107 -----
examples/jms/queue-requestor/pom.xml | 113 -----
examples/jms/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 -
examples/jms/queue-selector/pom.xml | 118 -----
examples/jms/queue-selector/readme.html | 52 --
.../jms/example/QueueSelectorExample.java | 143 ------
.../src/main/resources/jndi.properties | 20 -
examples/jms/queue/pom.xml | 118 -----
examples/jms/queue/readme.html | 38 --
.../artemis/jms/example/QueueExample.java | 84 ----
.../queue/src/main/resources/jndi.properties | 20 -
examples/jms/reattach-node/pom.xml | 120 -----
examples/jms/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 -
examples/jms/replicated-failback-static/pom.xml | 104 ----
.../jms/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 -
examples/jms/replicated-failback/pom.xml | 103 ----
examples/jms/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 -
.../jms/replicated-multiple-failover/pom.xml | 118 -----
.../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 -
.../jms/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/jms/request-reply/pom.xml | 121 -----
examples/jms/request-reply/readme.html | 180 -------
.../jms/example/RequestReplyExample.java | 202 --------
.../src/main/resources/jndi.properties | 20 -
examples/jms/rest/dup-send/README.txt | 41 --
examples/jms/rest/dup-send/pom.xml | 170 -------
.../jms/rest/dup-send/src/main/java/Order.java | 69 ---
.../rest/dup-send/src/main/java/PostOrder.java | 77 ---
.../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 ---
examples/jms/rest/javascript-chat/README.txt | 16 -
examples/jms/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 | 89 ----
examples/jms/rest/jms-to-rest/README.txt | 49 --
examples/jms/rest/jms-to-rest/pom.xml | 170 -------
examples/jms/rest/jms-to-rest/postOrder.py | 44 --
examples/jms/rest/jms-to-rest/receiveOrder.py | 68 ---
.../jms-to-rest/src/main/java/JmsHelper.java | 43 --
.../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/jms/rest/pom.xml | 45 --
examples/jms/rest/push/README.txt | 32 --
examples/jms/rest/push/pom.xml | 176 -------
.../jms/rest/push/src/main/java/JmsHelper.java | 41 --
examples/jms/rest/push/src/main/java/Order.java | 69 ---
.../jms/rest/push/src/main/java/PostOrder.java | 47 --
.../jms/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 -
.../jms/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 ---
examples/jms/scale-down/pom.xml | 105 ----
examples/jms/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 -----
examples/jms/scheduled-message/pom.xml | 123 -----
examples/jms/scheduled-message/readme.html | 134 ------
.../jms/example/ScheduledMessageExample.java | 94 ----
.../src/main/resources/jndi.properties | 20 -
examples/jms/security/pom.xml | 120 -----
examples/jms/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 -
examples/jms/send-acknowledgements/pom.xml | 113 -----
examples/jms/send-acknowledgements/readme.html | 140 ------
.../example/SendAcknowledgementsExample.java | 104 ----
.../src/main/resources/jndi.properties | 20 -
examples/jms/spring-integration/pom.xml | 82 ----
examples/jms/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/jms/ssl-enabled/pom.xml | 118 -----
examples/jms/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 -
examples/jms/static-selector/pom.xml | 117 -----
examples/jms/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 -
.../aerogear-chat/aerogear-chat.css | 102 ----
.../aerogear-chat/aerogear-chat.js | 116 -----
.../aerogear-chat/aerogear-index.html | 97 ----
.../aerogear-chat/aerogear.min.js | 19 -
.../jms/stomp-websockets/aerogear-chat/stomp.js | 392 ---------------
examples/jms/stomp-websockets/chat/chat.css | 118 -----
examples/jms/stomp-websockets/chat/chat.js | 72 ---
examples/jms/stomp-websockets/chat/index.html | 73 ---
examples/jms/stomp-websockets/chat/stomp.js | 389 ---------------
examples/jms/stomp-websockets/pom.xml | 118 -----
examples/jms/stomp-websockets/readme.html | 56 ---
.../jms/example/StompWebSocketExample.java | 74 ---
.../main/resources/activemq/server0/broker.xml | 64 ---
.../src/main/resources/jndi.properties | 20 -
examples/jms/stomp/pom.xml | 118 -----
examples/jms/stomp/readme.html | 38 --
.../artemis/jms/example/StompExample.java | 131 -----
.../activemq/server0/artemis-roles.properties | 17 -
.../activemq/server0/artemis-users.properties | 17 -
.../main/resources/activemq/server0/broker.xml | 64 ---
.../stomp/src/main/resources/jndi.properties | 20 -
examples/jms/stomp1.1/pom.xml | 118 -----
examples/jms/stomp1.1/readme.html | 38 --
.../artemis/jms/example/StompExample.java | 136 ------
.../main/resources/activemq/server0/broker.xml | 64 ---
.../stomp1.1/src/main/resources/jndi.properties | 20 -
examples/jms/stomp1.2/pom.xml | 118 -----
examples/jms/stomp1.2/readme.html | 38 --
.../artemis/jms/example/StompExample.java | 133 ------
.../main/resources/activemq/server0/broker.xml | 64 ---
.../stomp1.2/src/main/resources/jndi.properties | 20 -
examples/jms/stop-server-failover/pom.xml | 169 -------
examples/jms/stop-server-failover/readme.html | 44 --
.../jms/example/StopServerFailoverExample.java | 117 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/symmetric-cluster/pom.xml | 329 -------------
examples/jms/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 ----
examples/jms/temp-queue/pom.xml | 118 -----
examples/jms/temp-queue/readme.html | 40 --
.../jms/example/TemporaryQueueExample.java | 118 -----
.../main/resources/activemq/server0/broker.xml | 65 ---
.../src/main/resources/jndi.properties | 20 -
examples/jms/topic-hierarchies/pom.xml | 118 -----
examples/jms/topic-hierarchies/readme.html | 42 --
.../jms/example/TopicHierarchyExample.java | 121 -----
.../main/resources/activemq/server0/broker.xml | 71 ---
.../src/main/resources/jndi.properties | 19 -
examples/jms/topic-selector-example1/pom.xml | 118 -----
.../jms/topic-selector-example1/readme.html | 38 --
.../jms/example/TopicSelectorExample1.java | 145 ------
.../main/resources/activemq/server0/broker.xml | 60 ---
.../src/main/resources/jndi.properties | 20 -
examples/jms/topic-selector-example2/pom.xml | 118 -----
.../jms/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/jms/topic/pom.xml | 117 -----
examples/jms/topic/readme.html | 36 --
.../artemis/jms/example/TopicExample.java | 94 ----
.../main/resources/activemq/server0/broker.xml | 59 ---
.../topic/src/main/resources/jndi.properties | 20 -
examples/jms/transaction-failover/pom.xml | 104 ----
examples/jms/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/jms/transactional/pom.xml | 118 -----
examples/jms/transactional/readme.html | 40 --
.../jms/example/TransactionalExample.java | 126 -----
.../src/main/resources/jndi.properties | 20 -
examples/jms/xa-heuristic/pom.xml | 121 -----
examples/jms/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/jms/xa-receive/pom.xml | 118 -----
examples/jms/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/jms/xa-send/pom.xml | 118 -----
examples/jms/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/mqtt/README.md | 29 --
examples/mqtt/basic-pubsub/pom.xml | 104 ----
examples/mqtt/basic-pubsub/readme.html | 132 ------
.../mqtt/example/MQTTBasicPubSubExample.java | 63 ---
examples/mqtt/pom.xml | 57 ---
examples/perf/perf/pom.xml | 156 ++++++
examples/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/perf/pom.xml | 50 ++
examples/perf/soak/README | 85 ++++
examples/perf/soak/pom.xml | 162 +++++++
examples/perf/soak/server0/broker.xml | 49 ++
examples/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/pom.xml | 44 +-
examples/protocols/amqp/pom.xml | 64 +++
examples/protocols/amqp/proton-cpp/compile.sh | 18 +
examples/protocols/amqp/proton-cpp/pom.xml | 113 +++++
examples/protocols/amqp/proton-cpp/readme.html | 120 +++++
.../amqp/proton-cpp/src/main/cpp/hello.cpp | 72 +++
.../artemis/jms/example/ProtonCPPExample.java | 121 +++++
.../src/main/resources/jndi.properties | 20 +
examples/protocols/amqp/proton-j/pom.xml | 109 +++++
examples/protocols/amqp/proton-j/readme.html | 95 ++++
.../artemis/jms/example/ProtonJExample.java | 64 +++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 68 +++
examples/protocols/amqp/proton-ruby/pom.xml | 67 +++
examples/protocols/amqp/proton-ruby/readme.html | 51 ++
.../activemq/server0/artemis-roles.properties | 17 +
.../activemq/server0/artemis-users.properties | 17 +
.../main/resources/activemq/server0/broker.xml | 65 +++
.../proton-ruby/src/main/scripts/receive.rb | 75 +++
.../amqp/proton-ruby/src/main/scripts/send.rb | 49 ++
examples/protocols/mqtt/basic-pubsub/pom.xml | 105 ++++
.../protocols/mqtt/basic-pubsub/readme.html | 132 ++++++
.../mqtt/example/MQTTBasicPubSubExample.java | 61 +++
examples/protocols/mqtt/pom.xml | 54 +++
examples/protocols/openwire/chat/pom.xml | 201 ++++++++
examples/protocols/openwire/chat/readme.html | 53 +++
.../activemq/artemis/openwire/example/Chat.java | 223 +++++++++
.../artemis/openwire/example/Server.java | 46 ++
.../activemq/server0/artemis-roles.properties | 20 +
.../activemq/server0/artemis-users.properties | 20 +
examples/protocols/openwire/pom.xml | 57 +++
examples/protocols/pom.xml | 64 +++
examples/protocols/stomp/pom.xml | 66 +++
.../aerogear-chat/aerogear-chat.css | 102 ++++
.../aerogear-chat/aerogear-chat.js | 116 +++++
.../aerogear-chat/aerogear-index.html | 97 ++++
.../aerogear-chat/aerogear.min.js | 19 +
.../stomp-websockets/aerogear-chat/stomp.js | 392 +++++++++++++++
.../stomp/stomp-websockets/chat/chat.css | 118 +++++
.../stomp/stomp-websockets/chat/chat.js | 72 +++
.../stomp/stomp-websockets/chat/index.html | 73 +++
.../stomp/stomp-websockets/chat/stomp.js | 389 +++++++++++++++
.../protocols/stomp/stomp-websockets/pom.xml | 109 +++++
.../stomp/stomp-websockets/readme.html | 56 +++
.../jms/example/StompWebSocketExample.java | 74 +++
.../src/main/resources/jndi.properties | 20 +
examples/protocols/stomp/stomp/pom.xml | 109 +++++
examples/protocols/stomp/stomp/readme.html | 38 ++
.../artemis/jms/example/StompExample.java | 131 +++++
.../stomp/src/main/resources/jndi.properties | 20 +
examples/protocols/stomp/stomp1.1/pom.xml | 109 +++++
examples/protocols/stomp/stomp1.1/readme.html | 38 ++
.../artemis/jms/example/StompExample.java | 136 ++++++
.../stomp1.1/src/main/resources/jndi.properties | 20 +
examples/protocols/stomp/stomp1.2/pom.xml | 109 +++++
examples/protocols/stomp/stomp1.2/readme.html | 38 ++
.../artemis/jms/example/StompExample.java | 133 ++++++
.../stomp1.2/src/main/resources/jndi.properties | 20 +
examples/soak/normal/README | 85 ----
examples/soak/normal/pom.xml | 162 -------
examples/soak/normal/server0/broker.xml | 49 --
examples/soak/normal/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 --------
.../normal/src/main/resources/jndi.properties | 20 -
examples/soak/pom.xml | 49 --
pom.xml | 1 +
1165 files changed, 48194 insertions(+), 49818 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/Create.java
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/Create.java b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/Create.java
index 2063fc4..6262fd2 100644
--- a/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/Create.java
+++ b/artemis-cli/src/main/java/org/apache/activemq/artemis/cli/commands/Create.java
@@ -26,12 +26,8 @@ import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.io.StringWriter;
-import java.nio.file.Files;
-import java.nio.file.attribute.PosixFilePermission;
import java.text.DecimalFormat;
-import java.util.Arrays;
import java.util.HashMap;
-import java.util.HashSet;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -43,15 +39,7 @@ import org.apache.activemq.artemis.cli.commands.util.SyncCalculation;
import org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType;
import org.apache.activemq.artemis.jlibaio.LibaioContext;
import org.apache.activemq.artemis.jlibaio.LibaioFile;
-
-import static java.nio.file.attribute.PosixFilePermission.GROUP_EXECUTE;
-import static java.nio.file.attribute.PosixFilePermission.GROUP_READ;
-import static java.nio.file.attribute.PosixFilePermission.GROUP_WRITE;
-import static java.nio.file.attribute.PosixFilePermission.OTHERS_EXECUTE;
-import static java.nio.file.attribute.PosixFilePermission.OTHERS_READ;
-import static java.nio.file.attribute.PosixFilePermission.OWNER_EXECUTE;
-import static java.nio.file.attribute.PosixFilePermission.OWNER_READ;
-import static java.nio.file.attribute.PosixFilePermission.OWNER_WRITE;
+import org.apache.activemq.artemis.utils.FileUtil;
/**
* CLI action that creates a broker instance directory.
@@ -701,13 +689,7 @@ public class Create extends InputAbstract {
}
private void makeExec(String path) throws IOException {
- try {
- File file = new File(directory, path);
- Files.setPosixFilePermissions(file.toPath(), new HashSet<PosixFilePermission>(Arrays.asList(OWNER_READ, OWNER_WRITE, OWNER_EXECUTE, GROUP_READ, GROUP_WRITE, GROUP_EXECUTE, OTHERS_READ, OTHERS_EXECUTE)));
- }
- catch (Throwable ignore) {
- // Our best effort was not good enough :)
- }
+ FileUtil.makeExec(new File(directory, path));
}
private String[] getQueueList() {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/FileUtil.java
----------------------------------------------------------------------
diff --git a/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/FileUtil.java b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/FileUtil.java
new file mode 100644
index 0000000..9ec689c
--- /dev/null
+++ b/artemis-commons/src/main/java/org/apache/activemq/artemis/utils/FileUtil.java
@@ -0,0 +1,47 @@
+/**
+ * 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.utils;
+
+import java.io.File;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.attribute.PosixFilePermission;
+import java.util.Arrays;
+import java.util.HashSet;
+
+import static java.nio.file.attribute.PosixFilePermission.GROUP_EXECUTE;
+import static java.nio.file.attribute.PosixFilePermission.GROUP_READ;
+import static java.nio.file.attribute.PosixFilePermission.GROUP_WRITE;
+import static java.nio.file.attribute.PosixFilePermission.OTHERS_EXECUTE;
+import static java.nio.file.attribute.PosixFilePermission.OTHERS_READ;
+import static java.nio.file.attribute.PosixFilePermission.OWNER_EXECUTE;
+import static java.nio.file.attribute.PosixFilePermission.OWNER_READ;
+import static java.nio.file.attribute.PosixFilePermission.OWNER_WRITE;
+
+public class FileUtil {
+
+ public static void makeExec(File file) throws IOException {
+ try {
+ Files.setPosixFilePermissions(file.toPath(), new HashSet<PosixFilePermission>(Arrays.asList(OWNER_READ, OWNER_WRITE, OWNER_EXECUTE, GROUP_READ, GROUP_WRITE, GROUP_EXECUTE, OTHERS_READ, OTHERS_EXECUTE)));
+ }
+ catch (Throwable ignore) {
+ // Our best effort was not good enough :)
+ }
+ }
+
+}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-distribution/src/main/resources/README.html
----------------------------------------------------------------------
diff --git a/artemis-distribution/src/main/resources/README.html b/artemis-distribution/src/main/resources/README.html
index fe89886..15acea8 100644
--- a/artemis-distribution/src/main/resources/README.html
+++ b/artemis-distribution/src/main/resources/README.html
@@ -23,9 +23,9 @@ under the License.
<meta content="text/html; charset=ISO-8859-1"
http-equiv="content-type">
<title>Apache ActiveMQ Artemis README</title>
- <link rel="stylesheet" type="text/css" href="./examples/jms/common/common.css" />
- <link rel="stylesheet" type="text/css" href="./examples/jms/common/prettify.css" />
- <script type="text/javascript" src="./examples/jms/common/prettify.js"></script>
+ <link rel="stylesheet" type="text/css" href="./examples/common/common.css" />
+ <link rel="stylesheet" type="text/css" href="./examples/common/prettify.css" />
+ <script type="text/javascript" src="./examples/common/prettify.js"></script>
</head>
<body>
@@ -67,12 +67,12 @@ NAME
SYNOPSIS
artemis create [--allow-anonymous]
- [--cluster-password <clusterPassword>] [--cluster-user <clusterUser>]
- [--clustered] [--data <data>] [--encoding <encoding>] [--force]
- [--home <home>] [--host <host>] [--java-options <javaOptions>]
- [--password <password>] [--port-offset <portOffset>] [--replicated]
- [--role <role>] [--shared-store] [--silent] [--user <user>] [--]
- <directory>
+ [--cluster-password <clusterPassword>] [--cluster-user <clusterUser>]
+ [--clustered] [--data <data>] [--encoding <encoding>] [--force]
+ [--home <home>] [--host <host>] [--java-options <javaOptions>]
+ [--password <password>] [--port-offset <portOffset>] [--replicated]
+ [--role <role>] [--shared-store] [--silent] [--user <user>] [--]
+ <directory>
...
</PRE>
@@ -113,3 +113,4 @@ The examples are shipped inside the distribution folder under "examples"</br></b
The ActiveMQ Artemis 1.0.0 release notes can be found in the <a href="https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315920&version=12328953">Apache ActiveMQ Artemis project JIRA</a>.
+</body>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisAbstractPlugin.java
----------------------------------------------------------------------
diff --git a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisAbstractPlugin.java b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisAbstractPlugin.java
index f7647d3..7e9bf85 100644
--- a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisAbstractPlugin.java
+++ b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisAbstractPlugin.java
@@ -20,18 +20,12 @@ package org.apache.activemq.artemis.maven;
import org.apache.maven.plugin.AbstractMojo;
import org.apache.maven.plugin.MojoExecutionException;
import org.apache.maven.plugin.MojoFailureException;
-import org.apache.maven.plugins.annotations.Parameter;
public abstract class ArtemisAbstractPlugin extends AbstractMojo {
- /**
- * It will ignore executioni if ignore has been set to true. This is useful as a property from the build.
- */
- @Parameter(defaultValue = "")
- private boolean ignore;
public void execute() throws MojoExecutionException, MojoFailureException {
- if (ignore) {
+ if (isIgnore()) {
getLog().debug("******************************************************************************************************");
getLog().debug("Execution of " + getClass().getSimpleName() + " is being ignored as ignore has been set to true");
getLog().debug("******************************************************************************************************");
@@ -41,5 +35,7 @@ public abstract class ArtemisAbstractPlugin extends AbstractMojo {
}
}
+ protected abstract boolean isIgnore();
+
protected abstract void doExecute() throws MojoExecutionException, MojoFailureException;
}
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCLIPlugin.java
----------------------------------------------------------------------
diff --git a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCLIPlugin.java b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCLIPlugin.java
index 447a570..2424d26 100644
--- a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCLIPlugin.java
+++ b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCLIPlugin.java
@@ -37,6 +37,9 @@ public class ArtemisCLIPlugin extends ArtemisAbstractPlugin {
private PluginDescriptor descriptor;
+ @Parameter(defaultValue = "${noServer}")
+ boolean ignore;
+
@Parameter(defaultValue = "server")
String name;
@@ -91,6 +94,11 @@ public class ArtemisCLIPlugin extends ArtemisAbstractPlugin {
}
+ protected boolean isIgnore() {
+ return ignore;
+ }
+
+
@Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
// This is to avoid the Run issuing a kill at any point
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisClientPlugin.java
----------------------------------------------------------------------
diff --git a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisClientPlugin.java b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisClientPlugin.java
index be3a19b..6023cc1 100644
--- a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisClientPlugin.java
+++ b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisClientPlugin.java
@@ -37,12 +37,20 @@ public class ArtemisClientPlugin extends ArtemisAbstractPlugin {
@Parameter
String[] args;
+ @Parameter(defaultValue = "${noClient}")
+ boolean ignore;
+
/**
* @parameter
*/
private Properties systemProperties;
@Override
+ protected boolean isIgnore() {
+ return ignore;
+ }
+
+ @Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
try {
if (systemProperties != null && !systemProperties.isEmpty()) {
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/21bf4406/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCreatePlugin.java
----------------------------------------------------------------------
diff --git a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCreatePlugin.java b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCreatePlugin.java
index e0db714..acb9466 100644
--- a/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCreatePlugin.java
+++ b/artemis-maven-plugin/src/main/java/org/apache/activemq/artemis/maven/ArtemisCreatePlugin.java
@@ -17,7 +17,9 @@
package org.apache.activemq.artemis.maven;
import java.io.File;
+import java.io.FileOutputStream;
import java.io.IOException;
+import java.io.PrintStream;
import java.nio.file.Files;
import java.nio.file.LinkOption;
import java.nio.file.Path;
@@ -28,6 +30,7 @@ import java.util.Map;
import java.util.Set;
import org.apache.activemq.artemis.cli.Artemis;
+import org.apache.activemq.artemis.utils.FileUtil;
import org.apache.maven.plugin.MojoExecutionException;
import org.apache.maven.plugin.MojoFailureException;
import org.apache.maven.plugin.descriptor.PluginDescriptor;
@@ -140,6 +143,9 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
@Parameter(defaultValue = "${localRepository}")
private org.apache.maven.artifact.repository.ArtifactRepository localRepository;
+ @Parameter(defaultValue = "${noServer}")
+ boolean ignore;
+
/**
* Validate if the directory is a artemis.home *
*
@@ -171,10 +177,12 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
}
@Override
+ protected boolean isIgnore() {
+ return ignore;
+ }
+
+ @Override
protected void doExecute() throws MojoExecutionException, MojoFailureException {
- if (System.getProperty("bypassAddress") != null) {
- System.out.println("BYPASSADDRESS");
- }
getLog().info("Local " + localRepository);
MavenProject project = (MavenProject) getPluginContext().get("project");
@@ -251,6 +259,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
getLog().debug("***** Server created at " + instance + " with home=" + home + " *****");
+ File commandLine = new File(instance.getParentFile(), "create-" + instance.getName() + ".sh");
+ FileOutputStream outputStream;
+ try {
+ outputStream = new FileOutputStream(commandLine);
+ }
+ catch (Exception e) {
+ e.printStackTrace();
+ throw new MojoExecutionException(e.getMessage(), e);
+ }
+
+ PrintStream commandLineStream = new PrintStream(outputStream);
+ commandLineStream.println("# These are the commands used to create " + instance.getName());
+ commandLineStream.println(getCommandline(listCommands));
+
try {
Artemis.execute(home, null, listCommands);
@@ -265,12 +287,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
Path target = instance.toPath().resolve("etc").resolve(file);
getLog().debug("Replacing " + file + " into " + target);
- Files.copy(configuration.toPath().resolve(file), target, StandardCopyOption.REPLACE_EXISTING);
+ Path originalFile = configuration.toPath().resolve(file);
+ Files.copy(originalFile, target, StandardCopyOption.REPLACE_EXISTING);
+
+ commandLineStream.println("");
+ commandLineStream.println("# replacing " + originalFile.getFileName() + " on the default configuration");
+ commandLineStream.println("cp " + originalFile + " " + target);
}
}
}
if (libList != null) {
+ commandLineStream.println();
+ commandLineStream.println("# This is a list of files that need to be installed under ./lib.");
+ commandLineStream.println("# We are copying them from your maven lib home");
for (int i = 0; i < libList.length; i++) {
String[] splitString = libList[i].split(":");
@@ -302,11 +332,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
getLog().debug("Artifact:: " + artifact + " file = " + artifactFile);
- copyToLib(artifactFile);
+ copyToLib(artifactFile, commandLineStream);
}
}
+ commandLineStream.close();
+
+ FileUtil.makeExec(commandLine);
+
+ getLog().info("###################################################################################################");
+ getLog().info(commandLine.getName() + " created with commands to reproduce " + instance.getName());
+ getLog().info("under " + commandLine.getParent());
+ getLog().info("###################################################################################################");
+
}
catch (Exception e) {
getLog().error(e);
@@ -314,9 +353,20 @@ public class ArtemisCreatePlugin extends ArtemisAbstractPlugin {
}
}
- private void copyToLib(File projectLib) throws IOException {
+ private String getCommandline(ArrayList<String> listCommands) {
+ StringBuffer buffer = new StringBuffer();
+ buffer.append(home.getAbsolutePath() + "/bin/artemis ");
+ for (String string : listCommands) {
+ buffer.append(string + " ");
+ }
+ return buffer.toString();
+ }
+
+ private void copyToLib(File projectLib, PrintStream commandLineStream) throws IOException {
Path target = instance.toPath().resolve("lib").resolve(projectLib.getName());
target.toFile().mkdirs();
+
+ commandLineStream.println("cp " + projectLib.getAbsolutePath() + " " + target);
getLog().debug("Copying " + projectLib.getName() + " as " + target.toFile().getAbsolutePath());
Files.copy(projectLib.toPath(), target, StandardCopyOption.REPLACE_EXISTING);
}