Modifier and Type | Field and Description |
---|---|
protected StructuredEvent |
AnyMessage.structuredEventValue_
the wrapped Any converted to a StructuredEvent
|
Modifier and Type | Method and Description |
---|---|
abstract StructuredEvent |
AbstractMessage.toStructuredEvent()
Access this NotificationEvent as StructuredEvent.
|
StructuredEvent |
TypedEventMessage.toStructuredEvent() |
StructuredEvent |
AnyMessage.toStructuredEvent() |
StructuredEvent |
StructuredEventMessage.toStructuredEvent() |
Modifier and Type | Method and Description |
---|---|
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent) |
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent,
IProxyConsumer consumer) |
void |
StructuredEventMessage.setStructuredEvent(StructuredEvent structuredEvent,
boolean startTimeSupported,
boolean stopTimeSupported) |
Modifier and Type | Method and Description |
---|---|
protected int |
AbstractFilter.match_structured_internal(StructuredEvent structuredEvent)
match the StructuredEvent to the associated constraints.
|
boolean |
AbstractFilter.match_structured(StructuredEvent structuredevent) |
boolean |
MappingFilterImpl.match_structured(StructuredEvent structuredEvent,
AnyHolder anyHolder) |
Modifier and Type | Method and Description |
---|---|
Message |
DefaultMessageFactory.newMessage(StructuredEvent structuredEvent)
create a message wrapping a structured event.
|
Message |
DefaultMessageFactory.newMessage(StructuredEvent structuredEvent,
IProxyConsumer consumer)
create a Message wrapping a structured event.
|
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
Message.toStructuredEvent() |
Modifier and Type | Field and Description |
---|---|
protected static StructuredEvent |
StructuredProxyPullSupplierImpl.UNDEFINED_STRUCTURED_EVENT
undefined StructuredEvent that is returned on unsuccessful pull operations.
|
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
StructuredProxyPullSupplierImpl.pull_structured_event() |
StructuredEvent[] |
SequenceProxyPullSupplierImpl.pull_structured_events(int number) |
StructuredEvent |
StructuredProxyPullSupplierImpl.try_pull_structured_event(BooleanHolder hasEvent) |
StructuredEvent[] |
SequenceProxyPullSupplierImpl.try_pull_structured_events(int number,
BooleanHolder success) |
Modifier and Type | Method and Description |
---|---|
protected Message[] |
AbstractProxyConsumer.newMessages(StructuredEvent[] events) |
void |
StructuredProxyPushConsumerImpl.push_structured_event(StructuredEvent structuredEvent) |
void |
SequenceProxyPushConsumerImpl.push_structured_events(StructuredEvent[] events) |
Modifier and Type | Field and Description |
---|---|
StructuredEvent |
StructuredEventHolder.value |
StructuredEvent[] |
EventBatchHolder.value |
Modifier and Type | Method and Description |
---|---|
static StructuredEvent[] |
EventBatchHelper.extract(Any any) |
static StructuredEvent |
StructuredEventHelper.extract(Any any) |
static StructuredEvent[] |
EventBatchHelper.read(InputStream _in) |
static StructuredEvent |
StructuredEventHelper.read(InputStream in) |
Modifier and Type | Method and Description |
---|---|
static void |
StructuredEventHelper.insert(Any any,
StructuredEvent s) |
static void |
EventBatchHelper.insert(Any any,
StructuredEvent[] s) |
static void |
StructuredEventHelper.write(OutputStream out,
StructuredEvent s) |
static void |
EventBatchHelper.write(OutputStream _out,
StructuredEvent[] _s) |
Constructor and Description |
---|
EventBatchHolder(StructuredEvent[] initial) |
StructuredEventHolder(StructuredEvent initial) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
_StructuredProxyPullSupplierStub.pull_structured_event() |
StructuredEvent |
StructuredProxyPullSupplierPOATie.pull_structured_event() |
StructuredEvent[] |
_SequenceProxyPullSupplierStub.pull_structured_events(int max_number) |
StructuredEvent[] |
SequenceProxyPullSupplierPOATie.pull_structured_events(int max_number) |
StructuredEvent |
_StructuredProxyPullSupplierStub.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
StructuredProxyPullSupplierPOATie.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent[] |
_SequenceProxyPullSupplierStub.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
StructuredEvent[] |
SequenceProxyPullSupplierPOATie.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
void |
StructuredProxyPushConsumerPOATie.push_structured_event(StructuredEvent notification) |
void |
_StructuredProxyPushConsumerStub.push_structured_event(StructuredEvent notification) |
void |
SequenceProxyPushConsumerPOATie.push_structured_events(StructuredEvent[] notifications) |
void |
_SequenceProxyPushConsumerStub.push_structured_events(StructuredEvent[] notifications) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
_StructuredProxyPullSupplierAckStub.pull_structured_event() |
StructuredEvent |
StructuredProxyPullSupplierAckPOATie.pull_structured_event() |
StructuredEvent[] |
SequenceProxyPullSupplierAckPOATie.pull_structured_events(int max_number) |
StructuredEvent[] |
_SequenceProxyPullSupplierAckStub.pull_structured_events(int max_number) |
StructuredEvent |
_StructuredProxyPullSupplierAckStub.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
StructuredProxyPullSupplierAckPOATie.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent[] |
SequenceProxyPullSupplierAckPOATie.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
StructuredEvent[] |
_SequenceProxyPullSupplierAckStub.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
StructuredPullSupplierOperations.pull_structured_event() |
StructuredEvent |
_StructuredPullSupplierStub.pull_structured_event() |
StructuredEvent |
StructuredPullSupplierPOATie.pull_structured_event() |
StructuredEvent[] |
_SequencePullSupplierStub.pull_structured_events(int max_number) |
StructuredEvent[] |
SequencePullSupplierPOATie.pull_structured_events(int max_number) |
StructuredEvent[] |
SequencePullSupplierOperations.pull_structured_events(int max_number) |
StructuredEvent |
StructuredPullSupplierOperations.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
_StructuredPullSupplierStub.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
StructuredPullSupplierPOATie.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent[] |
_SequencePullSupplierStub.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
StructuredEvent[] |
SequencePullSupplierPOATie.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
StructuredEvent[] |
SequencePullSupplierOperations.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
void |
StructuredPushConsumerPOATie.push_structured_event(StructuredEvent notification) |
void |
StructuredPushConsumerOperations.push_structured_event(StructuredEvent notification) |
void |
_StructuredPushConsumerStub.push_structured_event(StructuredEvent notification) |
void |
_SequencePushConsumerStub.push_structured_events(StructuredEvent[] notifications) |
void |
SequencePushConsumerOperations.push_structured_events(StructuredEvent[] notifications) |
void |
SequencePushConsumerPOATie.push_structured_events(StructuredEvent[] notifications) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
StructuredPullSupplierAckPOATie.pull_structured_event() |
StructuredEvent |
_StructuredPullSupplierAckStub.pull_structured_event() |
StructuredEvent[] |
_SequencePullSupplierAckStub.pull_structured_events(int max_number) |
StructuredEvent[] |
SequencePullSupplierAckPOATie.pull_structured_events(int max_number) |
StructuredEvent |
StructuredPullSupplierAckPOATie.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
_StructuredPullSupplierAckStub.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent[] |
_SequencePullSupplierAckStub.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
StructuredEvent[] |
SequencePullSupplierAckPOATie.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
boolean |
_FilterStub.match_structured(StructuredEvent filterable_data) |
boolean |
FilterOperations.match_structured(StructuredEvent filterable_data) |
boolean |
FilterPOATie.match_structured(StructuredEvent filterable_data) |
boolean |
MappingFilterOperations.match_structured(StructuredEvent filterable_data,
AnyHolder result_to_set) |
boolean |
MappingFilterPOATie.match_structured(StructuredEvent filterable_data,
AnyHolder result_to_set) |
boolean |
_MappingFilterStub.match_structured(StructuredEvent filterable_data,
AnyHolder result_to_set) |