Package | Description |
---|---|
org.kie.remote | |
org.kie.remote.impl | |
org.kie.remote.impl.consumer | |
org.kie.remote.util |
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 | 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,
Listener listener,
Producer producer) |
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,
Listener listener,
Producer producer) |
Constructor and Description |
---|
KafkaListenerThread(Properties configuration,
TopicsConfig config) |
LocalListenerThread(TopicsConfig topicsConfig) |
Modifier and Type | Method and Description |
---|---|
static ListenerThread |
KafkaRemoteUtil.getListenerThread(TopicsConfig topicsConfig,
boolean isLocal,
Properties configuration) |
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.