org.jacorb.notification.servant

Class AbstractProxyPushSupplier

public abstract class AbstractProxyPushSupplier extends AbstractProxySupplier implements IProxyPushSupplier

Version: $Id: AbstractProxyPushSupplier.java,v 1.9 2006/06/16 14:33:39 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN: extends = "AbstractProxySupplierMBean" name = "notification.proxy.push_failed" description = "push to ProxyPushConsumer failed" notificationType = "java.lang.String"

Field Summary
protected SemaphorepushSync_
number of concurrent push operations allowed.
Constructor Summary
AbstractProxyPushSupplier(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin)
Method Summary
voiddisableDelivery()
voidflushPendingEvents()
intgetAveragePushDuration()
intgetPushErrorCount()
intgetPushOperationCount()
StringgetRetryStrategy()
protected voidhandleFailedPushOperation(PushOperation operation, Exception error)
protected booleanisEnabled()
voidmessageQueued()
protected abstract booleanpushEvent()
voidresetErrorCounter()
voidscheduleFlush()
voidschedulePush()
voidscheduleTask(PushTaskExecutor.PushTask pushTask)
voidsetRetryStrategy(String factoryName)

Field Detail

pushSync_

protected final Semaphore pushSync_
number of concurrent push operations allowed.

Constructor Detail

AbstractProxyPushSupplier

public AbstractProxyPushSupplier(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin)

Method Detail

disableDelivery

public void disableDelivery()

flushPendingEvents

public void flushPendingEvents()

getAveragePushDuration

public int getAveragePushDuration()

UNKNOWN: description = "Average time (in ms) per Push-Operation" access = "read-only"

getPushErrorCount

public int getPushErrorCount()

UNKNOWN: description = "Number of failed Push-Operations" access = "read-only"

getPushOperationCount

public int getPushOperationCount()

UNKNOWN: description = "Total Number of Push Operations" access = "read-only"

getRetryStrategy

public String getRetryStrategy()

UNKNOWN: description = "Factory used to control RetryPolicy" access = "read-write"

handleFailedPushOperation

protected void handleFailedPushOperation(PushOperation operation, Exception error)

isEnabled

protected boolean isEnabled()

messageQueued

public final void messageQueued()

pushEvent

protected abstract boolean pushEvent()

resetErrorCounter

public void resetErrorCounter()

scheduleFlush

public void scheduleFlush()

schedulePush

public final void schedulePush()

scheduleTask

public final void scheduleTask(PushTaskExecutor.PushTask pushTask)

setRetryStrategy

public void setRetryStrategy(String factoryName)

UNKNOWN: description = "Factory used to control RetryPolicy" access = "read-write"