org.jacorb.notification.servant
Interface MessageSupplierDelegate
- All Known Implementing Classes:
- ProxyPullConsumerImpl, SequenceProxyPullConsumerImpl, StructuredProxyPullConsumerImpl, TypedProxyPullConsumerImpl
- public interface MessageSupplierDelegate
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()