public class ConsumerConnectionState extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
protected static org.slf4j.Logger |
logger |
| 构造器和说明 |
|---|
ConsumerConnectionState(ConsumerClient consumerClient) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected boolean |
doHandleAddConsumers(List<String> topics,
String app) |
protected boolean |
doHandleRemoveConsumers(List<String> topics,
String app) |
protected Set<String> |
getOrCreateAddedTopicSet(String app) |
void |
handleAddConsumers() |
void |
handleAddConsumers(Collection<String> topics,
String app) |
void |
handleRemoveConsumers() |
void |
handleRemoveConsumers(Collection<String> topics,
String app) |
public ConsumerConnectionState(ConsumerClient consumerClient)
public void handleAddConsumers()
public void handleAddConsumers(Collection<String> topics, String app)
public void handleRemoveConsumers(Collection<String> topics, String app)
public void handleRemoveConsumers()
Copyright © 2020 Joyqueue Community. All rights reserved.