org.jacorb.notification.servant
Class AbstractProxyConsumer

java.lang.Object
  extended byorg.jacorb.notification.servant.AbstractProxy
      extended byorg.jacorb.notification.servant.AbstractProxyConsumer
All Implemented Interfaces:
AbstractProxyConsumerMBean, AbstractProxyMBean, org.apache.avalon.framework.configuration.Configurable, Disposable, org.picocontainer.Disposable, FilterAdminOperations, FilterStage, FilterStageSource, IProxyConsumer, IServantLifecyle, JMXManageable, NotifyingDisposable, NotifyPublishOperations, QoSAdminOperations
Direct Known Subclasses:
ProxyPullConsumerImpl, ProxyPushConsumerImpl, SequenceProxyPullConsumerImpl, SequenceProxyPushConsumerImpl, StructuredProxyPullConsumerImpl, StructuredProxyPushConsumerImpl, TypedProxyPullConsumerImpl, TypedProxyPushConsumerImpl

public abstract class AbstractProxyConsumer
extends AbstractProxy
implements IProxyConsumer, NotifyPublishOperations, AbstractProxyConsumerMBean

Version:
$Id: AbstractProxyConsumer.java,v 1.20 2006/01/09 21:39:36 alphonse.bendt Exp $
Author:
Alphonse Bendt

Nested Class Summary
 
Nested classes inherited from class org.jacorb.notification.interfaces.JMXManageable
JMXManageable.JMXCallback
 
Field Summary
protected  SupplierAdmin supplierAdmin_
           
 
Fields inherited from class org.jacorb.notification.servant.AbstractProxy
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
 
Constructor Summary
protected AbstractProxyConsumer(IAdmin admin, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager)
           
 
Method Summary
protected  void checkMessageProperties(Message m)
          check if a Message is acceptable to the QoS Settings of this ProxyConsumer
protected  void clientDisconnected()
           
protected  void connectClient(Object client)
           
 FilterStage getFirstStage()
           
 MessageConsumer getMessageConsumer()
          get the associated MessageConsumer or null.
 int getMessageCount()
           
protected  MessageFactory getMessageFactory()
           
 boolean getStartTimeSupported()
           
 boolean getStopTimeSupported()
           
 java.util.List getSubsequentFilterStages()
           
 boolean hasMessageConsumer()
          check if this FilterStage has a MessageConsumer associcated.
 SupplierAdmin MyAdmin()
           
protected  Message[] newMessages(StructuredEvent[] events)
           
 EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)
           
 void offer_change(EventType[] added, EventType[] removed)
           
protected  void processMessage(Message mesg)
           
protected  void removeListener()
          removes the listener. subscription_change will no more be issued to the connected Supplier
protected  void schedulePullTask(MessageSupplier target)
           
 void setSubsequentDestinations(java.util.List list)
           
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxy
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, connectionResumed, connectionSuspended, deactivate, destroy, disconnectClient, dispose, 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, MyType, priority_filter, priority_filter, registerDisposable, remove_all_filters, remove_filter, resetErrorCounter, 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.jacorb.notification.servant.AbstractProxyMBean
destroy, getClientIOR, getConnected, getErrorCounter, getInterFilterGroupOperator, getStatus, resetErrorCounter
 
Methods inherited from interface org.jacorb.notification.lifecycle.IServantLifecyle
newServant
 

Field Detail

supplierAdmin_

protected final SupplierAdmin supplierAdmin_
Constructor Detail

AbstractProxyConsumer

protected AbstractProxyConsumer(IAdmin admin,
                                ORB orb,
                                POA poa,
                                org.apache.avalon.framework.configuration.Configuration conf,
                                TaskProcessor taskProcessor,
                                MessageFactory messageFactory,
                                SupplierAdmin supplierAdmin,
                                OfferManager offerManager,
                                SubscriptionManager subscriptionManager)
Method Detail

getMessageFactory

protected MessageFactory getMessageFactory()

getSubsequentFilterStages

public final java.util.List getSubsequentFilterStages()
Specified by:
getSubsequentFilterStages in interface FilterStageSource

setSubsequentDestinations

public void setSubsequentDestinations(java.util.List list)

schedulePullTask

protected void schedulePullTask(MessageSupplier target)

checkMessageProperties

protected void checkMessageProperties(Message m)
check if a Message is acceptable to the QoS Settings of this ProxyConsumer


getFirstStage

public FilterStage getFirstStage()
Specified by:
getFirstStage in interface IProxyConsumer

getStopTimeSupported

public boolean getStopTimeSupported()
Specified by:
getStopTimeSupported in interface IProxyConsumer

getStartTimeSupported

public boolean getStartTimeSupported()
Specified by:
getStartTimeSupported in interface IProxyConsumer

MyAdmin

public final SupplierAdmin MyAdmin()

getMessageConsumer

public final MessageConsumer getMessageConsumer()
Description copied from interface: FilterStage
get the associated MessageConsumer or null.

Specified by:
getMessageConsumer in interface FilterStage

hasMessageConsumer

public final boolean hasMessageConsumer()
Description copied from interface: FilterStage
check if this FilterStage has a MessageConsumer associcated.

Specified by:
hasMessageConsumer in interface FilterStage

offer_change

public void offer_change(EventType[] added,
                         EventType[] removed)
                  throws InvalidEventType
Specified by:
offer_change in interface NotifyPublishOperations
Throws:
InvalidEventType

obtain_subscription_types

public final EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)

removeListener

protected void removeListener()
removes the listener. subscription_change will no more be issued to the connected Supplier

Specified by:
removeListener in class AbstractProxy

clientDisconnected

protected final void clientDisconnected()
Specified by:
clientDisconnected in class AbstractProxy

connectClient

protected void connectClient(Object client)
Overrides:
connectClient in class AbstractProxy

processMessage

protected void processMessage(Message mesg)

getMessageCount

public final int getMessageCount()
Specified by:
getMessageCount in interface AbstractProxyConsumerMBean

newMessages

protected Message[] newMessages(StructuredEvent[] events)