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.StructuredProxyPullConsumerImpl
public class StructuredProxyPullConsumerImpl
extends org.jacorb.notification.servant.AbstractProxyConsumer
implements StructuredProxyPullConsumerOperations, MessageSupplier
Field Summary | |
protected long | |
protected Sync |
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_ |
Constructor Summary | |
|
Method Summary | |
ProxyType |
|
Object |
|
void |
|
void |
|
void | |
protected void | |
protected void | |
void | |
Servant | |
EventType[] |
|
protected void | |
void |
|
protected void | |
protected 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 StructuredProxyPullConsumerImpl(AbstractAdmin admin, ChannelContext channelContext)
public ProxyType MyType()
- Specified by:
- MyType in interface ProxyConsumerOperations
- Overrides:
- MyType in interface AbstractProxy
public void connect_structured_pull_supplier(StructuredPullSupplier pullSupplier) throws AlreadyConnected
- Specified by:
- connect_structured_pull_supplier in interface StructuredProxyPullConsumerOperations
public 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_structured_pull_consumer()
- Specified by:
- disconnect_structured_pull_consumer in interface StructuredPullConsumerOperations
public EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)
- Specified by:
- obtain_subscription_types in interface ProxyConsumerOperations
- Overrides:
- obtain_subscription_types in interface org.jacorb.notification.servant.AbstractProxyConsumer
public void runPullMessage() throws Disconnected
the implementation pulls one or more events from its Supplier and hands over the pulled events to the TaskProcessor.
- Specified by:
- runPullMessage in interface MessageSupplier
protected void startTask()
protected void stopTask()