You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2016/08/10 12:27:09 UTC
[1/2] activemq-artemis git commit: [ARTEMIS-675] incorrect commentary
in examples
Repository: activemq-artemis
Updated Branches:
refs/heads/master d108d87cb -> ff18527ab
[ARTEMIS-675] incorrect commentary in 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/b94fb67a
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/b94fb67a
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/b94fb67a
Branch: refs/heads/master
Commit: b94fb67a922ac475338df82d62ec456bfc5d70ba
Parents: d108d87
Author: bayern39 <mc...@redhat.com>
Authored: Wed Aug 10 17:28:48 2016 +0800
Committer: bayern39 <mc...@redhat.com>
Committed: Wed Aug 10 17:33:22 2016 +0800
----------------------------------------------------------------------
.../jms/example/StaticClusteredQueueExample.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/b94fb67a/examples/features/clustered/clustered-static-discovery/src/main/java/org/apache/activemq/artemis/jms/example/StaticClusteredQueueExample.java
----------------------------------------------------------------------
diff --git a/examples/features/clustered/clustered-static-discovery/src/main/java/org/apache/activemq/artemis/jms/example/StaticClusteredQueueExample.java b/examples/features/clustered/clustered-static-discovery/src/main/java/org/apache/activemq/artemis/jms/example/StaticClusteredQueueExample.java
index 453fafc..170d1d3 100644
--- a/examples/features/clustered/clustered-static-discovery/src/main/java/org/apache/activemq/artemis/jms/example/StaticClusteredQueueExample.java
+++ b/examples/features/clustered/clustered-static-discovery/src/main/java/org/apache/activemq/artemis/jms/example/StaticClusteredQueueExample.java
@@ -63,10 +63,10 @@ public class StaticClusteredQueueExample {
// Step 7. We create a JMS Connection connection1 which is a connection to server 1
connection1 = cf0.createConnection();
- // Step 6. We create a JMS Connection connection0 which is a connection to server 0
+ // Step 6. We create a JMS Connection connection0 which is a connection to server 2
connection2 = cf0.createConnection();
- // Step 7. We create a JMS Connection connection1 which is a connection to server 1
+ // Step 7. We create a JMS Connection connection1 which is a connection to server 3
connection3 = cf0.createConnection();
// Step 8. We create a JMS Session on server 0
@@ -75,10 +75,10 @@ public class StaticClusteredQueueExample {
// Step 9. We create a JMS Session on server 1
Session session1 = connection1.createSession(false, Session.AUTO_ACKNOWLEDGE);
- // Step 8. We create a JMS Session on server 0
+ // Step 8. We create a JMS Session on server 2
Session session2 = connection2.createSession(false, Session.AUTO_ACKNOWLEDGE);
- // Step 9. We create a JMS Session on server 1
+ // Step 9. We create a JMS Session on server 3
Session session3 = connection3.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Step 10. We start the connections to ensure delivery occurs on them
@@ -90,7 +90,7 @@ public class StaticClusteredQueueExample {
connection3.start();
- // Step 11. We create JMS MessageConsumer objects on server 0 and server 1
+ // Step 11. We create JMS MessageConsumer objects on server 0 server 1 server 2 server 3
MessageConsumer consumer0 = session0.createConsumer(queue);
MessageConsumer consumer1 = session1.createConsumer(queue);
@@ -104,7 +104,7 @@ public class StaticClusteredQueueExample {
// Step 12. We create a JMS MessageProducer object on server 3
MessageProducer producer = session3.createProducer(queue);
- // Step 13. We send some messages to server 0
+ // Step 13. We send some messages to server 3
final int numMessages = 20;
@@ -116,7 +116,7 @@ public class StaticClusteredQueueExample {
System.out.println("Sent message: " + message.getText());
}
Thread.sleep(2000);
- // Step 14. We now consume those messages on *both* server 0 and server 1.
+ // Step 14. We now consume those messages on server 0 server 1 server 2 server 3
// We note the messages have been distributed between servers in a round robin fashion
// JMS Queues implement point-to-point message where each message is only ever consumed by a
// maximum of one consumer
[2/2] activemq-artemis git commit: This closes #713
Posted by ma...@apache.org.
This closes #713
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/ff18527a
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/ff18527a
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/ff18527a
Branch: refs/heads/master
Commit: ff18527ab009e550bce6ad64f366e2b1cf1e6295
Parents: d108d87 b94fb67
Author: Martyn Taylor <mt...@redhat.com>
Authored: Wed Aug 10 13:26:50 2016 +0100
Committer: Martyn Taylor <mt...@redhat.com>
Committed: Wed Aug 10 13:26:50 2016 +0100
----------------------------------------------------------------------
.../jms/example/StaticClusteredQueueExample.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------