public abstract class AbstractRemoteEntryPoint extends Object implements RemoteWorkingMemory
Modifier and Type | Field and Description |
---|---|
protected String |
entryPoint |
protected Sender |
sender |
protected TopicsConfig |
topicsConfig |
Constructor and Description |
---|
AbstractRemoteEntryPoint(Sender sender,
String entryPoint,
TopicsConfig topicsConfig) |
Modifier and Type | Method and Description |
---|---|
protected <T> CompletableFuture<T> |
executeCommand(AbstractCommand command) |
String |
getEntryPointId() |
CompletableFuture<Long> |
getFactCount() |
<T> CompletableFuture<T> |
getObject(RemoteFactHandle<T> remoteFactHandle) |
CompletableFuture<Collection> |
getObjects()
This class is not a general-purpose Collection
implementation!
|
<T> CompletableFuture<Collection<T>> |
getObjects(Class<T> clazztype) |
CompletableFuture<Collection> |
getObjects(String namedQuery,
String objectName,
Serializable... params) |
protected abstract Map<String,CompletableFuture<Object>> |
getRequestsStore() |
protected final Sender sender
protected final String entryPoint
protected TopicsConfig topicsConfig
public AbstractRemoteEntryPoint(Sender sender, String entryPoint, TopicsConfig topicsConfig)
public String getEntryPointId()
getEntryPointId
in interface RemoteWorkingMemory
public CompletableFuture<Collection> getObjects()
RemoteWorkingMemory
This class is not a general-purpose Collection implementation! While this class implements the Collection interface, it intentionally violates Collection general contract, which mandates the use of the equals method when comparing objects.
Instead the approach used when comparing objects with the contains(Object) method is dependent on the WorkingMemory configuration, where it can be configured for Identity or for Equality.
getObjects
in interface RemoteWorkingMemory
public <T> CompletableFuture<Collection<T>> getObjects(Class<T> clazztype)
getObjects
in interface RemoteWorkingMemory
clazztype
- the filter to be applied to the returned collection of facts.public CompletableFuture<Collection> getObjects(String namedQuery, String objectName, Serializable... params)
getObjects
in interface RemoteWorkingMemory
namedQuery
- the filter to be applied to the returned collection of facts.public CompletableFuture<Long> getFactCount()
getFactCount
in interface RemoteWorkingMemory
public <T> CompletableFuture<T> getObject(RemoteFactHandle<T> remoteFactHandle)
getObject
in interface RemoteWorkingMemory
protected <T> CompletableFuture<T> executeCommand(AbstractCommand command)
protected abstract Map<String,CompletableFuture<Object>> getRequestsStore()
Copyright © 2001–2020 JBoss by Red Hat. All rights reserved.