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"