Uses of Interface
org.jacorb.notification.interfaces.Message

Packages that use Message
org.jacorb.notification   
org.jacorb.notification.engine   
org.jacorb.notification.filter   
org.jacorb.notification.interfaces   
org.jacorb.notification.queue   
org.jacorb.notification.servant   
 

Uses of Message in org.jacorb.notification
 

Methods in org.jacorb.notification that return Message
 Message MessageFactory.newMessage(Any any, AbstractProxyConsumerI consumer)
           
 Message MessageFactory.newMessage(StructuredEvent structuredEvent, AbstractProxyConsumerI consumer)
           
 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 PushOperation.message_
           
protected  Message AbstractTask.message_
           
 

Methods in org.jacorb.notification.engine that return Message
 Message AbstractTask.removeMessage()
           
 Message AbstractTask.copyMessage()
           
 

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
PushStructuredOperation(StructuredPushConsumer pushConsumer, Message message)
           
PushOperation(Message message)
           
PushAnyOperation(PushConsumer 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
abstract  Message EventQueueOverflowStrategy.removeElementFromQueue(AbstractBoundedEventQueue queue)
           
 Message EventQueue.getEvent(boolean wait)
          get the next Message from this queue. which particular event is selected depends on the underlying implementation.
 Message[] EventQueue.getEvents(int n, boolean wait)
          get up to n events from this queue.
 Message[] EventQueue.getAllEvents(boolean wait)
          get all Messages from this queue.
protected  Message BoundedPriorityEventQueue.getNextElement()
           
protected  Message BoundedPriorityEventQueue.getEarliestTimeout()
           
protected  Message BoundedPriorityEventQueue.getOldestElement()
           
protected  Message BoundedPriorityEventQueue.getYoungestElement()
           
protected  Message BoundedPriorityEventQueue.getLeastPriority()
           
protected  Message[] BoundedPriorityEventQueue.getElements(int max)
           
protected  Message[] BoundedPriorityEventQueue.getAllElements()
           
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.getNextElement()
           
protected  Message BoundedDeadlineEventQueue.getOldestElement()
           
protected  Message BoundedDeadlineEventQueue.getYoungestElement()
           
protected  Message BoundedDeadlineEventQueue.getEarliestTimeout()
           
protected  Message BoundedDeadlineEventQueue.getLeastPriority()
           
protected  Message[] BoundedDeadlineEventQueue.getElements(int max)
           
protected  Message[] BoundedDeadlineEventQueue.getAllElements()
           
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.getAllEvents(boolean wait)
           
 Message AbstractBoundedEventQueue.getEvent(boolean wait)
           
 Message[] AbstractBoundedEventQueue.getEvents(int max, boolean wait)
           
 

Methods in org.jacorb.notification.queue with parameters of type Message
 void EventQueue.put(Message event)
          put a Message into this queue.
protected  void BoundedPriorityEventQueue.addElement(Message event)
           
protected  void BoundedFifoEventQueue.addElement(Message e)
           
protected  void BoundedFifoEventQueue.removeElement(Message e)
           
protected  void BoundedDeadlineEventQueue.addElement(Message event)
           
protected abstract  void AbstractBoundedEventQueue.addElement(Message event)
           
 void AbstractBoundedEventQueue.put(Message event)
           
 

Uses of Message in org.jacorb.notification.servant
 

Methods in org.jacorb.notification.servant that return Message
protected  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
 void StructuredProxyPushSupplierImpl.deliverMessage(Message message)
          TODO check error handling when push fails
 void StructuredProxyPullSupplierImpl.deliverMessage(Message event)
          PullSupplier always enqueues.
 void SequenceProxyPushSupplierImpl.deliverMessage(Message event)
           
 void ProxyPushSupplierImpl.deliverMessage(Message message)
           
 void ProxyPullSupplierImpl.deliverMessage(Message message)
          Deliver Event to the underlying Consumer.
protected  void AbstractProxySupplier.enqueue(Message message)
          put a Message in the queue of pending Messages.