public interface ListenerThread extends Runnable
Modifier and Type | Method and Description |
---|---|
default void |
complete(Map<String,CompletableFuture<Object>> requestsStore,
ResultMessage message,
org.slf4j.Logger logger) |
static ListenerThread |
get(TopicsConfig topicsConfig,
Map<String,CompletableFuture<Object>> requestsStore,
boolean isLocal,
Properties configuration) |
static ListenerThread |
get(TopicsConfig topicsConfig,
Map<String,CompletableFuture<Object>> requestsStore,
Properties configuration) |
static Properties |
getMergedConf(Properties configuration) |
void |
stop() |
void stop()
static ListenerThread get(TopicsConfig topicsConfig, Map<String,CompletableFuture<Object>> requestsStore, Properties configuration)
static ListenerThread get(TopicsConfig topicsConfig, Map<String,CompletableFuture<Object>> requestsStore, boolean isLocal, Properties configuration)
static Properties getMergedConf(Properties configuration)
default void complete(Map<String,CompletableFuture<Object>> requestsStore, ResultMessage message, org.slf4j.Logger logger)
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.