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, AbstractProxyConsumerI consumer)
           
 Message MessageFactory.newMessage(StructuredEvent structuredEvent, AbstractProxyConsumerI consumer)
           
 Message MessageFactory.newMessage(java.lang.String interfaceName, java.lang.String operationName, NVList args, AbstractProxyConsumerI 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
 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.
 Schedulable DefaultTaskFactory.newFilterProxyConsumerTask(Message message)
           
 void DefaultTaskFactory.enqueueMessage(FilterStage[] nodes, Message mesg)
           
 void AbstractMessageTask.setMessage(Message message)
          set the Message for this Task to use.
 Schedulable TaskFactory.newFilterProxyConsumerTask(Message message)
           
 void TaskFactory.enqueueMessage(FilterStage[] nodes, Message event)
           
 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
 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, AbstractProxyConsumerI consumer)
          create a Message wrapping an unstructured event.
 Message DefaultMessageFactory.newMessage(StructuredEvent structuredEvent, AbstractProxyConsumerI consumer)
          create a Message wrapping a structured event.
 Message DefaultMessageFactory.newMessage(java.lang.String interfaceName, java.lang.String operationName, NVList args, AbstractProxyConsumerI 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.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
 Message RWLockEventQueueDecorator.getMessageBlocking()
           
 Message RWLockEventQueueDecorator.getMessageNoBlock()
           
 Message[] RWLockEventQueueDecorator.getAllMessages()
           
 Message[] RWLockEventQueueDecorator.getUpToMessages(int max)
           
 Message[] RWLockEventQueueDecorator.getAtLeastMessages(int min)
           
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()
           
 Message MessageQueueAdapter.getMessageBlocking()
           
 Message MessageQueueAdapter.getMessageNoBlock()
           
 Message[] MessageQueueAdapter.getAllMessages()
           
 Message[] MessageQueueAdapter.getUpToMessages(int max)
           
 Message[] MessageQueueAdapter.getAtLeastMessages(int min)
           
 Message BasicMessageQueueAdapter.getMessageBlocking()
           
 Message BasicMessageQueueAdapter.getMessageNoBlock()
           
 Message[] BasicMessageQueueAdapter.getAllMessages()
           
 Message[] BasicMessageQueueAdapter.getUpToMessages(int max)
           
 Message[] BasicMessageQueueAdapter.getAtLeastMessages(int min)
           
abstract  Message EventQueueOverflowStrategy.removeElementFromQueue(AbstractBoundedEventQueue queue)
           
 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.
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)
           
 

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

Constructors in org.jacorb.notification.queue with parameters of type Message
HeapEntry(Message event, long order)
           
 

Uses of Message in org.jacorb.notification.servant
 

Methods in org.jacorb.notification.servant that return Message
 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 TypedProxyPullSupplierImpl.deliverMessage(Message message)
           
protected  void AbstractProxySupplier.enqueue(Message message)
          put a copy of the Message in the queue of pending Messages.
 void AbstractProxySupplier.deliverMessage(Message message)