Modifier and Type | Method and Description |
---|---|
Message |
AbstractMessage.getHandle() |
Message |
MessageFactory.newMessage(Any any) |
Message |
MessageFactory.newMessage(Any any,
IProxyConsumer consumer) |
Message |
MessageFactory.newMessage(Property[] props) |
Message |
MessageFactory.newMessage(java.lang.String interfaceName,
java.lang.String operationName,
NVList args,
IProxyConsumer consumer) |
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent) |
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent,
IProxyConsumer consumer) |
Modifier and Type | Field and Description |
---|---|
protected Message |
MessagePushOperation.message_ |
Modifier and Type | Method and Description |
---|---|
Message |
AbstractMessageTask.copyMessage() |
protected Message |
AbstractMessageTask.getMessage() |
Message |
AbstractMessageTask.removeMessage() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultTaskFactory.enqueueMessage(FilterStage[] nodes,
Message mesg) |
void |
TaskFactory.enqueueMessage(FilterStage[] nodes,
Message event) |
Schedulable |
DefaultTaskFactory.newFilterProxyConsumerTask(Message message) |
Schedulable |
TaskFactory.newFilterProxyConsumerTask(Message message) |
void |
DefaultTaskProcessor.processMessage(Message mesg)
process a Message.
|
void |
TaskProcessor.processMessage(Message mesg)
process a Message.
|
protected void |
DefaultTaskProcessor.processMessageInternal(Message event)
process a Message.
|
void |
AbstractMessageTask.setMessage(Message message)
set the Message for this Task to use.
|
Constructor and Description |
---|
MessagePushOperation(Message message) |
Modifier and Type | Method and Description |
---|---|
Message |
EvaluationContext.getCurrentMessage() |
Modifier and Type | Method and Description |
---|---|
EvaluationResult |
FilterConstraint.evaluate(EvaluationContext evaluationContext,
Message event) |
void |
EvaluationContext.setCurrentMessage(Message message) |
Modifier and Type | Method and Description |
---|---|
EvaluationResult |
ETCLFilterConstraint.evaluate(EvaluationContext evaluationContext,
Message event) |
Modifier and Type | Method and Description |
---|---|
Message |
DefaultMessageFactory.newMessage(Any any)
create a Message wrapping a unstructured event.
|
Message |
DefaultMessageFactory.newMessage(Any any,
IProxyConsumer consumer)
create a Message wrapping an unstructured event.
|
Message |
DefaultMessageFactory.newMessage(Property[] props)
create a message wrapping a typed event.
|
Message |
DefaultMessageFactory.newMessage(java.lang.String interfaceName,
java.lang.String operationName,
NVList args,
IProxyConsumer consumer)
create a Message wrapping a typed event.
|
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 |
---|---|
void |
MessageConsumer.queueMessage(Message m)
Deliver a Message to the associated Consumer.
|
Modifier and Type | Method and Description |
---|---|
protected Message[] |
BoundedFifoEventQueue.getAllElements() |
protected Message[] |
AbstractBoundedEventHeap.getAllElements() |
protected abstract Message[] |
AbstractBoundedEventQueue.getAllElements() |
Message[] |
MessageQueueAdapter.getAllMessages() |
Message[] |
RWLockEventQueueDecorator.getAllMessages() |
Message[] |
DefaultMessageQueueAdapter.getAllMessages() |
Message[] |
AbstractBoundedEventQueue.getAllMessages(boolean wait) |
Message[] |
MessageQueue.getAllMessages(boolean wait)
get all Messages from this queue.
|
Message[] |
MessageQueueAdapter.getAtLeastMessages(int min) |
Message[] |
RWLockEventQueueDecorator.getAtLeastMessages(int min) |
Message[] |
DefaultMessageQueueAdapter.getAtLeastMessages(int min) |
protected Message |
BoundedDeadlineEventQueue.getEarliestTimeout() |
protected Message |
BoundedFifoEventQueue.getEarliestTimeout() |
protected Message |
BoundedPriorityEventQueue.getEarliestTimeout() |
protected abstract Message |
AbstractBoundedEventQueue.getEarliestTimeout() |
protected Message |
BoundedReceiveTimeEventQueue.getEarliestTimeout() |
protected Message[] |
BoundedFifoEventQueue.getElements(int max) |
protected Message[] |
AbstractBoundedEventHeap.getElements(int max) |
protected abstract Message[] |
AbstractBoundedEventQueue.getElements(int max) |
protected Message |
BoundedDeadlineEventQueue.getLeastPriority() |
protected Message |
BoundedFifoEventQueue.getLeastPriority() |
protected Message |
BoundedPriorityEventQueue.getLeastPriority() |
protected abstract Message |
AbstractBoundedEventQueue.getLeastPriority() |
protected Message |
BoundedReceiveTimeEventQueue.getLeastPriority() |
Message |
AbstractBoundedEventQueue.getMessage(boolean wait) |
Message |
MessageQueue.getMessage(boolean wait)
get the next Message from this queue.
|
Message |
MessageQueueAdapter.getMessageBlocking() |
Message |
RWLockEventQueueDecorator.getMessageBlocking() |
Message |
DefaultMessageQueueAdapter.getMessageBlocking() |
Message |
MessageQueueAdapter.getMessageNoBlock() |
Message |
RWLockEventQueueDecorator.getMessageNoBlock() |
Message |
DefaultMessageQueueAdapter.getMessageNoBlock() |
Message[] |
AbstractBoundedEventQueue.getMessages(int max,
boolean wait) |
Message[] |
MessageQueue.getMessages(int n,
boolean wait)
get up to
n events from this queue. |
protected Message |
BoundedFifoEventQueue.getNextElement() |
protected Message |
AbstractBoundedEventHeap.getNextElement() |
protected abstract Message |
AbstractBoundedEventQueue.getNextElement() |
protected Message |
AbstractBoundedEventHeap.getNextHeapElement() |
protected Message |
BoundedDeadlineEventQueue.getOldestElement() |
protected Message |
BoundedFifoEventQueue.getOldestElement() |
protected Message |
BoundedPriorityEventQueue.getOldestElement() |
protected abstract Message |
AbstractBoundedEventQueue.getOldestElement() |
protected Message |
BoundedReceiveTimeEventQueue.getOldestElement() |
Message[] |
MessageQueueAdapter.getUpToMessages(int max) |
Message[] |
RWLockEventQueueDecorator.getUpToMessages(int max) |
Message[] |
DefaultMessageQueueAdapter.getUpToMessages(int max) |
protected Message |
BoundedDeadlineEventQueue.getYoungestElement() |
protected Message |
BoundedFifoEventQueue.getYoungestElement() |
protected Message |
BoundedPriorityEventQueue.getYoungestElement() |
protected abstract Message |
AbstractBoundedEventQueue.getYoungestElement() |
protected Message |
BoundedReceiveTimeEventQueue.getYoungestElement() |
Message |
EventQueueOverflowStrategy.removeElementFromQueue(AbstractBoundedEventQueue queue) |
protected Message |
AbstractBoundedEventHeap.removeFirstElement(java.util.Comparator comp) |
Modifier and Type | Method and Description |
---|---|
protected void |
BoundedFifoEventQueue.addElement(Message e) |
protected void |
AbstractBoundedEventHeap.addElement(Message event) |
protected abstract void |
AbstractBoundedEventQueue.addElement(Message message) |
void |
MessageQueueAdapter.enqeue(Message message) |
void |
RWLockEventQueueDecorator.enqeue(Message message) |
void |
DefaultMessageQueueAdapter.enqeue(Message message) |
void |
AbstractBoundedEventQueue.put(Message event) |
void |
MessageQueue.put(Message event)
put a Message into this queue.
|
Modifier and Type | Method and Description |
---|---|
protected Message[] |
AbstractProxySupplier.getAllMessages() |
protected Message[] |
AbstractProxySupplier.getAtLeastMessages(int min) |
Message |
AbstractProxySupplier.getMessageBlocking() |
protected Message |
AbstractProxySupplier.getMessageNoBlock() |
protected Message[] |
AbstractProxySupplier.getUpToMessages(int max) |
protected Message[] |
AbstractProxyConsumer.newMessages(StructuredEvent[] events) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractProxyConsumer.checkMessageProperties(Message m)
check if a Message is acceptable to the QoS Settings of this ProxyConsumer
|
protected void |
AbstractProxySupplier.enqueue(Message message)
put a copy of the Message in the queue of pending Messages.
|
protected void |
AbstractProxyConsumer.processMessage(Message mesg) |
void |
TypedProxyPullSupplierImpl.queueMessage(Message message) |
void |
AbstractProxySupplier.queueMessage(Message message) |