org.jacorb.notification.servant
Class TypedProxyPullSupplierImpl

java.lang.Object
  extended byorg.jacorb.notification.servant.AbstractProxy
      extended byorg.jacorb.notification.servant.AbstractProxySupplier
          extended byorg.jacorb.notification.servant.TypedProxyPullSupplierImpl
All Implemented Interfaces:
java.lang.Comparable, org.apache.avalon.framework.configuration.Configurable, org.picocontainer.Disposable, Disposable, FilterAdminOperations, FilterStage, FilterStageSource, ITypedProxy, ManageableServant, MessageConsumer, NotifySubscribeOperations, ProxySupplierOperations, PullSupplierOperations, QoSAdminOperations, TypedProxyPullSupplierOperations, TypedPullSupplierOperations, TypedPullSupplierOperations

public class TypedProxyPullSupplierImpl
extends AbstractProxySupplier
implements TypedProxyPullSupplierOperations, ITypedProxy

Version:
$Id: TypedProxyPullSupplierImpl.java,v 1.8 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
TypedProxyPullSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, DynAnyFactory dynAnyFactory, Repository repository)
           
 
Method Summary
 Object activate()
           
 void connect_typed_pull_consumer(PullConsumer pullConsumer)
           
 void deliverMessage(Message message)
          Deliver a Message to the associated Consumer.
 void deliverPendingData()
           
 void disconnect_pull_supplier()
           
 void disconnectClient()
          invoke the proxy specific disconnect method.
 Object get_typed_supplier()
           
protected  long getCost()
           
 MessageConsumer getMessageConsumer()
          get the associated MessageConsumer or null.
 Servant getServant()
           
 java.util.List getSubsequentFilterStages()
           
 ProxyType MyType()
           
 Any pull()
           
 Any try_pull(BooleanHolder booleanHolder)
           
 
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier
compareTo, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, getErrorThreshold, getMessageBlocking, getMessageNoBlock, getMessageQueueFactory, getPendingMessagesCount, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, messageDelivered, 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, connectionResumed, connectionSuspended, 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, resetErrorCounter, 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.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.interfaces.MessageConsumer
destroy, isDisposed
 

Constructor Detail

TypedProxyPullSupplierImpl

public TypedProxyPullSupplierImpl(ITypedAdmin admin,
                                  ConsumerAdmin consumerAdmin,
                                  ORB orb,
                                  POA poa,
                                  org.apache.avalon.framework.configuration.Configuration conf,
                                  TaskProcessor taskProcessor,
                                  OfferManager offerManager,
                                  SubscriptionManager subscriptionManager,
                                  DynAnyFactory dynAnyFactory,
                                  Repository repository)
                           throws org.apache.avalon.framework.configuration.ConfigurationException
Method Detail

pull

public Any pull()
         throws Disconnected
Specified by:
pull in interface PullSupplierOperations
Throws:
Disconnected

try_pull

public Any try_pull(BooleanHolder booleanHolder)
             throws Disconnected
Specified by:
try_pull in interface PullSupplierOperations
Throws:
Disconnected

disconnect_pull_supplier

public void disconnect_pull_supplier()
Specified by:
disconnect_pull_supplier in interface PullSupplierOperations

connect_typed_pull_consumer

public void connect_typed_pull_consumer(PullConsumer pullConsumer)
                                 throws AlreadyConnected
Specified by:
connect_typed_pull_consumer in interface TypedProxyPullSupplierOperations
Throws:
AlreadyConnected

get_typed_supplier

public Object get_typed_supplier()
Specified by:
get_typed_supplier in interface TypedPullSupplierOperations

MyType

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

getSubsequentFilterStages

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

getMessageConsumer

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

Specified by:
getMessageConsumer in interface FilterStage

getServant

public Servant getServant()
Specified by:
getServant in class AbstractProxy

activate

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

deliverMessage

public void deliverMessage(Message message)
Description copied from interface: MessageConsumer
Deliver a Message to the associated Consumer.

Specified by:
deliverMessage in interface MessageConsumer
Overrides:
deliverMessage in class AbstractProxySupplier

deliverPendingData

public void deliverPendingData()

disconnectClient

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

Specified by:
disconnectClient in class AbstractProxy

getCost

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