K
- key type to sendM
- message type to sendpublic final class TopicProducerImpl<K,M> extends Object implements TopicProducer<K,M>
Producer
.Constructor and Description |
---|
TopicProducerImpl(String updateBroker,
String topic,
boolean async) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
String |
getTopic() |
String |
getUpdateBroker() |
void |
send(K key,
M message) |
public String getUpdateBroker()
getUpdateBroker
in interface TopicProducer<K,M>
public String getTopic()
getTopic
in interface TopicProducer<K,M>
public void close()
close
in interface TopicProducer<K,M>
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2014–2015. All rights reserved.