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.SequenceProxyPushSupplierImpl
All Implemented Interfaces:
AbstractProxyMBean, AbstractProxyPushSupplierMBean, AbstractProxySupplierMBean, java.lang.Comparable, org.apache.avalon.framework.configuration.Configurable, Disposable, org.picocontainer.Disposable, FilterAdminOperations, FilterStage, FilterStageSource, IProxyPushSupplier, IServantLifecyle, JMXManageable, MessageConsumer, NotifyingDisposable, NotifySubscribeOperations, ProxySupplierOperations, QoSAdminOperations, SequenceProxyPushSupplierImplMBean, SequenceProxyPushSupplierOperations, SequencePushSupplierOperations

public class SequenceProxyPushSupplierImpl
extends AbstractProxyPushSupplier
implements SequenceProxyPushSupplierOperations, SequenceProxyPushSupplierImplMBean

Version:
$Id: SequenceProxyPushSupplierImpl.java,v 1.27 2006/03/07 19:23:47 alphonse.bendt Exp $
Author:
Alphonse Bendt

Nested Class Summary
 
Nested classes inherited from class org.jacorb.notification.interfaces.JMXManageable
JMXManageable.JMXCallback
 
Field Summary
 
Fields inherited from class org.jacorb.notification.servant.AbstractProxyPushSupplier
pushSync_
 
Fields inherited from class org.jacorb.notification.servant.AbstractProxy
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
 
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. invoked when resume_connection was called successfully.
protected  void connectionSuspended()
          this is an extension point.
 void disconnect_sequence_push_supplier()
           
protected  void disconnectClient()
          invoke the proxy specific disconnect method.
 void flushPendingEvents()
           
protected  long getCost()
           
 ProxyType MyType()
           
 Servant newServant()
           
 boolean pushEvent()
           
static long time2millis(long timeT)
           
 long timeT2millis()
           
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxyPushSupplier
disableDelivery, getAveragePushDuration, getPushErrorCount, getPushOperationCount, getRetryStrategy, handleFailedPushOperation, isEnabled, messageQueued, resetErrorCounter, scheduleFlush, schedulePush, scheduleTask, setRetryStrategy
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier
clearPendingMessageQueue, clientDisconnected, compareTo, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, getDiscardPolicy, getErrorThreshold, getMaxEventsPerConsumer, getMessageBlocking, getMessageConsumer, getMessageNoBlock, getMessageQueueFactory, getNumberOfDiscardedMessages, getOrderPolicy, getPendingMessagesCount, getSubsequentFilterStages, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, MyAdmin, obtain_offered_types, queueMessage, removeListener, setMaxEventsPerConsumer, subscription_change
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxy
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, deactivate, destroy, get_all_filters, get_filter, get_qos, getClientIOR, getConnected, getErrorCounter, getFilters, getID, getInterFilterGroupOperator, getJMXNotificationTypes, getJMXObjectName, getLifetimeFilter, getMBeanName, getMBeanType, getORB, getPOA, getPriorityFilter, getStatus, getTaskProcessor, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isDestroyed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, priority_filter, priority_filter, registerDisposable, remove_all_filters, remove_filter, resume_connection, sendNotification, sendNotification, set_qos, setJMXCallback, 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.jacorb.notification.servant.AbstractProxyPushSupplierMBean
getAveragePushDuration, getPushErrorCount, getPushOperationCount, getRetryStrategy, resetErrorCounter, setRetryStrategy
 
Methods inherited from interface org.jacorb.notification.servant.AbstractProxySupplierMBean
clearPendingMessageQueue, getDiscardPolicy, getMaxEventsPerConsumer, getNumberOfDiscardedMessages, getOrderPolicy, getPendingMessagesCount, setMaxEventsPerConsumer
 
Methods inherited from interface org.jacorb.notification.servant.AbstractProxyMBean
destroy, getClientIOR, getConnected, getErrorCounter, getInterFilterGroupOperator, getStatus
 
Methods inherited from interface org.jacorb.notification.interfaces.IProxyPushSupplier
incErrorCounter, isRetryAllowed
 
Methods inherited from interface org.jacorb.notification.interfaces.MessageConsumer
destroy, isDestroyed, queueMessage
 
Methods inherited from interface java.lang.Comparable
compareTo
 
Methods inherited from interface org.jacorb.notification.interfaces.NotifyingDisposable
registerDisposable
 
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()
Specified by:
MyType in interface ProxySupplierOperations
Specified by:
MyType in class AbstractProxy

pushEvent

public boolean pushEvent()
Specified by:
pushEvent in class AbstractProxyPushSupplier

flushPendingEvents

public void flushPendingEvents()
Overrides:
flushPendingEvents in class AbstractProxyPushSupplier

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 AbstractProxy

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.

Specified by:
disconnectClient in class AbstractProxy

timeT2millis

public long timeT2millis()

time2millis

public static long time2millis(long timeT)

newServant

public Servant newServant()
Specified by:
newServant in interface IServantLifecyle

getCost

protected long getCost()
Specified by:
getCost in class AbstractProxySupplier