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.filter.etcl   
org.jacorb.notification.impl   
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, 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)