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<Integer> |
fireAllRules() |
void |
fireUntilHalt() |
RemoteStreamingEntryPoint |
getEntryPoint(String name) |
void |
halt() |
getRequestsStore, insert
executeCommand, getEntryPointId, getFactCount, getObjects, getObjects, getObjects
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, create
insert
getEntryPointId, getFactCount, 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<Integer> fireAllRules()
fireAllRules
in interface RemoteStatefulSession
public void fireUntilHalt()
fireUntilHalt
in interface RemoteStatefulSession
public void halt()
halt
in interface RemoteStatefulSession
Copyright © 2001–2019 JBoss by Red Hat. All rights reserved.