Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
EventTable.read(java.lang.String selector)
Retrieves first added event from the table that matches to given selector.
|
ImmutableEventDatagram |
EventQueue.read(java.lang.String selector)
Retrieves but doesn't not remove an event from the head of
the queue that matches to selector clause.
|
ImmutableEventDatagram |
EventTable.readLast(java.lang.String selector)
Retrieves last added event from the table that matches to given selector.
|
ImmutableEventDatagram |
EventQueue.readLast(java.lang.String selector)
Retrieves but doesn't not remove last added event from the
queue that matches to selector clause.
|
ImmutableEventDatagram |
EventTable.take(java.lang.String selector)
Retrieves first added event from the table that matches to given selector.
|
ImmutableEventDatagram |
EventQueue.take(java.lang.String selector)
Retrieves next event from the head of the queue that matches to selector clause.
|
ImmutableEventDatagram |
EventTable.takeLast(java.lang.String selector)
Retrieves last added event from the table that matches to given selector.
|
ImmutableEventDatagram |
EventQueue.takeLast(java.lang.String selector)
Retrieves last added event from the queue that matches to selector clause.
|
ImmutableEventDatagram |
EventTable.waitToRead(java.lang.String selector)
The same as
EventTable.read(String) but blocks until event is available. |
ImmutableEventDatagram |
EventQueue.waitToRead(java.lang.String selector)
Retrieves but do not remove an event from the head of
the queue that matches to selector clause.
|
ImmutableEventDatagram |
EventTable.waitToRead(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventTable.read(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventQueue.waitToRead(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventQueue.read(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventTable.waitToReadLast(java.lang.String selector)
The same as
EventTable.readLast(String) but blocks until event is available. |
ImmutableEventDatagram |
EventQueue.waitToReadLast(java.lang.String selector)
Retrieves but do not remove last added event from
the queue that matches to selector clause.
|
ImmutableEventDatagram |
EventTable.waitToReadLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventTable.readLast(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventQueue.waitToReadLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventQueue.readLast(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventTable.waitToTake(java.lang.String selector)
The same as
EventTable.take(String) but blocks until event is available. |
ImmutableEventDatagram |
EventQueue.waitToTake(java.lang.String selector)
The same as
EventQueue.take(String) but blocks until an event is
available for retrieve. |
ImmutableEventDatagram |
EventTable.waitToTake(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventTable.take(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventQueue.waitToTake(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventQueue.take(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventTable.waitToTakeLast(java.lang.String selector)
The same as
EventTable.takeLast(String) but blocks until event is available. |
ImmutableEventDatagram |
EventQueue.waitToTakeLast(java.lang.String selector)
The same as
EventQueue.takeLast(String) but blocks until an event is
available for retrieve. |
ImmutableEventDatagram |
EventTable.waitToTakeLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventTable.takeLast(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
ImmutableEventDatagram |
EventQueue.waitToTakeLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit)
The same as
EventQueue.takeLast(String) but waiting up to the
specified timeout until an event becomes available for retrieve. |
Modifier and Type | Method and Description |
---|---|
void |
EventTable.delete(ImmutableEventDatagram event)
Deletes event from the table with the same primary keys or
with the same properties values if primary keys not set.
|
void |
EventTable.insert(ImmutableEventDatagram event)
Inserts new event into the table.
|
void |
EventTable.upsert(ImmutableEventDatagram event)
Works the same way as
EventTable.insert(ImmutableEventDatagram) but
if event with the same primary keys exists in the table,
existing event will be updated and new event won't be inserted
into the table. |
Modifier and Type | Class and Description |
---|---|
class |
HTTPClientException
Title: Service Event Fabric Client
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
HTTPEventFactory.createEvent(java.lang.String eventId)
Creates and returns an instance of an event datagram.
|
ImmutableEventDatagram |
HTTPEventFactory.createEvent(java.lang.String eventId,
boolean withImport) |
ImmutableEventDatagram |
HTTPDataspaceAccessor.raiseDataspaceWriteMessage(OpaqueEvent event,
long timeout) |
ImmutableEventDatagram |
HTTPFabricConnection.raiseRequest(RequestConsumerReference consumer,
ImmutableEventDatagram request,
long timeout) |
ImmutableEventDatagram |
HTTPFabricConnection.raiseRequest(java.lang.String consumerName,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period expires.
|
ImmutableEventDatagram |
HTTPDataspaceAccessor.raiseSystemRequest(ImmutableEventDatagram request,
long timeout) |
ImmutableEventDatagram |
HTTPEventAsyncConsumer.receive() |
ImmutableEventDatagram |
HTTPEventAsyncConsumer.receive(long waitTime) |
ImmutableEventDatagram |
HTTPEventAsyncConsumer.receive(java.lang.String eventSelector) |
ImmutableEventDatagram |
HTTPEventAsyncConsumer.receive(java.lang.String eventSelector,
long waitTime) |
ImmutableEventDatagram |
HTTPEventAsyncConsumer.receiveNoWait() |
ImmutableEventDatagram |
HTTPEventAsyncConsumer.receiveNoWait(java.lang.String eventSelector) |
Modifier and Type | Method and Description |
---|---|
void |
HTTPFabricConnection.raiseEvent(ImmutableEventDatagram event,
EventScope eventScope,
long timeToLive) |
ImmutableEventDatagram |
HTTPFabricConnection.raiseRequest(RequestConsumerReference consumer,
ImmutableEventDatagram request,
long timeout) |
ImmutableEventDatagram |
HTTPFabricConnection.raiseRequest(java.lang.String consumerName,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period expires.
|
ImmutableEventDatagram |
HTTPDataspaceAccessor.raiseSystemRequest(ImmutableEventDatagram request,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
ServiceAccessor.invokeAsyncServiceRequest(ImmutableEventDatagram request)
Sends the specified request asynchronously.
|
ImmutableEventDatagram |
ServiceAccessor.invokeServiceRequest(ImmutableEventDatagram request)
Performs the
ServiceAccessor.invokeServiceRequest(ImmutableEventDatagram, long) with a timeout
previously set by the FabricComponentAccessor.setRequestTimeout(long) method or default timeout (30 seconds). |
ImmutableEventDatagram |
ServiceAccessor.invokeServiceRequest(ImmutableEventDatagram request,
long timeout)
Sends the specified request and waits until a response will be received or waiting period will expire.
|
Modifier and Type | Class and Description |
---|---|
class |
FabricConnectionException
Title: Service Event Fabric Client
|
class |
FabricConnectionFactoryException
Title: Service Event Fabric Client
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
FabricConnection.raiseRequest(RequestConsumerReference consumer,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period expires.
|
Modifier and Type | Method and Description |
---|---|
void |
FabricConnection.raiseEvent(ImmutableEventDatagram event,
EventScope eventScope,
long timeToLive)
Raises the specified event.
|
ImmutableEventDatagram |
FabricConnection.raiseRequest(RequestConsumerReference consumer,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period expires.
|
Modifier and Type | Class and Description |
---|---|
class |
XMPPClientException
Title: Service Event Fabric Client
|
Modifier and Type | Method and Description |
---|---|
void |
FutureFunctionManager.onEvent(ImmutableEventDatagram event) |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
ReplicationTarget.onRequest(ImmutableEventDatagram event) |
ImmutableEventDatagram |
ReplicationManager.onRequest(ImmutableEventDatagram event) |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
ReplicationTarget.onRequest(ImmutableEventDatagram event) |
ImmutableEventDatagram |
ReplicationManager.onRequest(ImmutableEventDatagram event) |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
Collection.getEventForTrigger(com.streamscape.ds.session.Session session,
java.lang.Object[] oldData,
java.lang.Object[] newData,
int when,
int triggerType) |
ImmutableEventDatagram |
AbstractCollection.getEventForTrigger(com.streamscape.ds.session.Session session,
java.lang.Object[] oldData,
java.lang.Object[] newData,
int when,
int triggerType) |
ImmutableEventDatagram |
Collection.unwrapEvent(com.streamscape.ds.session.Session session,
java.lang.Object data) |
ImmutableEventDatagram |
AbstractCollection.unwrapEvent(com.streamscape.ds.session.Session session,
java.lang.Object data) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
Collection.wrapEvent(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
java.lang.Object |
AbstractCollection.wrapEvent(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
EventQueueProxy.read(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.readLast(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.take(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.takeLast(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.waitToRead(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.waitToRead(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventQueueProxy.waitToReadLast(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.waitToReadLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventQueueProxy.waitToTake(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.waitToTake(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventQueueProxy.waitToTakeLast(java.lang.String selector) |
ImmutableEventDatagram |
EventQueueProxy.waitToTakeLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
void |
MessageQueueCollection.onEvent(ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
ProcessQueueException
Title: Dataspace Framework
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
ProcessQueueCollection.getEventForTrigger(com.streamscape.ds.session.Session session,
java.lang.Object[] oldData,
java.lang.Object[] newData,
int when,
int operationType) |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
EventTableCollection.getEventForTrigger(com.streamscape.ds.session.Session session,
java.lang.Object[] oldData,
java.lang.Object[] newData,
int when,
int triggerType) |
ImmutableEventDatagram |
EventTableProxy.read(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.readLast(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.take(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.takeLast(java.lang.String selector) |
ImmutableEventDatagram |
EventTableCollection.unwrapEvent(com.streamscape.ds.session.Session session,
java.lang.Object data) |
ImmutableEventDatagram |
EventTableCollection.waitToRead(com.streamscape.ds.session.Session session,
java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableCollection.waitToRead(com.streamscape.ds.session.Session session,
java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit,
boolean isLast) |
ImmutableEventDatagram |
EventTableProxy.waitToRead(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.waitToRead(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableCollection.waitToReadLast(com.streamscape.ds.session.Session session,
java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableProxy.waitToReadLast(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.waitToReadLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableCollection.waitToTake(com.streamscape.ds.session.Session session,
java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableCollection.waitToTake(com.streamscape.ds.session.Session session,
java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit,
boolean isLast) |
ImmutableEventDatagram |
EventTableProxy.waitToTake(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.waitToTake(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableCollection.waitToTakeLast(com.streamscape.ds.session.Session session,
java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
ImmutableEventDatagram |
EventTableProxy.waitToTakeLast(java.lang.String selector) |
ImmutableEventDatagram |
EventTableProxy.waitToTakeLast(java.lang.String selector,
long timeout,
java.util.concurrent.TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
void |
EventTableProxy.delete(ImmutableEventDatagram event) |
void |
EventTableCollection.delete(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
void |
EventTableProxy.insert(ImmutableEventDatagram event) |
void |
EventTableCollection.insert(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
void |
EventTableCollection.onEvent(ImmutableEventDatagram event) |
void |
EventTableProxy.upsert(ImmutableEventDatagram event) |
void |
EventTableCollection.upsert(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
java.lang.Object |
EventTableCollection.wrapEvent(com.streamscape.ds.session.Session session,
ImmutableEventDatagram event) |
Modifier and Type | Method and Description |
---|---|
void |
Actor.onEvent(ImmutableEventDatagram event) |
Constructor and Description |
---|
EventAnalyzer(ImmutableEventDatagram event) |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
RequestListener.onRequest(ImmutableEventDatagram event)
Processes the event delivered by the dispatcher and returns a reply.
|
ImmutableEventDatagram |
EventDispatcher.raiseRequest(EventDatagram request,
RequestDistributionStrategy distributionStrategy,
ReplyMatchStrategy matchStrategy,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period will expire.
|
ImmutableEventDatagram |
EventDispatcher.raiseRequest(EventRequestConsumer consumer,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period will expire.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive()
Returns a next available event in the event queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive(long waitTime)
Returns a next available event from the underlying queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive(java.lang.String eventSelector)
Returns a next event matching the specified event selector from the underlying queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receive(java.lang.String eventSelector,
long waitTime)
Returns a next event matching the specified event selector from the underlying queue.
|
ImmutableEventDatagram |
EventAsyncConsumer.receiveNoWait()
Returns a next event if one is immediately available or
null if there are none available. |
ImmutableEventDatagram |
EventAsyncConsumer.receiveNoWait(java.lang.String eventSelector)
Returns a next event matching the specified event selector if one is available or
null if there are no matching
events found. |
Modifier and Type | Method and Description |
---|---|
void |
EventListener.onEvent(ImmutableEventDatagram event)
Processes an event delivered by the
EventDispatcher . |
ImmutableEventDatagram |
RequestListener.onRequest(ImmutableEventDatagram event)
Processes the event delivered by the dispatcher and returns a reply.
|
void |
EventDispatcher.raiseEvent(ImmutableEventDatagram event)
Raises the specified event.
|
ImmutableEventDatagram |
EventDispatcher.raiseRequest(EventRequestConsumer consumer,
ImmutableEventDatagram request,
long timeout)
Raises the specified request and waits until a reply will be received or waiting period will expire.
|
Modifier and Type | Method and Description |
---|---|
void |
MacroProcessor.setEvent(ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
FactoryManagerException
Title: Object Mediation Framework
|
class |
ObjectMediationException
Title: Object Mediation Framework
|
class |
SerialVersionMismatchException
Title: Object Mediation Framework
|
Modifier and Type | Class and Description |
---|---|
class |
JSerializerException
Title: Object Mediation Framework
|
Modifier and Type | Class and Description |
---|---|
class |
JSONSerializerException
Title: Object Mediation Framework
|
Modifier and Type | Class and Description |
---|---|
class |
ConverterException
Title: Object Mediation Framework
|
class |
SemanticMapperException
Title: Object Mediation Framework
|
Modifier and Type | Class and Description |
---|---|
class |
ConverterPluginManagerException
Title: Open Service Framework
|
Modifier and Type | Method and Description |
---|---|
void |
SemanticMapperContext.setMacroProcessorEvent(ImmutableEventDatagram event) |
void |
AbstractSemanticMapperContext.setMacroProcessorEvent(ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
SerializerException
Title: Object Mediation Framework
|
Modifier and Type | Class and Description |
---|---|
class |
XSerializerException
Title: Object Mediation Framework
|
Modifier and Type | Class and Description |
---|---|
class |
RepositoryException
Title: Fabric Repository Framework
|
Modifier and Type | Class and Description |
---|---|
class |
RepositoryAccessorException
Title: Fabric Repository Framework
|
Modifier and Type | Class and Description |
---|---|
class |
CpuThresholdAdvisory
Title: Service Event Fabric Runtime
|
class |
DiskThresholdAdvisory
Title: Service Event Fabric Runtime
|
class |
MemoryThresholdAdvisory
Title: Service Event Fabric Runtime
|
Modifier and Type | Interface and Description |
---|---|
interface |
AdvisoryEventDatagram
Title: Structured Data Objects
|
interface |
DeltaEventDatagram
Title: Structured Data Objects
|
interface |
EventDatagram
Title: Structured Data Objects
|
interface |
EventDatagramWithProperties
Title: Structured Data Objects
|
interface |
ExceptionEventDatagram
Title: Structured Data Objects
|
interface |
OpaqueDatagram
Title: Structured Data Objects
|
Modifier and Type | Class and Description |
---|---|
class |
com.streamscape.sdo.IAbstractDataEvent
Title: Structured Data Objects
|
class |
com.streamscape.sdo.IAbstractEvent
Title: Structured Data Objects
|
class |
com.streamscape.sdo.IAbstractExceptionEvent
Title: Structured Data Objects
|
class |
SecurityViolationException
Title: Structured Data Objects
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
ImmutableEventDatagram.clone()
Clones the event.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractReplicationAdvisory
Title: Dataspace Framework
|
class |
AdvisoryEvent
Title: Service Event Fabric Runtime
|
class |
BlockedDataspaceSessionAdvisory
Title: Structured Data Objects
|
class |
BlockedThreadAdvisory
Title: Structured Data Objects
|
class |
ComponentStateChangeAdvisory
Title: Structured Data Objects
|
class |
ConnectionStateChangeAdvisory
Title: Open Service Framework
|
class |
DaemonServiceBlockedAdvisory
Title: Service Framework
|
class |
DataspaceMetricAdvisory
Title: Structured Data Objects
|
class |
DataspaceStateAdvisory
Title: Structured Data Objects
|
class |
EventTriggerAdvisory
Title: Service Event Fabric Runtime
|
class |
HTTPClientAdvisory
Title: Structured Data Objects
|
class |
HTTPRestClientAdvisory
Title: Structured Data Objects
|
class |
JournalFileTableStateChangeAdvisory
Title: Open Service Framework
|
class |
LogFileTableStateChangeAdvisory |
class |
MetricAdvisory
Title: Structured Data Objects
|
class |
ReplicaMetricAdvisory
Title: Dataspace Framework
|
class |
ReplicaStateChangeAdvisory
Title: Dataspace Framework
|
class |
ReplicaTimeoutAdvisory
Title: Dataspace Framework
|
class |
ReplicationExceptionAdvisory |
class |
ReplicationFailAdvisory
Title: Dataspace Framework
|
class |
ReplicationSourceMetricAdvisory
Title: Dataspace Framework
|
class |
RepositoryArtifactStateChangeAdvisory
Title: Structured Data Objects
|
class |
RepositoryStateChangeAdvisory
Title: RepositoryStateChangeAdvisory
|
class |
RuntimeAdvisory
Title: Structured Data Objects
|
class |
ServiceMetricAdvisory
Title: Structured Data Objects
|
class |
ServiceStateAdvisory
Title: Structured Data Objects
|
class |
StateAdvisory
Title: Structured Data Objects
|
class |
ThreadDeadlockAdvisory
Title: Structured Data Objects
|
class |
VirtualServerStateChangeAdvisory
Title: Open Service Framework
|
class |
XMPPClientAdvisory
Title: Structured Data Objects
|
class |
XMPPConnectionStateChangeAdvisory
Title: Structured Data Objects
|
Modifier and Type | Method and Description |
---|---|
AdvisoryEventDatagram |
AdvisoryDatagramFactory.newEventInstanceFrom(ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
com.streamscape.sdo.event.AbstractMutableEvent
Title: Structured Data Objects
|
class |
AcknowledgementEvent
Title: Structured Data Objects: Acknowledgment Event
|
class |
AuditEvent
Title: Structured Data Objects: Audit Event
|
class |
BytesEvent
Title: Structured Data Objects: Bytes Event
|
class |
ChunkEvent
Title: Structured Data Objects: Chunk Event
|
class |
DataEvent
Title: Structured Data Objects: Data Event
|
class |
DeltaEvent
Title: Structured Data Objects: Delta Event
|
class |
ExceptionEvent
Title: Structured Data Objects: Exception Event
|
class |
FileEvent
Title: Structured Data Objects: File Event
|
class |
KafkaEvent
Title: Structured Data Objects: Kafka Event
|
class |
LogEvent
Title: Structured Data Objects: Log Event
|
class |
MailEvent
Title: Structured Data Objects: Mail Event
|
class |
MapEvent
Title: Structured Data Objects: Map Event
|
class |
ObjectEvent
Title: Structured Data Objects: Object Event
|
class |
OpaqueEvent
Title: Structured Data Objects: Opaque Event
|
class |
RejectedEvent
Title: Structured Data Objects: Rejected Event
|
class |
RowArrayEvent
Title: Structured Data Objects: Row Array Event
|
class |
RowChangeEvent
Title: Structured Data Objects
|
class |
RowEvent
Title: Structured Data Objects: Row Event
|
class |
RowSetEvent
Title: Structured Data Objects: Row Set Event
|
class |
StreamEvent
Title: Structured Data Objects: Stream Event
|
class |
StreamStateEvent
Title: Structured Data Objects: Stream State Event
|
class |
TextEvent
Title: Structured Data Objects: Text Event
|
class |
XMLEvent
Title: Structured Data Objects: XML Event
|
class |
XMPPEvent
Title: Structured Data Objects: XMPP Event
|
Modifier and Type | Method and Description |
---|---|
OpaqueDatagram |
OpaqueDatagramFactory.newEventInstanceFrom(ImmutableEventDatagram event) |
EventDatagram |
EventDatagramFactory.newEventInstanceFrom(ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
ApplicationFabricException
Title: Structured Data Objects
|
class |
ClientException
Title: Structured Data Objects
|
class |
DatabaseSQLException
Title: Structured Data Objects
|
class |
FabricEventException
Title: Structured Data Objects
|
class |
LanguageException
Title: Structured Data Objects
|
class |
ServiceFrameworkException
Title: Structured Data Objects
|
class |
SoapFaultException
Title: Structured Data Objects
|
class |
SoapRequestException
Title: Structured Data Objects
|
class |
SQLQueryException
Title: Structured Data Objects
|
class |
SQLQueryParseException
Title: Structured Data Objects
|
class |
SQLQueryValidationException
Title: Structured Data Objects
|
class |
TransportException
Title: Structured Data Objects
|
class |
ValidationException
Title: Structured Data Objects
|
class |
XMLParseException
Title: Structured Data Objects
|
Modifier and Type | Method and Description |
---|---|
ExceptionEventDatagram |
ExceptionDatagramFactory.createEvent(java.lang.String eventId,
ImmutableEventDatagram sourceEvent)
Creates an exception datagram object using the specified Event Id.
|
ExceptionEventDatagram |
ExceptionDatagramFactory.newEventInstanceFrom(ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
DatagramFactoryException
Title: Structured Data Objects
|
class |
DatagramFactoryManagerException
Title: Structured Data Objects
|
class |
SemanticTypeFactoryException
Title: Structured Data Objects
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
DatagramFactory.createEvent(Prototype prototype)
Create and returns an event datagram object of a specific type based on the
Prototype . |
ImmutableEventDatagram |
DatagramFactory.createEvent(java.lang.String eventId)
Creates an event datagram object using the specified Event Id.
|
ImmutableEventDatagram |
DatagramFactory.newEventInstance(SemanticType type)
Creates and returns an instance of an event datagram of this factory's type
based on the semantic type.
|
ImmutableEventDatagram |
DatagramFactory.newEventInstance(java.lang.String semanticType)
Creates an event instance based on the specified semantic type.
|
ImmutableEventDatagram |
DatagramFactory.newEventInstanceFrom(ImmutableEventDatagram event)
Creates an event instance using the specified event.
|
ImmutableEventDatagram |
DatagramFactory.newEventInstanceFrom(java.lang.String eventId)
Creates an event instance using the specified Event Id.
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
DatagramFactory.newEventInstanceFrom(ImmutableEventDatagram event)
Creates an event instance using the specified event.
|
Modifier and Type | Class and Description |
---|---|
class |
EventSelectorFormatException
Title: Service Event Fabric Core
|
class |
FabricEventDispatcherException
Title: Service Event Fabric Core
|
class |
FabricEventSinkException
Title: Service Event Fabric Core
|
class |
FabricEventSourceException
Title: Service Event Fabric Core
|
class |
FabricEventStreamException
Title: Service Event Fabric Core
|
class |
FabricEventTriggerException
Title: Service Event Fabric Core
|
class |
FabricRequestException
Title: Service Event Fabric Core
|
class |
FabricUnboundEventException
Title: Structured Data Objects
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
FabricEventStreamException.getEvent()
Returns the event that caused this exception.
|
ImmutableEventDatagram |
FabricRequestListener.onRequest(ImmutableEventDatagram event)
Processes the specified event and returns a reply.
|
ImmutableEventDatagram |
EventReceiver.receive()
Returns the next event in the stream from the underlying event queue.
|
ImmutableEventDatagram |
EventReceiver.receive(long timeout)
Returns the next event in the stream from the underlying event queue.
|
ImmutableEventDatagram |
EventReceiver.receive(java.lang.String eventSelector)
Returns the next event in the stream from the underlying event queue.
|
ImmutableEventDatagram |
EventReceiver.receive(java.lang.String eventSelector,
long timeout)
Returns the next event in the stream from the underlying event queue.
|
ImmutableEventDatagram |
EventReceiver.receiveNoWait()
Returns the next event in the stream from the underlying event queue.
|
ImmutableEventDatagram |
EventReceiver.receiveNoWait(java.lang.String eventSelector)
Returns the next event in the stream from the underlying event queue.
|
Modifier and Type | Method and Description |
---|---|
void |
FabricEventListener.onEvent(ImmutableEventDatagram event)
Processes the specified event.
|
ImmutableEventDatagram |
FabricRequestListener.onRequest(ImmutableEventDatagram event)
Processes the specified event and returns a reply.
|
Constructor and Description |
---|
FabricEventStreamException(EventConsumerReference consumer,
ImmutableEventDatagram event) |
Modifier and Type | Class and Description |
---|---|
class |
FabricComponentAccessorAdvisory
Title: Structured Data Objects
|
class |
FabricComponentAccessorException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
CoherenceAgentAdvisory
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
LogGenerationAdvisory
Title: Service Event Fabric Core
|
class |
LogThresholdAdvisory
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
DataspaceComponentException
Title: Service Event Fabric Core
|
class |
DataspaceManagerException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
DeploymentAdvisory
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryModuleException
Title: Service Event Fabric Core
|
Modifier and Type | Method and Description |
---|---|
AcknowledgementEvent |
TriggerFunctionContextImpl.createAcknowledgement(ImmutableEventDatagram event,
boolean withSourceData) |
void |
DirectServiceAccessor.invokeAsyncServiceRequest(ImmutableEventDatagram request) |
ImmutableEventDatagram |
AbstractDropBoxManagerRemote.invokeDropBoxManagerRequest(java.lang.String nodeName,
ImmutableEventDatagram request,
long timeout) |
ImmutableEventDatagram |
DirectServiceAccessor.invokeServiceRequest(ImmutableEventDatagram request) |
ImmutableEventDatagram |
DirectServiceAccessor.invokeServiceRequest(ImmutableEventDatagram request,
long timeout) |
ImmutableEventDatagram |
AbstractDropBoxManagerRemote.onRequest(ImmutableEventDatagram event) |
void |
TriggerFunctionContextImpl.raiseEvent(ImmutableEventDatagram event) |
void |
TriggerFunctionContextImpl.raiseEvent(ImmutableEventDatagram event,
EventScope eventScope) |
ImmutableEventDatagram |
AccessibleObjectComponentSimple.raiseSystemRequest(ImmutableEventDatagram request,
long timeout) |
void |
TriggerFunctionContextImpl.setActionableEvent(ImmutableEventDatagram actionableEvent) |
void |
TriggerFunctionContextImpl.setSourceEvent(ImmutableEventDatagram sourceEvent) |
Modifier and Type | Class and Description |
---|---|
class |
DropBoxFactoryException
Title: Service Event Fabric Core
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
EventTriggerAction.invokeAction(ImmutableEventDatagram datagram)
Invoked by the
Event Trigger mechanism when a new actionable
event arrives. |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
EventTriggerAction.invokeAction(ImmutableEventDatagram datagram)
Invoked by the
Event Trigger mechanism when a new actionable
event arrives. |
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
TriggerFunctionContext.createEvent(java.lang.String eventId) |
ImmutableEventDatagram |
TriggerFunctionContext.getActionableEvent() |
Modifier and Type | Method and Description |
---|---|
AcknowledgementEvent |
TriggerFunctionContext.createAcknowledgement(ImmutableEventDatagram event,
boolean withSourceData) |
void |
TriggerScript.execute(ImmutableEventDatagram actionableEvent,
ImmutableEventDatagram sourceEvent,
long executionWindowMs,
TriggerFunctionContextImpl.DataspaceAccessorProvider dataspaceAccessorProvider) |
void |
TriggerFunctionContext.raiseEvent(ImmutableEventDatagram event) |
void |
TriggerFunctionContext.raiseEvent(ImmutableEventDatagram value,
EventScope eventScope) |
Modifier and Type | Class and Description |
---|---|
class |
ClientThresholdAdvisory
Title: Service Event Fabric Core
|
class |
FabricExchangeAdvisory
Title: Service Event Fabric Core
|
class |
FabricExchangeException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
FabricGroupManagerException
Title: Service Event Fabric Core
|
Modifier and Type | Method and Description |
---|---|
void |
FabricGroupLink.raiseEvent(ImmutableEventDatagram event,
EventScope eventScope,
long timeToLive)
Raises the specified event.
|
Modifier and Type | Class and Description |
---|---|
class |
ModuleException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
FabricModeratorAdvisory
Title: Service Event Fabric Core
|
Modifier and Type | Method and Description |
---|---|
static ComponentReference |
ModeratorUtils.lookupComponent(Moderator moderator,
ImmutableEventDatagram event)
Returns the component corresponding to a source of the specified event.
|
Modifier and Type | Method and Description |
---|---|
static EventWrapper |
EventWrapperFactory.createEventWrapper(ImmutableEventDatagram event) |
java.util.Map |
EventWrapper.getAllFields(ImmutableEventDatagram event) |
java.lang.Class |
EventWrapper.getFieldType(ImmutableEventDatagram event,
java.lang.String name) |
java.util.Map |
EventWrapper.getProperties(ImmutableEventDatagram event) |
void |
EventWrapper.setField(ImmutableEventDatagram event,
java.lang.String name,
java.lang.Object value) |
Modifier and Type | Class and Description |
---|---|
class |
AcceptorException
Title: Service Event Fabric Core
|
class |
AcceptorFactoryException
Title: Service Event Fabric Core
|
class |
AcceptorFactoryManagerException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
SchedulerAdvisory
Title: Service Event Fabric Core
|
class |
SchedulerCompletionEvent
Title: Structured Data Objects: Scheduler Event
|
class |
SchedulerEvent
Title: Structured Data Objects: Scheduler Event
|
class |
SchedulerException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
SecurityAdvisory
Title: Service Event Fabric Core
|
class |
SecurityManagerException
Title: Service Event Fabric Core
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceContextException
Title: Service Event Fabric Core
|
class |
ServiceManagerException
Title: Service Event Fabric Core
|
Modifier and Type | Method and Description |
---|---|
ImmutableEventDatagram |
ServiceContext.createResponseEvent(java.lang.String methodName)
Creates an instance of response event based on the Event Handler method name.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceContext.raiseEvent(ImmutableEventDatagram event,
long timeToLive)
Raises a service-specific event.
|
Modifier and Type | Class and Description |
---|---|
class |
ServiceCallAdvisory
Title: Service Event Fabric Runtime
|
Modifier and Type | Class and Description |
---|---|
class |
EventIdentityPluginManagerException
Title: Open Service Framework
|
Modifier and Type | Method and Description |
---|---|
void |
EventHandler.bindRequestEvent(ImmutableEventDatagram event)
Binds the specified event as a request object.
|
void |
EventHandler.bindResponseEvent(ImmutableEventDatagram datagram)
Binds the specified event as a response object.
|
Modifier and Type | Class and Description |
---|---|
class |
SemanticLexiconException
Title: Semantic Lexicon Processing Framework
|
Modifier and Type | Class and Description |
---|---|
class |
SLSessionException
Title: Semantic Lexicon Processing Framework
|
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.