public class InlineDmaapTopicSink extends InlineBusTopicSink implements DmaapTopicSink
Topic.CommInfrastructure
Modifier and Type | Field and Description |
---|---|
protected static org.openecomp.policy.common.logging.flexlogger.Logger |
logger |
protected String |
password |
protected String |
userName |
alive, locked, networkLogger, partitionId, publisher
apiKey, apiSecret, recentEvents, servers, topic
factory
DEFAULT_LOG_SEND_FAILURES_AFTER
NETWORK_LOGGER
Constructor and Description |
---|
InlineDmaapTopicSink(List<String> servers,
String topic,
String apiKey,
String apiSecret,
String userName,
String password,
String partitionKey) |
Modifier and Type | Method and Description |
---|---|
Topic.CommInfrastructure |
getTopicCommInfrastructure()
gets the communication infrastructure type
|
void |
init()
Initialize the Bus publisher
|
String |
toString() |
getPartitionKey, isAlive, isLocked, lock, send, setPartitionKey, shutdown, start, stop, unlock
getApiKey, getApiSecret, getRecentEvents, getServers, getTopic
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getPartitionKey, setPartitionKey
getApiKey, getApiSecret
getRecentEvents, getServers, getTopic
protected static org.openecomp.policy.common.logging.flexlogger.Logger logger
protected final String userName
protected final String password
public InlineDmaapTopicSink(List<String> servers, String topic, String apiKey, String apiSecret, String userName, String password, String partitionKey) throws IllegalArgumentException
IllegalArgumentException
public void init()
InlineBusTopicSink
init
in class InlineBusTopicSink
public Topic.CommInfrastructure getTopicCommInfrastructure()
getTopicCommInfrastructure
in interface Topic
getTopicCommInfrastructure
in class InlineBusTopicSink
public String toString()
toString
in class BusTopicBase
Copyright © 2018. All rights reserved.