org.jacorb.notification.servant
Class SequenceProxyPushSupplierImpl

java.lang.Object
  extended byorg.jacorb.notification.servant.AbstractProxy
      extended byorg.jacorb.notification.servant.AbstractProxySupplier
          extended byorg.jacorb.notification.servant.AbstractProxyPushSupplier
              extended byorg.jacorb.notification.servant.StructuredProxyPushSupplierImpl
                  extended byorg.jacorb.notification.servant.SequenceProxyPushSupplierImpl
All Implemented Interfaces:
CallbackingDisposable, java.lang.Comparable, org.apache.avalon.framework.configuration.Configurable, org.picocontainer.Disposable, Disposable, FilterAdminOperations, FilterStage, FilterStageSource, IProxyPushSupplier, ManageableServant, MessageConsumer, NotifySubscribeOperations, ProxySupplierOperations, QoSAdminOperations, SequenceProxyPushSupplierOperations, SequencePushSupplierOperations, StructuredProxyPushSupplierOperations, StructuredPushSupplierOperations

public class SequenceProxyPushSupplierImpl
extends StructuredProxyPushSupplierImpl
implements SequenceProxyPushSupplierOperations

Version:
$Id: SequenceProxyPushSupplierImpl.java,v 1.17 2005/04/27 10:45:46 alphonse.bendt Exp $
Author:
Alphonse Bendt

Field Summary
 
Fields inherited from class org.jacorb.notification.servant.AbstractProxy
id_, isIDPublic_, lifetimeFilter_, logger_, offerManager_, priorityFilter_, qosSettings_, subscriptionManager_, thisServant_
 
Constructor Summary
SequenceProxyPushSupplierImpl(IAdmin admin, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration config, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin)
           
 
Method Summary
 void connect_sequence_push_consumer(SequencePushConsumer consumer)
           
protected  void connectionResumed()
          this is an extension point.
protected  void connectionSuspended()
          this is an extension point.
 void disconnect_sequence_push_supplier()
           
protected  void disconnectClient()
          invoke the proxy specific disconnect method.
protected  long getCost()
           
 Servant getServant()
           
 ProxyType MyType()
          this callback is called by the TimerDaemon.
 void pushPendingData()
          overrides the superclass version.
 
Methods inherited from class org.jacorb.notification.servant.StructuredProxyPushSupplierImpl
activate, connect_structured_push_consumer, disconnect_structured_push_supplier, getMessageConsumer, getSubsequentFilterStages
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxyPushSupplier
disableDelivery, handleFailedPushOperation, isEnabled, messageDelivered, resetErrorCounter, schedulePush, schedulePush
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier
compareTo, connectClient, deliverMessage, dispose, enqueue, getAllMessages, getAtLeastMessages, getErrorThreshold, getMessageBlocking, getMessageNoBlock, getMessageQueueFactory, getPendingMessagesCount, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, MyAdmin, obtain_offered_types, removeListener, subscription_change
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxy
_default_POA, add_filter, addDisposeHook, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, deactivate, destroy, get_all_filters, get_filter, get_qos, getErrorCounter, getFilters, getID, getLifetimeFilter, getORB, getPOA, getPriorityFilter, getTaskProcessor, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isConnected, isDisposed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, priority_filter, priority_filter, remove_all_filters, remove_filter, resume_connection, set_qos, suspend_connection, validate_event_qos, validate_qos
 
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.SequenceProxyPushSupplierOperations
resume_connection, suspend_connection
 
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.omg.CosNotifyChannelAdmin.StructuredProxyPushSupplierOperations
resume_connection, suspend_connection
 
Methods inherited from interface org.jacorb.notification.interfaces.IProxyPushSupplier
hasPendingData, incErrorCounter, isRetryAllowed
 
Methods inherited from interface org.jacorb.notification.interfaces.MessageConsumer
deliverMessage, destroy, isDisposed
 
Methods inherited from interface java.lang.Comparable
compareTo
 
Methods inherited from interface org.jacorb.notification.interfaces.CallbackingDisposable
addDisposeHook
 
Methods inherited from interface org.picocontainer.Disposable
dispose
 

Constructor Detail

SequenceProxyPushSupplierImpl

public SequenceProxyPushSupplierImpl(IAdmin admin,
                                     ORB orb,
                                     POA poa,
                                     org.apache.avalon.framework.configuration.Configuration config,
                                     TaskProcessor taskProcessor,
                                     PushTaskExecutorFactory pushTaskExecutorFactory,
                                     OfferManager offerManager,
                                     SubscriptionManager subscriptionManager,
                                     ConsumerAdmin consumerAdmin)
                              throws org.apache.avalon.framework.configuration.ConfigurationException
Method Detail

MyType

public ProxyType MyType()
this callback is called by the TimerDaemon. Check if there are pending Events and deliver them to the Consumer. As there's only one TimerDaemon its important to block the daemon only a minimal amount of time. Therefor the Callback does not do the actual delivery. Instead a DeliverTask is scheduled for this Supplier.

Specified by:
MyType in interface ProxySupplierOperations
Overrides:
MyType in class StructuredProxyPushSupplierImpl

pushPendingData

public void pushPendingData()
overrides the superclass version.

Specified by:
pushPendingData in interface IProxyPushSupplier
Overrides:
pushPendingData in class StructuredProxyPushSupplierImpl

connect_sequence_push_consumer

public void connect_sequence_push_consumer(SequencePushConsumer consumer)
                                    throws AlreadyConnected,
                                           TypeError
Specified by:
connect_sequence_push_consumer in interface SequenceProxyPushSupplierOperations
Throws:
AlreadyConnected
TypeError

connectionResumed

protected void connectionResumed()
Description copied from class: AbstractProxy
this is an extension point. invoked when resume_connection was called successfully.

Overrides:
connectionResumed in class StructuredProxyPushSupplierImpl

connectionSuspended

protected void connectionSuspended()
Description copied from class: AbstractProxy
this is an extension point.

Overrides:
connectionSuspended in class AbstractProxy

disconnect_sequence_push_supplier

public void disconnect_sequence_push_supplier()
Specified by:
disconnect_sequence_push_supplier in interface SequencePushSupplierOperations

disconnectClient

protected void disconnectClient()
Description copied from class: AbstractProxy
invoke the proxy specific disconnect method.

Overrides:
disconnectClient in class StructuredProxyPushSupplierImpl

getServant

public Servant getServant()
Overrides:
getServant in class StructuredProxyPushSupplierImpl

getCost

protected long getCost()
Overrides:
getCost in class StructuredProxyPushSupplierImpl