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 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)
           
 

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.copyMessage()
           
protected  Message AbstractMessageTask.getMessage()
           
 Message AbstractMessageTask.removeMessage()
           
 

Methods in org.jacorb.notification.engine with parameters of type Message
 void TaskFactory.enqueueMessage(FilterStage[] nodes, Message event)
           
 void DefaultTaskFactory.enqueueMessage(FilterStage[] nodes, Message mesg)
           
 Schedulable TaskFactory.newFilterProxyConsumerTask(Message message)
           
 Schedulable DefaultTaskFactory.newFilterProxyConsumerTask(Message message)
           
 void TaskProcessor.processMessage(Message mesg)
          process a Message.
 void DefaultTaskProcessor.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.
 

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
 EvaluationResult FilterConstraint.evaluate(EvaluationContext evaluationContext, Message event)
           
 void EvaluationContext.setCurrentMessage(Message message)
           
 

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)
          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.
 

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[] AbstractBoundedEventHeap.getAllElements()
           
protected abstract  Message[] AbstractBoundedEventQueue.getAllElements()
           
protected  Message[] BoundedFifoEventQueue.getAllElements()
           
 Message[] DefaultMessageQueueAdapter.getAllMessages()
           
 Message[] MessageQueueAdapter.getAllMessages()
           
 Message[] RWLockEventQueueDecorator.getAllMessages()
           
 Message[] AbstractBoundedEventQueue.getAllMessages(boolean wait)
           
 Message[] MessageQueue.getAllMessages(boolean wait)
          get all Messages from this queue.
 Message[] DefaultMessageQueueAdapter.getAtLeastMessages(int min)
           
 Message[] MessageQueueAdapter.getAtLeastMessages(int min)
           
 Message[] RWLockEventQueueDecorator.getAtLeastMessages(int min)
           
protected abstract  Message AbstractBoundedEventQueue.getEarliestTimeout()
           
protected  Message BoundedDeadlineEventQueue.getEarliestTimeout()
           
protected  Message BoundedFifoEventQueue.getEarliestTimeout()
           
protected  Message BoundedPriorityEventQueue.getEarliestTimeout()
           
protected  Message BoundedReceiveTimeEventQueue.getEarliestTimeout()
           
protected  Message[] AbstractBoundedEventHeap.getElements(int max)
           
protected abstract  Message[] AbstractBoundedEventQueue.getElements(int max)
           
protected  Message[] BoundedFifoEventQueue.getElements(int max)
           
protected abstract  Message AbstractBoundedEventQueue.getLeastPriority()
           
protected  Message BoundedDeadlineEventQueue.getLeastPriority()
           
protected  Message BoundedFifoEventQueue.getLeastPriority()
           
protected  Message BoundedPriorityEventQueue.getLeastPriority()
           
protected  Message BoundedReceiveTimeEventQueue.getLeastPriority()
           
 Message AbstractBoundedEventQueue.getMessage(boolean wait)
           
 Message MessageQueue.getMessage(boolean wait)
          get the next Message from this queue.
 Message DefaultMessageQueueAdapter.getMessageBlocking()
           
 Message MessageQueueAdapter.getMessageBlocking()
           
 Message RWLockEventQueueDecorator.getMessageBlocking()
           
 Message DefaultMessageQueueAdapter.getMessageNoBlock()
           
 Message MessageQueueAdapter.getMessageNoBlock()
           
 Message RWLockEventQueueDecorator.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 AbstractBoundedEventHeap.getNextElement()
           
protected abstract  Message AbstractBoundedEventQueue.getNextElement()
           
protected  Message BoundedFifoEventQueue.getNextElement()
           
protected  Message AbstractBoundedEventHeap.getNextHeapElement()
           
protected abstract  Message AbstractBoundedEventQueue.getOldestElement()
           
protected  Message BoundedDeadlineEventQueue.getOldestElement()
           
protected  Message BoundedFifoEventQueue.getOldestElement()
           
protected  Message BoundedPriorityEventQueue.getOldestElement()
           
protected  Message BoundedReceiveTimeEventQueue.getOldestElement()
           
 Message[] DefaultMessageQueueAdapter.getUpToMessages(int max)
           
 Message[] MessageQueueAdapter.getUpToMessages(int max)
           
 Message[] RWLockEventQueueDecorator.getUpToMessages(int max)
           
protected abstract  Message AbstractBoundedEventQueue.getYoungestElement()
           
protected  Message BoundedDeadlineEventQueue.getYoungestElement()
           
protected  Message BoundedFifoEventQueue.getYoungestElement()
           
protected  Message BoundedPriorityEventQueue.getYoungestElement()
           
protected  Message BoundedReceiveTimeEventQueue.getYoungestElement()
           
 Message EventQueueOverflowStrategy.removeElementFromQueue(AbstractBoundedEventQueue queue)
           
protected  Message AbstractBoundedEventHeap.removeFirstElement(java.util.Comparator comp)
           
 

Methods in org.jacorb.notification.queue with parameters of type Message
protected  void AbstractBoundedEventHeap.addElement(Message event)
           
protected abstract  void AbstractBoundedEventQueue.addElement(Message message)
           
protected  void BoundedFifoEventQueue.addElement(Message e)
           
 void DefaultMessageQueueAdapter.enqeue(Message message)
           
 void MessageQueueAdapter.enqeue(Message message)
           
 void RWLockEventQueueDecorator.enqeue(Message message)
           
 void AbstractBoundedEventQueue.put(Message event)
           
 void MessageQueue.put(Message event)
          put a Message into this queue.
 

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)
           
 Message AbstractProxySupplier.getMessageBlocking()
           
protected  Message AbstractProxySupplier.getMessageNoBlock()
           
protected  Message[] AbstractProxySupplier.getUpToMessages(int max)
           
protected  Message[] AbstractProxyConsumer.newMessages(StructuredEvent[] events)
           
 

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 AbstractProxySupplier.enqueue(Message message)
          put a copy of the Message in the queue of pending Messages.
protected  void AbstractProxyConsumer.processMessage(Message mesg)
           
 void AbstractProxySupplier.queueMessage(Message message)
           
 void TypedProxyPullSupplierImpl.queueMessage(Message message)