org.jacorb.notification.servant

Class TypedProxyPullSupplierImpl

public class TypedProxyPullSupplierImpl extends AbstractProxySupplier implements TypedProxyPullSupplierOperations, ITypedProxy, TypedProxyPullSupplierImplMBean

Version: $Id: TypedProxyPullSupplierImpl.java,v 1.16 2006/05/17 13:09:39 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN: extends = "AbstractProxySupplierMBean"

Constructor Summary
TypedProxyPullSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, DynAnyFactory dynAnyFactory, Repository repository)
Method Summary
voidconnect_typed_pull_consumer(PullConsumer pullConsumer)
voiddeliverPendingData()
voiddisconnectClient()
voiddisconnect_pull_supplier()
protected longgetCost()
intgetPendingMessagesCount()
StringgetSupportedInterface()
Objectget_typed_supplier()
ProxyTypeMyType()
ServantnewServant()
Anypull()
voidqueueMessage(Message message)
Anytry_pull(BooleanHolder booleanHolder)

Constructor Detail

TypedProxyPullSupplierImpl

public TypedProxyPullSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, DynAnyFactory dynAnyFactory, Repository repository)

Method Detail

connect_typed_pull_consumer

public void connect_typed_pull_consumer(PullConsumer pullConsumer)

deliverPendingData

public void deliverPendingData()

disconnectClient

public void disconnectClient()

disconnect_pull_supplier

public void disconnect_pull_supplier()

getCost

protected long getCost()

getPendingMessagesCount

public int getPendingMessagesCount()

getSupportedInterface

public String getSupportedInterface()

UNKNOWN: access = "read-only"

get_typed_supplier

public Object get_typed_supplier()

MyType

public ProxyType MyType()

newServant

public Servant newServant()

pull

public Any pull()

queueMessage

public void queueMessage(Message message)

try_pull

public Any try_pull(BooleanHolder booleanHolder)