[hornetq-commits] JBoss hornetq SVN: r8493 - in trunk: examples/jms/message-group and 2 other directories.

do-not-reply at jboss.org do-not-reply at jboss.org
Wed Dec 2 04:47:39 EST 2009


Author: ataylor
Date: 2009-12-02 04:47:39 -0500 (Wed, 02 Dec 2009)
New Revision: 8493

Modified:
   trunk/docs/user-manual/en/message-grouping.xml
   trunk/examples/jms/message-group/readme.html
   trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java
   trunk/tests/src/org/hornetq/tests/integration/jms/bridge/JMSBridgeTest.java
Log:
removed JMSXGroupSeq references

Modified: trunk/docs/user-manual/en/message-grouping.xml
===================================================================
--- trunk/docs/user-manual/en/message-grouping.xml	2009-12-02 09:45:17 UTC (rev 8492)
+++ trunk/docs/user-manual/en/message-grouping.xml	2009-12-02 09:47:39 UTC (rev 8493)
@@ -44,19 +44,15 @@
       <title>Using JMS</title>
       <para>The property name used to identify the message group is <literal
          >JMSXGroupID</literal>.</para>
-      <para>Within the same group, messages can also set a <literal>JMSXGroupSeq</literal>
-         <literal>int</literal> property (starting at 1).</para>
       <programlisting>
  // send 2 messages in the same group to ensure the same
  // consumer will receive both
  Message message = ...
  message.setStringProperty("JMSXGroupID", "Group-0");
- message.setIntProperty("JMSXGroupSeq", 1);
  producer.send(message);
 
  message = ...
  message.setStringProperty("JMSXGroupID", "Group-0");
- message.setIntProperty("JMSXGroupSeq", 2);
  producer.send(message);          
        </programlisting>
       <para>Alternatively, you can set <literal>autogroup</literal> to true on the <literal

Modified: trunk/examples/jms/message-group/readme.html
===================================================================
--- trunk/examples/jms/message-group/readme.html	2009-12-02 09:45:17 UTC (rev 8492)
+++ trunk/examples/jms/message-group/readme.html	2009-12-02 09:47:39 UTC (rev 8493)
@@ -79,7 +79,6 @@
          {
             groupMessages[i] = session.createTextMessage("Group-0 message " + i);
             groupMessages[i].setStringProperty(HornetQMessage.JMSXGROUPID, "Group-0");
-            groupMessages[i].setIntProperty("JMSXGroupSeq", i + 1);
             producer.send(groupMessages[i]);
             System.out.println("Sent message: " + groupMessages[i].getText());
          }

Modified: trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java
===================================================================
--- trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java	2009-12-02 09:45:17 UTC (rev 8492)
+++ trunk/examples/jms/message-group/src/org/hornetq/jms/example/MessageGroupExample.java	2009-12-02 09:47:39 UTC (rev 8493)
@@ -82,7 +82,6 @@
          {
             groupMessages[i] = session.createTextMessage("Group-0 message " + i);
             groupMessages[i].setStringProperty(HornetQMessage.JMSXGROUPID, "Group-0");
-            groupMessages[i].setIntProperty("JMSXGroupSeq", i + 1);
             producer.send(groupMessages[i]);
             System.out.println("Sent message: " + groupMessages[i].getText());
          }
@@ -136,10 +135,9 @@
          try
          {
             TextMessage msg = (TextMessage)message;
-            System.out.format("Message: [%s] received by %s, (%s in the group)\n",
+            System.out.format("Message: [%s] received by %s\n",
                               msg.getText(),
-                              name,
-                              msg.getIntProperty("JMSXGroupSeq"));
+                              name);
             messageReceiverMap.put(msg.getText(), name);
          }
          catch (JMSException e)

Modified: trunk/tests/src/org/hornetq/tests/integration/jms/bridge/JMSBridgeTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/jms/bridge/JMSBridgeTest.java	2009-12-02 09:45:17 UTC (rev 8492)
+++ trunk/tests/src/org/hornetq/tests/integration/jms/bridge/JMSBridgeTest.java	2009-12-02 09:47:39 UTC (rev 8493)
@@ -772,7 +772,6 @@
             //We add some JMSX ones too
             
             tm.setStringProperty("JMSXGroupID", "mygroup543");
-            tm.setIntProperty("JMSXGroupSeq", 777);
             
             prod.send(tm);
             
@@ -802,7 +801,6 @@
             assertEquals(23, tm.getIntProperty("Sausages"));
             
             assertEquals("mygroup543", tm.getStringProperty("JMSXGroupID"));
-            assertEquals(777, tm.getIntProperty("JMSXGroupSeq"));
             
             if (on)
             {            
@@ -847,8 +845,7 @@
 	            assertTrue(tm.getBooleanProperty("cheese"));
 	            assertEquals(23, tm.getIntProperty("Sausages"));
 	            
-	            assertEquals("mygroup543", tm.getStringProperty("JMSXGroupID"));
-	            assertEquals(777, tm.getIntProperty("JMSXGroupSeq"));            
+	            assertEquals("mygroup543", tm.getStringProperty("JMSXGroupID")); 
 	            
 	            String header = tm.getStringProperty(HornetQMessage.JBOSS_MESSAGING_BRIDGE_MESSAGE_ID_LIST);
 	            



More information about the hornetq-commits mailing list