|
|||||||||||
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.StructuredProxyPullSupplierImpl
Field Summary | |
protected static StructuredEvent |
undefinedStructuredEvent_
undefined StructuredEvent that is returned on unsuccessful pull operations. |
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_ |
Constructor Summary | |
StructuredProxyPullSupplierImpl(AbstractAdmin myAdminServant,
ChannelContext channelContext)
|
Method Summary | |
Object |
activate()
|
void |
connect_structured_pull_consumer(StructuredPullConsumer consumer)
|
void |
deliverMessage(Message event)
PullSupplier always enqueues. |
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_structured_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()
|
StructuredEvent |
pull_structured_event()
|
StructuredEvent |
try_pull_structured_event(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 |
Field Detail |
protected static final StructuredEvent undefinedStructuredEvent_
Constructor Detail |
public StructuredProxyPullSupplierImpl(AbstractAdmin myAdminServant, ChannelContext channelContext)
Method Detail |
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void connect_structured_pull_consumer(StructuredPullConsumer consumer) throws AlreadyConnected
connect_structured_pull_consumer
in interface StructuredProxyPullSupplierOperations
AlreadyConnected
public StructuredEvent pull_structured_event() throws Disconnected
pull_structured_event
in interface StructuredPullSupplierOperations
Disconnected
public StructuredEvent try_pull_structured_event(BooleanHolder hasEvent) throws Disconnected
try_pull_structured_event
in interface StructuredPullSupplierOperations
Disconnected
public void disconnect_structured_pull_supplier()
disconnect_structured_pull_supplier
in interface StructuredPullSupplierOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public void deliverMessage(Message event)
deliverMessage
in interface MessageConsumer
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 disableDelivery()
MessageConsumer
disableDelivery
in interface MessageConsumer
disableDelivery
in class AbstractProxySupplier
public void enableDelivery()
MessageConsumer
enableDelivery
in interface MessageConsumer
enableDelivery
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 |