org.jacorb.notification.servant
Interface MessageSupplierDelegate

All Known Implementing Classes:
ECProxyPullConsumerImpl, 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

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

void queueMessages(MessageSupplierDelegate.PullResult data)

getConnected

boolean getConnected()

isSuspended

boolean isSuspended()