2024-10-08 09:38:54 +08:00
|
|
|
|
/**
|
2025-03-04 10:42:17 +08:00
|
|
|
|
* 开源代码,仅供学习和交流研究使用,商用请联系三丙
|
|
|
|
|
|
* 微信:mohan_88888
|
|
|
|
|
|
* 抖音:程序员三丙
|
|
|
|
|
|
* 付费课程知识星球:https://t.zsxq.com/aKtXo
|
2024-10-08 09:38:54 +08:00
|
|
|
|
*/
|
|
|
|
|
|
package sanbing.jcpp.infrastructure.queue;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import sanbing.jcpp.infrastructure.queue.common.TopicPartitionInfo;
|
|
|
|
|
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
import java.util.Set;
|
|
|
|
|
|
|
|
|
|
|
|
public interface QueueConsumer<T extends QueueMsg> {
|
|
|
|
|
|
|
|
|
|
|
|
String getTopic();
|
|
|
|
|
|
|
|
|
|
|
|
void subscribe();
|
|
|
|
|
|
|
|
|
|
|
|
void subscribe(Set<TopicPartitionInfo> partitions);
|
|
|
|
|
|
|
|
|
|
|
|
void stop();
|
|
|
|
|
|
|
|
|
|
|
|
void unsubscribe();
|
|
|
|
|
|
|
|
|
|
|
|
List<T> poll(long durationInMillis);
|
|
|
|
|
|
|
|
|
|
|
|
void commit();
|
|
|
|
|
|
|
|
|
|
|
|
boolean isStopped();
|
|
|
|
|
|
|
|
|
|
|
|
List<String> getFullTopicNames();
|
|
|
|
|
|
|
|
|
|
|
|
}
|