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.ProxyPullSupplierImpl
public class ProxyPullSupplierImpl
extends AbstractProxySupplier
implements ProxyPullSupplierOperations
Field Summary |
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_ |
Method Summary | |
ProxyType |
|
Object |
|
void |
|
void |
|
void | |
void | |
protected void | |
void | |
void | |
MessageConsumer | |
Servant | |
List | |
boolean | |
Any |
|
Any |
|
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 ProxyType MyType()
- Specified by:
- MyType in interface ProxySupplierOperations
- Overrides:
- MyType in interface AbstractProxy
public void connect_any_pull_consumer(PullConsumer consumer) throws AlreadyConnected
- Specified by:
- connect_any_pull_consumer in interface ProxyPullSupplierOperations
public void deliverMessage(Message message)
Deliver Event to the underlying Consumer. As our Consumer is a PullConsumer we simply put the Events in a Queue. The PullConsumer will pull the Events out of the Queue at a later time.
- Specified by:
- deliverMessage in interface MessageConsumer
public void deliverPendingData()
- Specified by:
- deliverPendingData in interface MessageConsumer
public void disableDelivery()
- Specified by:
- disableDelivery in interface MessageConsumer
- Overrides:
- disableDelivery in interface AbstractProxySupplier
protected void disconnectClient()
- Overrides:
- disconnectClient in interface AbstractProxy
public void disconnect_pull_supplier()
- Specified by:
- disconnect_pull_supplier in interface PullSupplierOperations
public void enableDelivery()
- 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 Any try_pull(BooleanHolder hasEvent) throws Disconnected
- Specified by:
- try_pull in interface PullSupplierOperations