|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in org.jacorb.notification |
---|
Methods in org.jacorb.notification that return Message | |
Message |
MessageFactory.newMessage(Any any,
IProxyConsumer consumer)
|
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent,
IProxyConsumer consumer)
|
Message |
MessageFactory.newMessage(java.lang.String interfaceName,
java.lang.String operationName,
NVList args,
IProxyConsumer consumer)
|
Message |
MessageFactory.newMessage(Property[] props)
|
Message |
MessageFactory.newMessage(Any any)
|
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent)
|
Message |
AbstractMessage.getHandle()
|
Uses of Message in org.jacorb.notification.engine |
---|
Fields in org.jacorb.notification.engine declared as Message | |
protected Message |
MessagePushOperation.message_
|
Methods in org.jacorb.notification.engine that return Message | |
Message |
AbstractMessageTask.removeMessage()
|
Message |
AbstractMessageTask.copyMessage()
|
protected Message |
AbstractMessageTask.getMessage()
|
Methods in org.jacorb.notification.engine with parameters of type Message | |
Schedulable |
TaskFactory.newFilterProxyConsumerTask(Message message)
|
void |
TaskFactory.enqueueMessage(FilterStage[] nodes,
Message event)
|
Schedulable |
DefaultTaskFactory.newFilterProxyConsumerTask(Message message)
|
void |
DefaultTaskFactory.enqueueMessage(FilterStage[] nodes,
Message mesg)
|
void |
DefaultTaskProcessor.processMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied. |
protected void |
DefaultTaskProcessor.processMessageInternal(Message event)
process a Message. create FilterTask and schedule it. |
void |
AbstractMessageTask.setMessage(Message message)
set the Message for this Task to use. |
void |
TaskProcessor.processMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied. |
Constructors in org.jacorb.notification.engine with parameters of type Message | |
MessagePushOperation(Message message)
|
Uses of Message in org.jacorb.notification.filter |
---|
Methods in org.jacorb.notification.filter that return Message | |
Message |
EvaluationContext.getCurrentMessage()
|
Methods in org.jacorb.notification.filter with parameters of type Message | |
void |
EvaluationContext.setCurrentMessage(Message message)
|
EvaluationResult |
FilterConstraint.evaluate(EvaluationContext evaluationContext,
Message event)
|
Uses of Message in org.jacorb.notification.filter.etcl |
---|
Methods in org.jacorb.notification.filter.etcl with parameters of type Message | |
EvaluationResult |
ETCLFilterConstraint.evaluate(EvaluationContext evaluationContext,
Message event)
|
Uses of Message in org.jacorb.notification.impl |
---|
Methods in org.jacorb.notification.impl that return Message | |
Message |
DefaultMessageFactory.newMessage(Any any,
IProxyConsumer consumer)
create a Message wrapping an unstructured event. |
Message |
DefaultMessageFactory.newMessage(StructuredEvent structuredEvent,
IProxyConsumer consumer)
create a Message wrapping a structured 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(Property[] props)
create a message wrapping a typed event. |
Message |
DefaultMessageFactory.newMessage(Any any)
create a Message wrapping a unstructured event. |
Message |
DefaultMessageFactory.newMessage(StructuredEvent structuredEvent)
create a message wrapping a structured event. |
Uses of Message in org.jacorb.notification.interfaces |
---|
Methods in org.jacorb.notification.interfaces with parameters of type Message | |
void |
MessageConsumer.queueMessage(Message m)
Deliver a Message to the associated Consumer. |
Uses of Message in org.jacorb.notification.queue |
---|
Methods in org.jacorb.notification.queue that return Message | |
protected Message |
BoundedPriorityEventQueue.getEarliestTimeout()
|
protected Message |
BoundedPriorityEventQueue.getOldestElement()
|
protected Message |
BoundedPriorityEventQueue.getYoungestElement()
|
protected Message |
BoundedPriorityEventQueue.getLeastPriority()
|
Message |
RWLockEventQueueDecorator.getMessageBlocking()
|
Message |
RWLockEventQueueDecorator.getMessageNoBlock()
|
Message[] |
RWLockEventQueueDecorator.getAllMessages()
|
Message[] |
RWLockEventQueueDecorator.getUpToMessages(int max)
|
Message[] |
RWLockEventQueueDecorator.getAtLeastMessages(int min)
|
protected Message |
BoundedReceiveTimeEventQueue.getEarliestTimeout()
|
protected Message |
BoundedReceiveTimeEventQueue.getLeastPriority()
|
protected Message |
BoundedReceiveTimeEventQueue.getOldestElement()
|
protected Message |
BoundedReceiveTimeEventQueue.getYoungestElement()
|
protected abstract Message |
AbstractBoundedEventQueue.getEarliestTimeout()
|
protected abstract Message |
AbstractBoundedEventQueue.getLeastPriority()
|
protected abstract Message |
AbstractBoundedEventQueue.getNextElement()
|
protected abstract Message |
AbstractBoundedEventQueue.getOldestElement()
|
protected abstract Message |
AbstractBoundedEventQueue.getYoungestElement()
|
protected abstract Message[] |
AbstractBoundedEventQueue.getElements(int max)
|
protected abstract Message[] |
AbstractBoundedEventQueue.getAllElements()
|
Message[] |
AbstractBoundedEventQueue.getAllMessages(boolean wait)
|
Message |
AbstractBoundedEventQueue.getMessage(boolean wait)
|
Message[] |
AbstractBoundedEventQueue.getMessages(int max,
boolean wait)
|
protected Message |
AbstractBoundedEventHeap.removeFirstElement(java.util.Comparator comp)
|
protected Message[] |
AbstractBoundedEventHeap.getAllElements()
|
protected Message[] |
AbstractBoundedEventHeap.getElements(int max)
|
protected Message |
AbstractBoundedEventHeap.getNextHeapElement()
|
protected Message |
AbstractBoundedEventHeap.getNextElement()
|
Message |
MessageQueue.getMessage(boolean wait)
get the next Message from this queue. which particular event is selected depends on the underlying implementation. |
Message[] |
MessageQueue.getMessages(int n,
boolean wait)
get up to n events from this queue. |
Message[] |
MessageQueue.getAllMessages(boolean wait)
get all Messages from this queue. |
Message |
MessageQueueAdapter.getMessageBlocking()
|
Message |
MessageQueueAdapter.getMessageNoBlock()
|
Message[] |
MessageQueueAdapter.getAllMessages()
|
Message[] |
MessageQueueAdapter.getUpToMessages(int max)
|
Message[] |
MessageQueueAdapter.getAtLeastMessages(int min)
|
protected Message |
BoundedFifoEventQueue.getEarliestTimeout()
|
protected Message |
BoundedFifoEventQueue.getLeastPriority()
|
protected Message |
BoundedFifoEventQueue.getNextElement()
|
protected Message |
BoundedFifoEventQueue.getOldestElement()
|
protected Message |
BoundedFifoEventQueue.getYoungestElement()
|
protected Message[] |
BoundedFifoEventQueue.getAllElements()
|
protected Message[] |
BoundedFifoEventQueue.getElements(int max)
|
protected Message |
BoundedDeadlineEventQueue.getOldestElement()
|
protected Message |
BoundedDeadlineEventQueue.getYoungestElement()
|
protected Message |
BoundedDeadlineEventQueue.getEarliestTimeout()
|
protected Message |
BoundedDeadlineEventQueue.getLeastPriority()
|
Message |
DefaultMessageQueueAdapter.getMessageBlocking()
|
Message |
DefaultMessageQueueAdapter.getMessageNoBlock()
|
Message[] |
DefaultMessageQueueAdapter.getAllMessages()
|
Message[] |
DefaultMessageQueueAdapter.getUpToMessages(int max)
|
Message[] |
DefaultMessageQueueAdapter.getAtLeastMessages(int min)
|
Message |
EventQueueOverflowStrategy.removeElementFromQueue(AbstractBoundedEventQueue queue)
|
Methods in org.jacorb.notification.queue with parameters of type Message | |
void |
RWLockEventQueueDecorator.enqeue(Message message)
|
protected abstract void |
AbstractBoundedEventQueue.addElement(Message message)
|
void |
AbstractBoundedEventQueue.put(Message event)
|
protected void |
AbstractBoundedEventHeap.addElement(Message event)
|
void |
MessageQueue.put(Message event)
put a Message into this queue. |
void |
MessageQueueAdapter.enqeue(Message message)
|
protected void |
BoundedFifoEventQueue.addElement(Message e)
|
void |
DefaultMessageQueueAdapter.enqeue(Message message)
|
Uses of Message in org.jacorb.notification.servant |
---|
Methods in org.jacorb.notification.servant that return Message | |
protected Message[] |
AbstractProxyConsumer.newMessages(StructuredEvent[] events)
|
Message |
AbstractProxySupplier.getMessageBlocking()
|
protected Message |
AbstractProxySupplier.getMessageNoBlock()
|
protected Message[] |
AbstractProxySupplier.getAllMessages()
|
protected Message[] |
AbstractProxySupplier.getUpToMessages(int max)
|
protected Message[] |
AbstractProxySupplier.getAtLeastMessages(int min)
|
Methods in org.jacorb.notification.servant with parameters of type Message | |
protected void |
AbstractProxyConsumer.checkMessageProperties(Message m)
check if a Message is acceptable to the QoS Settings of this ProxyConsumer |
protected void |
AbstractProxyConsumer.processMessage(Message mesg)
|
void |
TypedProxyPullSupplierImpl.queueMessage(Message message)
|
protected void |
AbstractProxySupplier.enqueue(Message message)
put a copy of the Message in the queue of pending Messages. |
void |
AbstractProxySupplier.queueMessage(Message message)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |