Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing TransactionFailoverExample 

The TransactionFailoverExample IDs are not really unique if the journal is not cleaned up
This commit will make the IDs to use an UUID so the ID will always be unique even if you reuse the journal
This commit is contained in:
Clebert Suconic 2015-02-23 16:19:00 -05:00
parent 6612320792
commit 0ff13d0cf0
2 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
examples/jms/replicated-transaction-failover/src/main/java/org/apache/activemq/jms/example/ReplicatedTransactionFailoverExample.java
View File

@ -37,6 +37,13 @@ import org.apache.activemq.common.example.ActiveMQExample;
*/ */
public class ReplicatedTransactionFailoverExample extends ActiveMQExample public class ReplicatedTransactionFailoverExample extends ActiveMQExample
{ {
// You need to guarantee uniqueIDs when using duplicate detection
// It needs to be unique even after a restart
// as these IDs are stored on the journal for control
// We recommend some sort of UUID, but for this example the Current Time as string would be enough
String uniqueID = Long.toString(System.currentTimeMillis());
public static void main(final String[] args) public static void main(final String[] args)
{ {
new ReplicatedTransactionFailoverExample().run(args); new ReplicatedTransactionFailoverExample().run(args);
@ -146,7 +153,7 @@ public class ReplicatedTransactionFailoverExample extends ActiveMQExample
// We set the duplicate detection header - so the server will ignore the same message // We set the duplicate detection header - so the server will ignore the same message
// if sent again after failover // if sent again after failover
message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), "uniqueid" + i); message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), uniqueID + i);
producer.send(message); producer.send(message);
@ -169,7 +176,7 @@ public class ReplicatedTransactionFailoverExample extends ActiveMQExample
// We set the duplicate detection header - so the server will ignore the same message // We set the duplicate detection header - so the server will ignore the same message
// if sent again after failover // if sent again after failover
message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), "uniqueid" + i); message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), uniqueID + i);
producer.send(message); producer.send(message);

16
examples/jms/transaction-failover/src/main/java/org/apache/activemq/jms/example/TransactionFailoverExample.java
View File

@ -37,11 +37,19 @@ import org.apache.activemq.common.example.ActiveMQExample;
*/ */
public class TransactionFailoverExample extends ActiveMQExample public class TransactionFailoverExample extends ActiveMQExample
{ {
public static void main(final String[] args) public static void main(final String[] args)
{ {
new TransactionFailoverExample().run(args); new TransactionFailoverExample().run(args);
} }
// You need to guarantee uniqueIDs when using duplicate detection
// It needs to be unique even after a restart
// as these IDs are stored on the journal for control
// We recommend some sort of UUID, but for this example the Current Time as string would be enough
String uniqueID = Long.toString(System.currentTimeMillis());
@Override @Override
public boolean runExample() throws Exception public boolean runExample() throws Exception
{ {
@ -138,15 +146,13 @@ public class TransactionFailoverExample extends ActiveMQExample
final int numMessages, final int numMessages,
final boolean killServer) throws Exception final boolean killServer) throws Exception
{ {
// We send half of messages // We send half of messages
for (int i = 0; i < numMessages / 2; i++) for (int i = 0; i < numMessages / 2; i++)
{ {
TextMessage message = session.createTextMessage("This is text message " + i); TextMessage message = session.createTextMessage("This is text message " + i);
// We set the duplicate detection header - so the server will ignore the same message message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), uniqueID + i);
// if sent again after failover
message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), "uniqueid" + i);
producer.send(message); producer.send(message);
@ -169,7 +175,7 @@ public class TransactionFailoverExample extends ActiveMQExample
// We set the duplicate detection header - so the server will ignore the same message // We set the duplicate detection header - so the server will ignore the same message
// if sent again after failover // if sent again after failover
message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), "uniqueid" + i); message.setStringProperty(Message.HDR_DUPLICATE_DETECTION_ID.toString(), uniqueID + i);
producer.send(message); producer.send(message);