org.jacorb.notification.servant

Class TypedProxyPullConsumerImpl

public class TypedProxyPullConsumerImpl extends AbstractProxyConsumer implements TypedProxyPullConsumerOperations, MessageSupplier, MessageSupplierDelegate, ITypedProxy, TypedProxyPullConsumerImplMBean

Version: $Id: TypedProxyPullConsumerImpl.java,v 1.14 2006/03/06 19:53:46 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN: extends = "AbstractProxyConsumerMBean"

Constructor Summary
TypedProxyPullConsumerImpl(ITypedAdmin admin, SupplierAdmin supplierAdmin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Summary
voidconnect_typed_pull_supplier(TypedPullSupplier typedPullSupplier)
voiddisconnectClient()
voiddisconnect_pull_consumer()
StringgetSupportedInterface()
ProxyTypeMyType()
ServantnewServant()
MessageSupplierDelegate.PullResultpullMessages()
voidqueueMessages(PullResult data)
voidrunPullMessage()

Constructor Detail

TypedProxyPullConsumerImpl

public TypedProxyPullConsumerImpl(ITypedAdmin admin, SupplierAdmin supplierAdmin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)

Method Detail

connect_typed_pull_supplier

public void connect_typed_pull_supplier(TypedPullSupplier typedPullSupplier)

disconnectClient

public void disconnectClient()

disconnect_pull_consumer

public void disconnect_pull_consumer()

getSupportedInterface

public String getSupportedInterface()

UNKNOWN: access = "read-only"

MyType

public ProxyType MyType()

newServant

public Servant newServant()

pullMessages

public MessageSupplierDelegate.PullResult pullMessages()

queueMessages

public void queueMessages(PullResult data)

runPullMessage

public void runPullMessage()