|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxyConsumer
org.jacorb.notification.servant.StructuredProxyPullConsumerImpl
org.jacorb.notification.servant.SequenceProxyPullConsumerImpl
Field Summary |
Fields inherited from class org.jacorb.notification.servant.StructuredProxyPullConsumerImpl |
messageFactory_, pollInterval_, pullSync_ |
Fields inherited from class org.jacorb.notification.servant.AbstractProxy |
admin_, channelContext_, id_, isIDPublic_, lifetimeFilter_, logger_, offerManager_, priorityFilter_, qosSettings_, subscriptionManager_, thisServant_ |
Constructor Summary | |
SequenceProxyPullConsumerImpl(AbstractAdmin admin,
ChannelContext channelContext)
|
Method Summary | |
void |
connect_sequence_pull_supplier(SequencePullSupplier sequencePullSupplier)
|
void |
disconnect_sequence_pull_consumer()
|
protected void |
disconnectClient()
invoke the proxy specific disconnect method. |
Servant |
getServant()
|
ProxyType |
MyType()
|
protected void |
runPullEventInternal()
override superclass impl |
Methods inherited from class org.jacorb.notification.servant.StructuredProxyPullConsumerImpl |
activate, checkMessageProperties, configure, connect_structured_pull_supplier, connectClient, connectionResumed, connectionSuspended, disconnect_structured_pull_consumer, getFirstStage, getMessageConsumer, getSubsequentFilterStages, hasMessageConsumer, isStartTimeSupported, isTimeOutSupported, MyAdmin, obtain_subscription_types, offer_change, preActivate, runPullMessage, schedulePullTask, startTask, stopTask |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.omg.CosNotifyChannelAdmin.SequenceProxyPullConsumerOperations |
resume_connection, suspend_connection |
Methods inherited from interface org.omg.CosNotifyChannelAdmin.ProxyConsumerOperations |
MyAdmin, obtain_subscription_types, validate_event_qos |
Methods inherited from interface org.omg.CosNotification.QoSAdminOperations |
get_qos, set_qos, validate_qos |
Methods inherited from interface org.omg.CosNotifyFilter.FilterAdminOperations |
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter |
Methods inherited from interface org.omg.CosNotifyComm.NotifyPublishOperations |
offer_change |
Methods inherited from interface org.omg.CosNotifyChannelAdmin.StructuredProxyPullConsumerOperations |
resume_connection, suspend_connection |
Methods inherited from interface org.jacorb.notification.interfaces.Disposable |
dispose |
Constructor Detail |
public SequenceProxyPullConsumerImpl(AbstractAdmin admin, ChannelContext channelContext)
Method Detail |
public ProxyType MyType()
MyType
in interface ProxyConsumerOperations
MyType
in class StructuredProxyPullConsumerImpl
public void disconnect_sequence_pull_consumer()
disconnect_sequence_pull_consumer
in interface SequencePullConsumerOperations
public void connect_sequence_pull_supplier(SequencePullSupplier sequencePullSupplier) throws AlreadyConnected
connect_sequence_pull_supplier
in interface SequenceProxyPullConsumerOperations
AlreadyConnected
protected void runPullEventInternal() throws java.lang.InterruptedException, Disconnected
runPullEventInternal
in class StructuredProxyPullConsumerImpl
java.lang.InterruptedException
Disconnected
protected void disconnectClient()
AbstractProxy
disconnectClient
in class StructuredProxyPullConsumerImpl
public Servant getServant()
getServant
in class StructuredProxyPullConsumerImpl
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |