public class KafkaListenerThread extends Object implements ListenerThread
Constructor and Description |
---|
KafkaListenerThread(Properties configuration,
TopicsConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
complete(Map<String,CompletableFuture<Object>> requestsStore,
ResultMessage message,
org.slf4j.Logger logger) |
void |
init(Map<String,CompletableFuture<Object>> requestsStore) |
void |
run() |
void |
stop() |
public KafkaListenerThread(Properties configuration, TopicsConfig config)
public void init(Map<String,CompletableFuture<Object>> requestsStore)
init
in interface ListenerThread
public void complete(Map<String,CompletableFuture<Object>> requestsStore, ResultMessage message, org.slf4j.Logger logger)
public void stop()
stop
in interface ListenerThread
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.