|
||||||||||
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.AbstractProxySupplier
org.jacorb.notification.servant.ProxyPullSupplierImpl
public class ProxyPullSupplierImpl
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 | |
---|---|
Object |
activate()
|
void |
connect_any_pull_consumer(PullConsumer consumer)
|
void |
deliverMessage(Message message)
Deliver Event to the underlying Consumer. |
void |
deliverPendingData()
process pending work. push events to its connected (Push)Consumer. |
void |
disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead. |
void |
disconnect_pull_supplier()
|
protected void |
disconnectClient()
invoke the proxy specific disconnect method. |
void |
enableDelivery()
activate deliveries. this MessageConsumer may invoke remote operations again. |
MessageConsumer |
getMessageConsumer()
get the associated MessageConsumer or null. |
Servant |
getServant()
|
java.util.List |
getSubsequentFilterStages()
get FilterStages following this Node. |
boolean |
hasMessageConsumer()
check if this FilterStage has a MessageConsumer associcated. |
ProxyType |
MyType()
|
Any |
pull()
|
Any |
try_pull(BooleanHolder hasEvent)
|
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier |
---|
configure, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, getErrorThreshold, getExecutor, getMessageBlocking, getMessageNoBlock, getPendingMessagesCount, getUpToMessages, handleFailedPushOperation, hasPendingData, isEnabled, isPushSupplier, MyAdmin, obtain_offered_types, preActivate, setTaskExecutor, setTaskExecutor, subscription_change |
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.ProxySupplierOperations |
---|
lifetime_filter, lifetime_filter, MyAdmin, obtain_offered_types, priority_filter, priority_filter, 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.NotifySubscribeOperations |
---|
subscription_change |
Methods inherited from interface org.jacorb.notification.interfaces.MessageConsumer |
---|
getErrorCounter, incErrorCounter, isDisposed, resetErrorCounter |
Method Detail |
---|
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void disconnect_pull_supplier()
disconnect_pull_supplier
in interface PullSupplierOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public Any pull() throws Disconnected
pull
in interface PullSupplierOperations
Disconnected
public Any try_pull(BooleanHolder hasEvent) throws Disconnected
try_pull
in interface PullSupplierOperations
Disconnected
public void deliverMessage(Message message)
deliverMessage
in interface MessageConsumer
public void connect_any_pull_consumer(PullConsumer consumer) throws AlreadyConnected
connect_any_pull_consumer
in interface ProxyPullSupplierOperations
AlreadyConnected
public java.util.List getSubsequentFilterStages()
FilterStage
getSubsequentFilterStages
in interface FilterStage
public MessageConsumer getMessageConsumer()
FilterStage
getMessageConsumer
in interface FilterStage
public boolean hasMessageConsumer()
FilterStage
hasMessageConsumer
in interface FilterStage
public void enableDelivery()
MessageConsumer
enableDelivery
in interface MessageConsumer
enableDelivery
in class AbstractProxySupplier
public void disableDelivery()
MessageConsumer
disableDelivery
in interface MessageConsumer
disableDelivery
in class AbstractProxySupplier
public void deliverPendingData()
MessageConsumer
deliverPendingData
in interface MessageConsumer
public Servant getServant()
public Object activate()
activate
in interface ManageableServant
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |