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 <[email protected]> Authored: Mon Aug 10 10:41:52 2015 -0400 Committer: Clebert Suconic <[email protected]> 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); }
