public class RemoteStreamingKieSessionImpl extends RemoteStreamingEntryPointImpl implements RemoteStreamingKieSession
delegate
entryPoint, sender, topicsConfig
Constructor and Description |
---|
RemoteStreamingKieSessionImpl(Properties configuration) |
RemoteStreamingKieSessionImpl(Properties configuration,
TopicsConfig envConfig) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
CompletableFuture<Long> |
fireAllRules() |
void |
fireUntilHalt() |
RemoteStreamingEntryPoint |
getEntryPoint(String name) |
CompletableFuture<String> |
getKJarGAV() |
void |
halt() |
CompletableFuture<Boolean> |
updateKJarGAV(String kJar) |
getRequestsStore, insert
executeCommand, getEntryPointId, getFactCount, getObject, getObjects, getObjects, getObjects
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, create
insert
getEntryPointId, getFactCount, getObject, getObjects, getObjects, getObjects
public RemoteStreamingKieSessionImpl(Properties configuration)
public RemoteStreamingKieSessionImpl(Properties configuration, TopicsConfig envConfig)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public RemoteStreamingEntryPoint getEntryPoint(String name)
getEntryPoint
in interface RemoteStreamingKieSession
public CompletableFuture<Long> fireAllRules()
fireAllRules
in interface RemoteStatefulSession
public void fireUntilHalt()
fireUntilHalt
in interface RemoteStatefulSession
public void halt()
halt
in interface RemoteStatefulSession
public CompletableFuture<Boolean> updateKJarGAV(String kJar)
updateKJarGAV
in interface UpdatableSession
public CompletableFuture<String> getKJarGAV()
getKJarGAV
in interface UpdatableSession
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.