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
public class StructuredProxyPullSupplierImpl
extends AbstractProxySupplier
implements StructuredProxyPullSupplierOperations
Field Summary | |
protected static StructuredEvent |
|
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 |
|
Object |
|
void | |
void |
|
void |
|
void |
|
protected void | |
void | |
void |
|
MessageConsumer | |
Servant | |
List | |
boolean | |
StructuredEvent | |
StructuredEvent |
|
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 |
protected static final StructuredEvent undefinedStructuredEvent_
undefined StructuredEvent that is returned on unsuccessful pull operations.
public StructuredProxyPullSupplierImpl(AbstractAdmin myAdminServant, ChannelContext channelContext)
public ProxyType MyType()
- Specified by:
- MyType in interface ProxySupplierOperations
- Overrides:
- MyType in interface AbstractProxy
public void connect_structured_pull_consumer(StructuredPullConsumer consumer) throws AlreadyConnected
- Specified by:
- connect_structured_pull_consumer in interface StructuredProxyPullSupplierOperations
public void deliverMessage(Message event)
PullSupplier always enqueues.
- Specified by:
- deliverMessage in interface MessageConsumer
public void deliverPendingData()
process pending work. push events to its connected (Push)Consumer.
- Specified by:
- deliverPendingData in interface MessageConsumer
public void disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead.
- Specified by:
- disableDelivery in interface MessageConsumer
- Overrides:
- disableDelivery in interface AbstractProxySupplier
protected void disconnectClient()
- Overrides:
- disconnectClient in interface AbstractProxy
public void disconnect_structured_pull_supplier()
- Specified by:
- disconnect_structured_pull_supplier in interface StructuredPullSupplierOperations
public void enableDelivery()
activate deliveries. this MessageConsumer may invoke remote operations again.
- Specified by:
- enableDelivery in interface MessageConsumer
- Overrides:
- enableDelivery in interface AbstractProxySupplier
public MessageConsumer getMessageConsumer()
- Specified by:
- getMessageConsumer in interface FilterStage
public List getSubsequentFilterStages()
- Specified by:
- getSubsequentFilterStages in interface FilterStage
public boolean hasMessageConsumer()
- Specified by:
- hasMessageConsumer in interface FilterStage
public StructuredEvent pull_structured_event() throws Disconnected
- Specified by:
- pull_structured_event in interface StructuredPullSupplierOperations
public StructuredEvent try_pull_structured_event(BooleanHolder hasEvent) throws Disconnected
- Specified by:
- try_pull_structured_event in interface StructuredPullSupplierOperations