org.jacorb.notification.servant
Interface MessageSupplierDelegate

All Known Implementing Classes:
ProxyPullConsumerImpl, SequenceProxyPullConsumerImpl, StructuredProxyPullConsumerImpl, TypedProxyPullConsumerImpl

public interface MessageSupplierDelegate


Nested Class Summary
static class MessageSupplierDelegate.PullResult
           
 
Method Summary
 boolean getConnected()
           
 boolean isSuspended()
           
 MessageSupplierDelegate.PullResult pullMessages()
          the implementation pulls one or more events from its Supplier and hands over the pulled events to the TaskProcessor.
 void queueMessages(MessageSupplierDelegate.PullResult data)
           
 

Method Detail

pullMessages

public MessageSupplierDelegate.PullResult pullMessages()
                                                throws Disconnected
the implementation pulls one or more events from its Supplier and hands over the pulled events to the TaskProcessor.

Throws:
Disconnected

queueMessages

public void queueMessages(MessageSupplierDelegate.PullResult data)

getConnected

public boolean getConnected()

isSuspended

public boolean isSuspended()