org.jacorb.notification.servant

Class StructuredProxyPushSupplierImpl

Implemented Interfaces:
Configurable, Disposable, FilterAdminOperations, FilterStage, ManageableServant, MessageConsumer, NotifySubscribeOperations, ProxySupplierOperations, QoSAdminOperations, StructuredProxyPushSupplierOperations, StructuredPushSupplierOperations
Known Direct Subclasses:
SequenceProxyPushSupplierImpl

public class StructuredProxyPushSupplierImpl
extends AbstractProxySupplier
implements StructuredProxyPushSupplierOperations

Version:
$Id: StructuredProxyPushSupplierImpl.java,v 1.7 2004/05/06 12:40:00 nicolas Exp $

Author:
Alphonse Bendt

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_

Constructor Summary

StructuredProxyPushSupplierImpl(AbstractAdmin myAdminServant, ChannelContext channelContext)

Method Summary

ProxyType
MyType()
Object
activate()
void
connect_structured_push_consumer(StructuredPushConsumer consumer)
protected void
connectionResumed()
void
deliverMessage(Message message)
TODO check error handling when push fails
void
deliverPendingData()
process pending work. push events to its connected (Push)Consumer.
protected void
disconnectClient()
void
disconnect_structured_push_supplier()
MessageConsumer
getMessageConsumer()
Servant
getServant()
List
getSubsequentFilterStages()
boolean
hasMessageConsumer()

Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier

MyAdmin, configure, connectClient, disableDelivery, dispose, enableDelivery, enqueue, getAllMessages, getAtLeastMessages, getErrorThreshold, getExecutor, getMessageBlocking, getMessageNoBlock, getPendingMessagesCount, getUpToMessages, handleFailedPushOperation, hasPendingData, isEnabled, isPushSupplier, obtain_offered_types, preActivate, setTaskExecutor, setTaskExecutor, subscription_change

Methods inherited from class org.jacorb.notification.servant.AbstractProxy

MyType, _default_POA, add_filter, assertConnected, assertNotConnected, checkStillConnected, configure, connectClient, connectionResumed, connectionSuspended, deactivate, disconnectClient, dispose, getErrorCounter, getFilters, getID, getLifetimeFilter, getORB, getPOA, getPriorityFilter, getTaskProcessor, get_all_filters, get_filter, get_qos, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isConnected, isDisposed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, preActivate, priority_filter, priority_filter, remove_all_filters, remove_filter, resetErrorCounter, resume_connection, setDisposeHook, setID, setORB, setOfferManager, setPOA, setSubscriptionManager, setTaskProcessor, set_qos, suspend_connection, validate_event_qos, validate_qos

Constructor Details

StructuredProxyPushSupplierImpl

public StructuredProxyPushSupplierImpl(AbstractAdmin myAdminServant,
                                       ChannelContext channelContext)

Method Details

MyType

public ProxyType MyType()
Specified by:
MyType in interface ProxySupplierOperations
Overrides:
MyType in interface AbstractProxy


activate

public Object activate()
Specified by:
activate in interface ManageableServant


connect_structured_push_consumer

public void connect_structured_push_consumer(StructuredPushConsumer consumer)
            throws AlreadyConnected
Specified by:
connect_structured_push_consumer in interface StructuredProxyPushSupplierOperations


connectionResumed

protected void connectionResumed()
Overrides:
connectionResumed in interface AbstractProxy


deliverMessage

public void deliverMessage(Message message)
TODO check error handling when push fails
Specified by:
deliverMessage in interface MessageConsumer


deliverPendingData

public void deliverPendingData()
process pending work. push events to its connected (Push)Consumer.
Specified by:
deliverPendingData in interface MessageConsumer


disconnectClient

protected void disconnectClient()
Overrides:
disconnectClient in interface AbstractProxy


disconnect_structured_push_supplier

public void disconnect_structured_push_supplier()
Specified by:
disconnect_structured_push_supplier in interface StructuredPushSupplierOperations


getMessageConsumer

public MessageConsumer getMessageConsumer()
Specified by:
getMessageConsumer in interface FilterStage


getServant

public Servant getServant()


getSubsequentFilterStages

public List getSubsequentFilterStages()
Specified by:
getSubsequentFilterStages in interface FilterStage


hasMessageConsumer

public boolean hasMessageConsumer()
Specified by:
hasMessageConsumer in interface FilterStage