|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in org.jacorb.notification |
---|
Methods in org.jacorb.notification that return Message | |
---|---|
Message |
AbstractMessage.getHandle()
|
Message |
MessageFactory.newMessage(Any any)
|
Message |
MessageFactory.newMessage(Any any,
AbstractProxyConsumerI consumer)
|
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent)
|
Message |
MessageFactory.newMessage(StructuredEvent structuredEvent,
AbstractProxyConsumerI consumer)
|
Uses of Message in org.jacorb.notification.engine |
---|
Fields in org.jacorb.notification.engine declared as Message | |
---|---|
protected Message |
AbstractTask.message_
|
protected Message |
PushOperation.message_
|
Methods in org.jacorb.notification.engine that return Message | |
---|---|
Message |
AbstractTask.copyMessage()
|
Message |
AbstractTask.removeMessage()
|
Methods in org.jacorb.notification.engine with parameters of type Message | |
---|---|
void |
TaskProcessor.processMessage(Message mesg)
process a Message. the various settings for the Message (timeout, starttime, stoptime) are checked and applied. |
protected void |
TaskProcessor.processMessageInternal(Message event)
process a Message. create FilterTask and schedule it. |
void |
AbstractTask.setMessage(Message event)
set the Message for this Task to use. |
Constructors in org.jacorb.notification.engine with parameters of type Message | |
---|---|
PushAnyOperation(PushConsumer pushConsumer,
Message message)
|
|
PushOperation(Message message)
|
|
PushStructuredOperation(StructuredPushConsumer pushConsumer,
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 | |
---|---|
EvaluationResult |
FilterConstraint.evaluate(EvaluationContext evaluationContext,
Message event)
|
void |
EvaluationContext.setCurrentMessage(Message message)
|
Uses of Message in org.jacorb.notification.interfaces |
---|
Methods in org.jacorb.notification.interfaces with parameters of type Message | |
---|---|
void |
MessageConsumer.deliverMessage(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 abstract Message[] |
AbstractBoundedEventQueue.getAllElements()
|
protected Message[] |
BoundedDeadlineEventQueue.getAllElements()
|
protected Message[] |
BoundedFifoEventQueue.getAllElements()
|
protected Message[] |
BoundedPriorityEventQueue.getAllElements()
|
Message[] |
AbstractBoundedEventQueue.getAllEvents(boolean wait)
|
Message[] |
EventQueue.getAllEvents(boolean wait)
get all Messages from this queue. |
protected abstract Message |
AbstractBoundedEventQueue.getEarliestTimeout()
|
protected Message |
BoundedDeadlineEventQueue.getEarliestTimeout()
|
protected Message |
BoundedFifoEventQueue.getEarliestTimeout()
|
protected Message |
BoundedPriorityEventQueue.getEarliestTimeout()
|
protected abstract Message[] |
AbstractBoundedEventQueue.getElements(int max)
|
protected Message[] |
BoundedDeadlineEventQueue.getElements(int max)
|
protected Message[] |
BoundedFifoEventQueue.getElements(int max)
|
protected Message[] |
BoundedPriorityEventQueue.getElements(int max)
|
Message |
AbstractBoundedEventQueue.getEvent(boolean wait)
|
Message |
EventQueue.getEvent(boolean wait)
get the next Message from this queue. which particular event is selected depends on the underlying implementation. |
Message[] |
AbstractBoundedEventQueue.getEvents(int max,
boolean wait)
|
Message[] |
EventQueue.getEvents(int n,
boolean wait)
get up to n events from this queue. |
protected abstract Message |
AbstractBoundedEventQueue.getLeastPriority()
|
protected Message |
BoundedDeadlineEventQueue.getLeastPriority()
|
protected Message |
BoundedFifoEventQueue.getLeastPriority()
|
protected Message |
BoundedPriorityEventQueue.getLeastPriority()
|
protected abstract Message |
AbstractBoundedEventQueue.getNextElement()
|
protected Message |
BoundedDeadlineEventQueue.getNextElement()
|
protected Message |
BoundedFifoEventQueue.getNextElement()
|
protected Message |
BoundedPriorityEventQueue.getNextElement()
|
protected abstract Message |
AbstractBoundedEventQueue.getOldestElement()
|
protected Message |
BoundedDeadlineEventQueue.getOldestElement()
|
protected Message |
BoundedFifoEventQueue.getOldestElement()
|
protected Message |
BoundedPriorityEventQueue.getOldestElement()
|
protected abstract Message |
AbstractBoundedEventQueue.getYoungestElement()
|
protected Message |
BoundedDeadlineEventQueue.getYoungestElement()
|
protected Message |
BoundedFifoEventQueue.getYoungestElement()
|
protected Message |
BoundedPriorityEventQueue.getYoungestElement()
|
abstract Message |
EventQueueOverflowStrategy.removeElementFromQueue(AbstractBoundedEventQueue queue)
|
Methods in org.jacorb.notification.queue with parameters of type Message | |
---|---|
protected abstract void |
AbstractBoundedEventQueue.addElement(Message event)
|
protected void |
BoundedDeadlineEventQueue.addElement(Message event)
|
protected void |
BoundedFifoEventQueue.addElement(Message e)
|
protected void |
BoundedPriorityEventQueue.addElement(Message event)
|
void |
AbstractBoundedEventQueue.put(Message event)
|
void |
EventQueue.put(Message event)
put a Message into this queue. |
protected void |
BoundedFifoEventQueue.removeElement(Message e)
|
Uses of Message in org.jacorb.notification.servant |
---|
Methods in org.jacorb.notification.servant that return Message | |
---|---|
protected Message[] |
AbstractProxySupplier.getAllMessages()
|
protected Message[] |
AbstractProxySupplier.getAtLeastMessages(int min)
|
protected Message |
AbstractProxySupplier.getMessageBlocking()
|
protected Message |
AbstractProxySupplier.getMessageNoBlock()
|
protected Message[] |
AbstractProxySupplier.getUpToMessages(int max)
|
Methods in org.jacorb.notification.servant with parameters of type Message | |
---|---|
void |
ProxyPullSupplierImpl.deliverMessage(Message message)
Deliver Event to the underlying Consumer. |
void |
ProxyPushSupplierImpl.deliverMessage(Message message)
|
void |
SequenceProxyPushSupplierImpl.deliverMessage(Message event)
|
void |
StructuredProxyPullSupplierImpl.deliverMessage(Message event)
PullSupplier always enqueues. |
void |
StructuredProxyPushSupplierImpl.deliverMessage(Message message)
TODO check error handling when push fails |
protected void |
AbstractProxySupplier.enqueue(Message message)
put a Message in the queue of pending Messages. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |