Package | Description |
---|---|
org.kie.remote | |
org.kie.remote.impl | |
org.kie.remote.impl.consumer |
Modifier and Type | Method and Description |
---|---|
static TopicsConfig |
TopicsConfig.anTopicsConfig() |
TopicsConfig |
TopicsConfig.build() |
static TopicsConfig |
TopicsConfig.getDefaultTopicsConfig() |
TopicsConfig |
TopicsConfig.withEventsTopicName(String eventsTopicName) |
TopicsConfig |
TopicsConfig.withKieSessionInfosTopicName(String kieSessionInfosTopicName) |
Modifier and Type | Method and Description |
---|---|
static RemoteStreamingKieSession |
RemoteStreamingKieSession.create(Properties configuration,
TopicsConfig envConfig) |
static RemoteKieSession |
RemoteKieSession.create(Properties configuration,
TopicsConfig envConfig) |
Modifier and Type | Field and Description |
---|---|
protected TopicsConfig |
AbstractRemoteEntryPoint.topicsConfig |
Constructor and Description |
---|
AbstractRemoteEntryPoint(Sender sender,
String entryPoint,
TopicsConfig topicsConfig) |
RemoteEntryPointImpl(Sender sender,
String entryPoint,
TopicsConfig topicsConfig,
Listener listener) |
RemoteEntryPointImpl(Sender sender,
String entryPoint,
TopicsConfig topicsConfig,
RemoteStatefulSessionImpl delegate) |
RemoteKieSessionImpl(Properties configuration,
TopicsConfig envConfig) |
RemoteStatefulSessionImpl(Sender sender,
Listener listener,
TopicsConfig topicsConfig) |
RemoteStreamingEntryPointImpl(Sender sender,
String entryPoint,
TopicsConfig topicsConfig,
Listener listener) |
RemoteStreamingEntryPointImpl(Sender sender,
String entryPoint,
TopicsConfig topicsConfig,
RemoteStatefulSessionImpl delegate) |
RemoteStreamingKieSessionImpl(Properties configuration,
TopicsConfig envConfig) |
Modifier and Type | Method and Description |
---|---|
static ListenerThread |
ListenerThread.get(TopicsConfig topicsConfig,
Map<String,CompletableFuture<Object>> requestsStore,
boolean isLocal,
Properties configuration) |
static ListenerThread |
ListenerThread.get(TopicsConfig topicsConfig,
Map<String,CompletableFuture<Object>> requestsStore,
Properties configuration) |
Constructor and Description |
---|
KafkaListenerThread(Properties configuration,
TopicsConfig config,
Map<String,CompletableFuture<Object>> requestsStore) |
LocalListenerThread(TopicsConfig topicsConfig,
Map<String,CompletableFuture<Object>> requestsStore) |
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.