广播消息重置消费进度时，需要设置instacneName

zhouheming · Dec 2, 2013 · ef8a592 · ef8a592
1 parent bfad470
commit ef8a592
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/MQHelper.java b/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/MQHelper.java
@@ -46,12 +46,14 @@ public class MQHelper {
      */
     public static void resetOffsetByTimestamp(//
             final MessageModel messageModel,//
+            final String instanceName,//
             final String consumerGroup, //
             final String topic, //
             final long timestamp) throws Exception {
         final Logger log = ClientLogger.getLog();
 
         DefaultMQPullConsumer consumer = new DefaultMQPullConsumer(consumerGroup);
+        consumer.setInstanceName(instanceName);
         consumer.setMessageModel(messageModel);
         consumer.start();
 
@@ -81,4 +83,13 @@ public static void resetOffsetByTimestamp(//
             consumer.shutdown();
         }
     }
+
+
+    public static void resetOffsetByTimestamp(//
+            final MessageModel messageModel,//
+            final String consumerGroup, //
+            final String topic, //
+            final long timestamp) throws Exception {
+        resetOffsetByTimestamp(messageModel, "DEFAULT", consumerGroup, topic, timestamp);
+    }
 }