org.jacorb.notification.servant
public abstract class AbstractProxyPushSupplier extends AbstractProxySupplier implements IProxyPushSupplier
Version: $Id: AbstractProxyPushSupplier.java,v 1.9 2006/06/16 14:33:39 alphonse.bendt Exp $
UNKNOWN: extends = "AbstractProxySupplierMBean" name = "notification.proxy.push_failed" description = "push to ProxyPushConsumer failed" notificationType = "java.lang.String"
| Field Summary | |
|---|---|
| protected Semaphore | pushSync_
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 | |
|---|---|
| void | disableDelivery() |
| void | flushPendingEvents() |
| int | getAveragePushDuration() |
| int | getPushErrorCount() |
| int | getPushOperationCount() |
| String | getRetryStrategy() |
| protected void | handleFailedPushOperation(PushOperation operation, Exception error) |
| protected boolean | isEnabled() |
| void | messageQueued() |
| protected abstract boolean | pushEvent() |
| void | resetErrorCounter() |
| void | scheduleFlush() |
| void | schedulePush() |
| void | scheduleTask(PushTaskExecutor.PushTask pushTask) |
| void | setRetryStrategy(String factoryName) |
UNKNOWN: description = "Average time (in ms) per Push-Operation" access = "read-only"
UNKNOWN: description = "Number of failed Push-Operations" access = "read-only"
UNKNOWN: description = "Total Number of Push Operations" access = "read-only"
UNKNOWN: description = "Factory used to control RetryPolicy" access = "read-write"
UNKNOWN: description = "Factory used to control RetryPolicy" access = "read-write"