Modifier and Type | Method and Description |
---|---|
Any |
ProxyPullSupplierImpl.pull()
PullSupplier Interface.
|
void |
ProxyPushConsumerImpl.push(Any event)
Supplier sends data to the consumer (this object) using this call.
|
Any |
ProxyPullSupplierImpl.try_pull(BooleanHolder hasEvent)
PullSupplier Interface.
|
Modifier and Type | Method and Description |
---|---|
void |
PullFromSupplierTask.doWork() |
void |
PushOperation.invokePush() |
Modifier and Type | Method and Description |
---|---|
void |
MessageSupplier.runPullMessage()
pull one or more events from the Supplier
and hands over the pulled events to the TaskProcessor.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractProxy.handleDisconnected(Disconnected e) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractProxy.checkStillConnected() |
StructuredEvent |
StructuredProxyPullSupplierImpl.pull_structured_event() |
StructuredEvent[] |
SequenceProxyPullSupplierImpl.pull_structured_events(int number) |
Any |
TypedProxyPullSupplierImpl.pull() |
Any |
ProxyPullSupplierImpl.pull() |
MessageSupplierDelegate.PullResult |
SequenceProxyPullConsumerImpl.pullMessages() |
MessageSupplierDelegate.PullResult |
ProxyPullConsumerImpl.pullMessages() |
MessageSupplierDelegate.PullResult |
MessageSupplierDelegate.pullMessages()
the implementation pulls one or more events from its Supplier
and hands over the pulled events to the TaskProcessor.
|
MessageSupplierDelegate.PullResult |
StructuredProxyPullConsumerImpl.pullMessages() |
void |
StructuredProxyPushConsumerImpl.push_structured_event(StructuredEvent structuredEvent) |
void |
SequenceProxyPushConsumerImpl.push_structured_events(StructuredEvent[] events) |
void |
TypedProxyPushConsumerImpl.push(Any any) |
void |
ProxyPushConsumerImpl.push(Any event)
Supplier sends data to the consumer (this object) using this call.
|
void |
PullMessagesOperation.runPull() |
void |
SequenceProxyPullConsumerImpl.runPullMessage() |
void |
ProxyPullConsumerImpl.runPullMessage() |
void |
StructuredProxyPullConsumerImpl.runPullMessage() |
void |
TypedProxyPullConsumerImpl.runPullMessage() |
StructuredEvent |
StructuredProxyPullSupplierImpl.try_pull_structured_event(BooleanHolder hasEvent) |
StructuredEvent[] |
SequenceProxyPullSupplierImpl.try_pull_structured_events(int number,
BooleanHolder success) |
Any |
TypedProxyPullSupplierImpl.try_pull(BooleanHolder booleanHolder) |
Any |
ProxyPullSupplierImpl.try_pull(BooleanHolder hasEvent) |
Modifier and Type | Method and Description |
---|---|
Any |
ProxyPullSupplierPOATie.pull() |
Any |
_ProxyPullSupplierStub.pull() |
void |
_ProxyPushConsumerStub.push(Any data) |
void |
ProxyPushConsumerPOATie.push(Any data) |
Any |
ProxyPullSupplierPOATie.try_pull(BooleanHolder has_event) |
Any |
_ProxyPullSupplierStub.try_pull(BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
static Disconnected |
DisconnectedHelper.extract(Any any) |
static Disconnected |
DisconnectedHelper.read(InputStream in) |
Modifier and Type | Method and Description |
---|---|
static void |
DisconnectedHelper.insert(Any any,
Disconnected s) |
static void |
DisconnectedHelper.write(OutputStream out,
Disconnected s) |
Modifier and Type | Method and Description |
---|---|
Any |
PullSupplierOperations.pull() |
Any |
_PullSupplierStub.pull() |
Any |
PullSupplierPOATie.pull() |
void |
PushConsumerPOATie.push(Any data) |
void |
_PushConsumerStub.push(Any data) |
void |
PushConsumerOperations.push(Any data) |
Any |
PullSupplierOperations.try_pull(BooleanHolder has_event) |
Any |
_PullSupplierStub.try_pull(BooleanHolder has_event) |
Any |
PullSupplierPOATie.try_pull(BooleanHolder has_event) |
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) |
Any |
ProxyPullSupplierPOATie.pull() |
Any |
_ProxyPullSupplierStub.pull() |
void |
StructuredProxyPushConsumerPOATie.push_structured_event(StructuredEvent notification) |
void |
_StructuredProxyPushConsumerStub.push_structured_event(StructuredEvent notification) |
void |
_SequenceProxyPushConsumerStub.push_structured_events(StructuredEvent[] notifications) |
void |
SequenceProxyPushConsumerPOATie.push_structured_events(StructuredEvent[] notifications) |
void |
_ProxyPushConsumerStub.push(Any data) |
void |
ProxyPushConsumerPOATie.push(Any data) |
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) |
Any |
ProxyPullSupplierPOATie.try_pull(BooleanHolder has_event) |
Any |
_ProxyPullSupplierStub.try_pull(BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
_StructuredProxyPullSupplierAckStub.pull_structured_event() |
StructuredEvent |
StructuredProxyPullSupplierAckPOATie.pull_structured_event() |
StructuredEvent[] |
_SequenceProxyPullSupplierAckStub.pull_structured_events(int max_number) |
StructuredEvent[] |
SequenceProxyPullSupplierAckPOATie.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[] |
_SequenceProxyPullSupplierAckStub.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
StructuredEvent[] |
SequenceProxyPullSupplierAckPOATie.try_pull_structured_events(int max_number,
BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
StructuredPullSupplierOperations.pull_structured_event() |
StructuredEvent |
StructuredPullSupplierPOATie.pull_structured_event() |
StructuredEvent |
_StructuredPullSupplierStub.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) |
Any |
_PullSupplierStub.pull() |
Any |
PullSupplierPOATie.pull() |
void |
StructuredPushConsumerPOATie.push_structured_event(StructuredEvent notification) |
void |
StructuredPushConsumerOperations.push_structured_event(StructuredEvent notification) |
void |
_StructuredPushConsumerStub.push_structured_event(StructuredEvent notification) |
void |
SequencePushConsumerPOATie.push_structured_events(StructuredEvent[] notifications) |
void |
SequencePushConsumerOperations.push_structured_events(StructuredEvent[] notifications) |
void |
_SequencePushConsumerStub.push_structured_events(StructuredEvent[] notifications) |
void |
PushConsumerPOATie.push(Any data) |
void |
_PushConsumerStub.push(Any data) |
StructuredEvent |
StructuredPullSupplierOperations.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
StructuredPullSupplierPOATie.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
_StructuredPullSupplierStub.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) |
Any |
_PullSupplierStub.try_pull(BooleanHolder has_event) |
Any |
PullSupplierPOATie.try_pull(BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
StructuredEvent |
_StructuredPullSupplierAckStub.pull_structured_event() |
StructuredEvent |
StructuredPullSupplierAckPOATie.pull_structured_event() |
StructuredEvent[] |
_SequencePullSupplierAckStub.pull_structured_events(int max_number) |
StructuredEvent[] |
SequencePullSupplierAckPOATie.pull_structured_events(int max_number) |
StructuredEvent |
_StructuredPullSupplierAckStub.try_pull_structured_event(BooleanHolder has_event) |
StructuredEvent |
StructuredPullSupplierAckPOATie.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 |
---|---|
Any |
_TypedProxyPullSupplierStub.pull() |
Any |
TypedProxyPullSupplierPOATie.pull() |
void |
TypedProxyPushConsumerPOATie.push(Any data) |
void |
_TypedProxyPushConsumerStub.push(Any data) |
Any |
_TypedProxyPullSupplierStub.try_pull(BooleanHolder has_event) |
Any |
TypedProxyPullSupplierPOATie.try_pull(BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
Any |
TypedPullSupplierPOATie.pull() |
Any |
_TypedPullSupplierStub.pull() |
void |
TypedPushConsumerPOATie.push(Any data) |
void |
_TypedPushConsumerStub.push(Any data) |
Any |
TypedPullSupplierPOATie.try_pull(BooleanHolder has_event) |
Any |
_TypedPullSupplierStub.try_pull(BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
Any |
_TypedProxyPullSupplierStub.pull() |
Any |
TypedProxyPullSupplierPOATie.pull() |
void |
TypedProxyPushConsumerPOATie.push(Any data) |
void |
_TypedProxyPushConsumerStub.push(Any data) |
Any |
_TypedProxyPullSupplierStub.try_pull(BooleanHolder has_event) |
Any |
TypedProxyPullSupplierPOATie.try_pull(BooleanHolder has_event) |
Modifier and Type | Method and Description |
---|---|
Any |
TypedPullSupplierPOATie.pull() |
Any |
_TypedPullSupplierStub.pull() |
void |
TypedPushConsumerPOATie.push(Any data) |
void |
_TypedPushConsumerStub.push(Any data) |
Any |
TypedPullSupplierPOATie.try_pull(BooleanHolder has_event) |
Any |
_TypedPullSupplierStub.try_pull(BooleanHolder has_event) |