opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 13:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix RMQAsyncSend Thread-safe bugs

Browse Source
This commit is contained in:
shesheng
2018-05-31 14:47:28 +08:00
committed by Zhanhui Li
parent a0a602fa85
commit 0ae3e4a002
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQAsyncSendProducer.java
+3 -1
View File
@@ -18,6 +18,7 @@
package org.apache.rocketmq.test.client.rmq;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.log4j.Logger;
@@ -38,7 +39,8 @@ public class RMQAsyncSendProducer extends AbstractMQProducer {
private String nsAddr = null;
private DefaultMQProducer producer = null;
private SendCallback sendCallback = null;
private List<org.apache.rocketmq.client.producer.SendResult> successSendResult = new ArrayList<org.apache.rocketmq.client.producer.SendResult>();
private List<org.apache.rocketmq.client.producer.SendResult> successSendResult = Collections
.synchronizedList(new ArrayList<org.apache.rocketmq.client.producer.SendResult>());
private AtomicInteger exceptionMsgCount = new AtomicInteger(
0);
private int msgSize = 0;
test/src/test/java/org/apache/rocketmq/test/client/producer/async/AsyncSendWithMessageQueueIT.java
+1 -1
View File
@@ -68,7 +68,7 @@ public class AsyncSendWithMessageQueueIT extends BaseConf {
producer.clearMsg();
consumer.clearMsg();
producer.getSuccessSendResult().clear();
mq = new MessageQueue(topic, broker2Name, queueId);
producer.asyncSend(msgSize, mq);
producer.waitForResponse(10 * 1000);