org.jacorb.notification.servant

Class AbstractProxyConsumer

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

Version: $Id: AbstractProxyConsumer.java,v 1.21 2006/07/07 12:38:44 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN: extends = "AbstractProxyMBean"

Field Summary
protected SupplierAdminsupplierAdmin_
Constructor Summary
protected AbstractProxyConsumer(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Summary
protected voidcheckMessageProperties(Message m)
check if a Message is acceptable to the QoS Settings of this ProxyConsumer
protected voidclientDisconnected()
protected voidconnectClient(Object client)
FilterStagegetFirstStage()
MessageConsumergetMessageConsumer()
intgetMessageCount()
protected MessageFactorygetMessageFactory()
booleangetStartTimeSupported()
booleangetStopTimeSupported()
ListgetSubsequentFilterStages()
booleanhasMessageConsumer()
SupplierAdminMyAdmin()
protected Message[]newMessages(StructuredEvent[] events)
EventType[]obtain_subscription_types(ObtainInfoMode obtainInfoMode)
voidoffer_change(EventType[] added, EventType[] removed)
protected voidprocessMessage(Message mesg)
protected voidremoveListener()
removes the listener. subscription_change will no more be issued to the connected Supplier
protected voidschedulePullTask(MessageSupplier target)
voidsetSubsequentDestinations(List list)

Field Detail

supplierAdmin_

protected final SupplierAdmin supplierAdmin_

Constructor Detail

AbstractProxyConsumer

protected AbstractProxyConsumer(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager)

Method Detail

checkMessageProperties

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

clientDisconnected

protected final void clientDisconnected()

connectClient

protected void connectClient(Object client)

getFirstStage

public FilterStage getFirstStage()

getMessageConsumer

public final MessageConsumer getMessageConsumer()

getMessageCount

public final int getMessageCount()

UNKNOWN: description = "Total number of Messages received by this ProxyConsumer" access = "read-only"

getMessageFactory

protected MessageFactory getMessageFactory()

getStartTimeSupported

public boolean getStartTimeSupported()

UNKNOWN: description = "Does this ProxyConsumer support the per Message Option StartTime" access = "read-only"

getStopTimeSupported

public boolean getStopTimeSupported()

UNKNOWN: description = "Does this ProxyConsumer support the per Message Option TimeOut" access = "read-only"

getSubsequentFilterStages

public final List getSubsequentFilterStages()

hasMessageConsumer

public final boolean hasMessageConsumer()

MyAdmin

public final SupplierAdmin MyAdmin()

newMessages

protected Message[] newMessages(StructuredEvent[] events)

obtain_subscription_types

public final EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)

offer_change

public void offer_change(EventType[] added, EventType[] removed)

processMessage

protected void processMessage(Message mesg)

removeListener

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

schedulePullTask

protected void schedulePullTask(MessageSupplier target)

setSubsequentDestinations

public void setSubsequentDestinations(List list)