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.AbstractProxyConsumer
org.jacorb.notification.servant.ProxyPullConsumerImpl
public class ProxyPullConsumerImpl
extends org.jacorb.notification.servant.AbstractProxyConsumer
implements ProxyPullConsumerOperations, MessageSupplier
Field Summary |
Fields inherited from class org.jacorb.notification.servant.AbstractProxyConsumer | |
messageFactory_ |
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 |
|
protected void | |
protected void | |
protected void | |
void | |
long | |
int | |
long | |
Servant | |
int | |
void |
Methods inherited from class org.jacorb.notification.servant.AbstractProxyConsumer | |
MyAdmin , checkMessageProperties , connectClient , getFirstStage , getMessageConsumer , getSubsequentFilterStages , hasMessageConsumer , isStartTimeSupported , isTimeOutSupported , obtain_subscription_types , offer_change , preActivate , schedulePullTask |
public ProxyType MyType()
- Specified by:
- MyType in interface ProxyConsumerOperations
- Overrides:
- MyType in interface AbstractProxy
public void connect_any_pull_supplier(PullSupplier pullSupplier) throws AlreadyConnected
- Specified by:
- connect_any_pull_supplier in interface ProxyPullConsumerOperations
protected void connectionResumed()
- Overrides:
- connectionResumed in interface AbstractProxy
protected void connectionSuspended()
- Overrides:
- connectionSuspended in interface AbstractProxy
protected void disconnectClient()
- Overrides:
- disconnectClient in interface AbstractProxy
public void disconnect_pull_consumer()
- Specified by:
- disconnect_pull_consumer in interface PullConsumerOperations
public long getPollInterval()
public int getPullCounter()
public long getPullTimer()
public int getSuccessfulPullCounter()
public void runPullMessage() throws Disconnected
- Specified by:
- runPullMessage in interface MessageSupplier