public class LocalListenerThread extends Object implements ListenerThread
Constructor and Description |
---|
LocalListenerThread(TopicsConfig topicsConfig) |
Modifier and Type | Method and Description |
---|---|
void |
init(Map<String,CompletableFuture<Object>> requestsStore) |
void |
run() |
void |
stop() |
public LocalListenerThread(TopicsConfig topicsConfig)
public void init(Map<String,CompletableFuture<Object>> requestsStore)
init
in interface ListenerThread
public void stop()
stop
in interface ListenerThread
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.