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);