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

Merge remote-tracking branch 'origin/master' into develop

Browse Source 
# Conflicts:
#	broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
#	common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
#	common/src/main/java/org/apache/rocketmq/common/MixAll.java
#	common/src/main/java/org/apache/rocketmq/common/message/Message.java
#	common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
#	pom.xml
#	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
#	store/src/main/java/org/apache/rocketmq/store/CommitLog.java
#	test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java
#	test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java
This commit is contained in:
yukon
2017-08-01 15:05:54 +08:00
parent 33a99a4148 d4149207e2
commit 9bb6eae4bd
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/src/test/java/org/apache/rocketmq/test/client/consumer/filter/SqlFilterIT.java
+3
View File
@@ -20,6 +20,9 @@ package org.apache.rocketmq.test.client.consumer.filter;
import org.apache.log4j.Logger;
import org.apache.rocketmq.client.consumer.MessageSelector;
import org.apache.rocketmq.test.base.BaseConf;
import org.apache.rocketmq.test.client.consumer.broadcast.BaseBroadCastIT;
import org.apache.rocketmq.test.client.consumer.broadcast.normal.NormalMsgTwoSameGroupConsumerIT;
import org.apache.rocketmq.test.client.rmq.RMQBroadCastConsumer;
import org.apache.rocketmq.test.client.rmq.RMQNormalProducer;
import org.apache.rocketmq.test.client.rmq.RMQSqlConsumer;
import org.apache.rocketmq.test.factory.ConsumerFactory;