Prev Class | Next Class | Frames | No Frames |
Summary: Nested | Field | Method | Constr | Detail: Nested | Field | Method | Constr |
java.lang.Object
org.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxySupplier
org.jacorb.notification.servant.StructuredProxyPullSupplierImpl
org.jacorb.notification.servant.SequenceProxyPullSupplierImpl
public class SequenceProxyPullSupplierImpl
extends StructuredProxyPullSupplierImpl
implements SequenceProxyPullSupplierOperations
Field Summary |
Fields inherited from class org.jacorb.notification.servant.StructuredProxyPullSupplierImpl | |
undefinedStructuredEvent_ |
Fields inherited from class org.jacorb.notification.servant.AbstractProxySupplier | |
scheduleDeliverPendingMessagesOperation_ |
Fields inherited from class org.jacorb.notification.servant.AbstractProxy | |
admin_ , channelContext_ , id_ , isIDPublic_ , lifetimeFilter_ , logger_ , offerManager_ , priorityFilter_ , qosSettings_ , subscriptionManager_ , thisServant_ |
Constructor Summary | |
|
Method Summary | |
ProxyType |
|
void | |
protected void | |
void | |
MessageConsumer | |
Servant | |
List | |
boolean | |
StructuredEvent[] |
|
StructuredEvent[] |
|
Methods inherited from class org.jacorb.notification.servant.StructuredProxyPullSupplierImpl | |
MyType , activate , connect_structured_pull_consumer , deliverMessage , deliverPendingData , disableDelivery , disconnectClient , disconnect_structured_pull_supplier , enableDelivery , getMessageConsumer , getServant , getSubsequentFilterStages , hasMessageConsumer , pull_structured_event , try_pull_structured_event |
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier | |
MyAdmin , configure , connectClient , disableDelivery , dispose , enableDelivery , enqueue , getAllMessages , getAtLeastMessages , getErrorThreshold , getExecutor , getMessageBlocking , getMessageNoBlock , getPendingMessagesCount , getUpToMessages , handleFailedPushOperation , hasPendingData , isEnabled , isPushSupplier , obtain_offered_types , preActivate , setTaskExecutor , setTaskExecutor , subscription_change |
public SequenceProxyPullSupplierImpl(AbstractAdmin myAdminServant, ChannelContext channelContext)
public ProxyType MyType()
- Specified by:
- MyType in interface ProxySupplierOperations
- Overrides:
- MyType in interface StructuredProxyPullSupplierImpl
public void connect_sequence_pull_consumer(SequencePullConsumer consumer) throws AlreadyConnected
- Specified by:
- connect_sequence_pull_consumer in interface SequenceProxyPullSupplierOperations
protected void disconnectClient()
- Overrides:
- disconnectClient in interface StructuredProxyPullSupplierImpl
public void disconnect_sequence_pull_supplier()
- Specified by:
- disconnect_sequence_pull_supplier in interface SequencePullSupplierOperations
public MessageConsumer getMessageConsumer()
- Specified by:
- getMessageConsumer in interface FilterStage
- Overrides:
- getMessageConsumer in interface StructuredProxyPullSupplierImpl
public Servant getServant()
- Overrides:
- getServant in interface StructuredProxyPullSupplierImpl
public List getSubsequentFilterStages()
- Specified by:
- getSubsequentFilterStages in interface FilterStage
- Overrides:
- getSubsequentFilterStages in interface StructuredProxyPullSupplierImpl
public boolean hasMessageConsumer()
- Specified by:
- hasMessageConsumer in interface FilterStage
- Overrides:
- hasMessageConsumer in interface StructuredProxyPullSupplierImpl
public StructuredEvent[] pull_structured_events(int number) throws Disconnected
- Specified by:
- pull_structured_events in interface SequencePullSupplierOperations
public StructuredEvent[] try_pull_structured_events(int number, BooleanHolder success) throws Disconnected
- Specified by:
- try_pull_structured_events in interface SequencePullSupplierOperations