org.jacorb.notification.servant
Class ProxyPushSupplierImpl

java.lang.Object
  extended by org.jacorb.notification.servant.AbstractProxy
      extended by org.jacorb.notification.servant.AbstractProxySupplier
          extended by org.jacorb.notification.servant.AbstractProxyPushSupplier
              extended by org.jacorb.notification.servant.ProxyPushSupplierImpl
All Implemented Interfaces:
java.lang.Comparable, org.jacorb.config.Configurable, FilterStage, FilterStageSource, IProxyPushSupplier, JMXManageable, MessageConsumer, NotifyingDisposable, IServantLifecyle, AbstractProxyMBean, AbstractProxyPushSupplierMBean, AbstractProxySupplierMBean, ProxyPushSupplierImplMBean, PushSupplierOperations, QoSAdminOperations, ProxyPushSupplierOperations, ProxySupplierOperations, NotifySubscribeOperations, FilterAdminOperations, org.picocontainer.Disposable
Direct Known Subclasses:
ECProxyPushSupplierImpl

public class ProxyPushSupplierImpl
extends AbstractProxyPushSupplier
implements ProxyPushSupplierOperations, ProxyPushSupplierImplMBean

Version:
$Id: ProxyPushSupplierImpl.java,v 1.25 2009-04-25 10:08:51 andre.spiegel Exp $
Author:
Alphonse Bendt

Nested Class Summary
 
Nested classes/interfaces inherited from interface 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
ProxyPushSupplierImpl(IAdmin admin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin)
           
 
Method Summary
 void connect_any_push_consumer(PushConsumer pushConsumer)
           
protected  void connectionResumed()
          this is an extension point.
 void disconnect_push_supplier()
           
protected  void disconnectClient()
          invoke the proxy specific disconnect method.
 long getCost()
           
 ProxyType MyType()
           
 Servant newServant()
           
 boolean pushEvent()
           
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxyPushSupplier
disableDelivery, flushPendingEvents, 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, connectionSuspended, 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.ProxyPushSupplierOperations
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

ProxyPushSupplierImpl

public ProxyPushSupplierImpl(IAdmin admin,
                             ORB orb,
                             POA poa,
                             org.jacorb.config.Configuration conf,
                             TaskProcessor taskProcessor,
                             PushTaskExecutorFactory pushTaskExecutorFactory,
                             OfferManager offerManager,
                             SubscriptionManager subscriptionManager,
                             ConsumerAdmin consumerAdmin)
                      throws org.jacorb.config.ConfigurationException
Throws:
org.jacorb.config.ConfigurationException
Method Detail

MyType

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

disconnect_push_supplier

public void disconnect_push_supplier()
Specified by:
disconnect_push_supplier in interface PushSupplierOperations

disconnectClient

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

Specified by:
disconnectClient in class AbstractProxy

pushEvent

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

connect_any_push_consumer

public void connect_any_push_consumer(PushConsumer pushConsumer)
                               throws AlreadyConnected
Specified by:
connect_any_push_consumer in interface ProxyPushSupplierOperations
Throws:
AlreadyConnected

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

newServant

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

getCost

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