public class RemoteStreamingEntryPointImpl extends AbstractRemoteEntryPoint implements RemoteStreamingEntryPoint
Modifier and Type | Field and Description |
---|---|
protected RemoteStatefulSessionImpl |
delegate |
entryPoint, sender, topicsConfig
Modifier | Constructor and Description |
---|---|
protected |
RemoteStreamingEntryPointImpl(Sender sender,
String entryPoint,
TopicsConfig topicsConfig,
Listener listener) |
protected |
RemoteStreamingEntryPointImpl(Sender sender,
String entryPoint,
TopicsConfig topicsConfig,
RemoteStatefulSessionImpl delegate) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,CompletableFuture<Object>> |
getRequestsStore() |
void |
insert(Serializable object)
Inserts a new fact into this entry point
|
executeCommand, getEntryPointId, getFactCount, getObject, getObjects, getObjects, getObjects
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getEntryPointId, getFactCount, getObject, getObjects, getObjects, getObjects
protected final RemoteStatefulSessionImpl delegate
protected RemoteStreamingEntryPointImpl(Sender sender, String entryPoint, TopicsConfig topicsConfig, Listener listener)
protected RemoteStreamingEntryPointImpl(Sender sender, String entryPoint, TopicsConfig topicsConfig, RemoteStatefulSessionImpl delegate)
public void insert(Serializable object)
RemoteStreamingEntryPoint
insert
in interface RemoteStreamingEntryPoint
object
- the fact to be insertedprotected Map<String,CompletableFuture<Object>> getRequestsStore()
getRequestsStore
in class AbstractRemoteEntryPoint
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.