public class ProducerConnectionState extends Object
| 限定符和类型 | 字段和说明 |
|---|---|
protected static org.slf4j.Logger |
logger |
| 构造器和说明 |
|---|
ProducerConnectionState(ProducerClient producerClient) |
| 限定符和类型 | 方法和说明 |
|---|---|
protected boolean |
doHandleAddProducers(List<String> topics,
String app) |
protected boolean |
doHandleRemoveProducers(List<String> topics,
String app) |
protected Set<String> |
getOrCreateAddedTopicSet(String app) |
void |
handleAddProducers() |
void |
handleAddProducers(Collection<String> topics,
String app) |
void |
handleRemoveProducers() |
void |
handleRemoveProducers(Collection<String> topics,
String app) |
public ProducerConnectionState(ProducerClient producerClient)
public void handleAddProducers()
public void handleAddProducers(Collection<String> topics, String app)
public void handleRemoveProducers(Collection<String> topics, String app)
public void handleRemoveProducers()
Copyright © 2020 Joyqueue Community. All rights reserved.