public abstract class AbstractProxyPushSupplier extends AbstractProxySupplier implements IProxyPushSupplier
JMXManageable.JMXCallback
Modifier and Type | Field and Description |
---|---|
protected Semaphore |
pushSync_
number of concurrent push operations allowed.
|
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
AbstractProxyPushSupplier(IAdmin admin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
disableDelivery()
Disable Deliveries.
|
void |
flushPendingEvents() |
int |
getAveragePushDuration() |
int |
getPushErrorCount() |
int |
getPushOperationCount() |
String |
getRetryStrategy() |
protected void |
handleFailedPushOperation(PushOperation operation,
Exception error) |
protected boolean |
isEnabled() |
void |
messageQueued()
this is an extension point.
|
protected abstract boolean |
pushEvent() |
void |
resetErrorCounter()
reset the error count to zero.
|
void |
scheduleFlush() |
void |
schedulePush() |
void |
scheduleTask(PushTaskExecutor.PushTask pushTask)
schedule a pushTask for execution using this Objects executor.
|
void |
setRetryStrategy(String factoryName) |
clearPendingMessageQueue, clientDisconnected, compareTo, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, getCost, getDiscardPolicy, getErrorThreshold, getMaxEventsPerConsumer, getMessageBlocking, getMessageConsumer, getMessageNoBlock, getMessageQueueFactory, getNumberOfDiscardedMessages, getOrderPolicy, getPendingMessagesCount, getSubsequentFilterStages, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, MyAdmin, obtain_offered_types, queueMessage, removeListener, setMaxEventsPerConsumer, subscription_change
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, connectionResumed, connectionSuspended, deactivate, destroy, disconnectClient, get_all_filters, get_filter, get_qos, getClientIOR, getConnected, getErrorCounter, getFilters, getID, getInterFilterGroupOperator, getJMXNotificationTypes, getJMXObjectName, getLifetimeFilter, getMBeanName, getMBeanType, getORB, getPOA, getPriorityFilter, getStatus, getTaskProcessor, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isDestroyed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, MyType, priority_filter, priority_filter, registerDisposable, remove_all_filters, remove_filter, resume_connection, sendNotification, sendNotification, set_qos, setJMXCallback, suspend_connection, validate_event_qos, validate_qos
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
incErrorCounter, isRetryAllowed
destroy, isDestroyed, queueMessage
compareTo
registerDisposable
newServant
protected final Semaphore pushSync_
public AbstractProxyPushSupplier(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin) throws ConfigurationException
ConfigurationException
protected abstract boolean pushEvent()
protected void handleFailedPushOperation(PushOperation operation, Exception error)
public void setRetryStrategy(String factoryName) throws ClassNotFoundException
ClassNotFoundException
public String getRetryStrategy()
public final void schedulePush()
public void scheduleFlush()
scheduleFlush
in interface IProxyPushSupplier
public final void scheduleTask(PushTaskExecutor.PushTask pushTask)
IProxyPushSupplier
scheduleTask
in interface IProxyPushSupplier
public void flushPendingEvents()
public final void messageQueued()
AbstractProxySupplier
messageQueued
in class AbstractProxySupplier
public void resetErrorCounter()
IProxyPushSupplier
resetErrorCounter
in interface IProxyPushSupplier
resetErrorCounter
in class AbstractProxy
public void disableDelivery()
IProxyPushSupplier
disableDelivery
in interface IProxyPushSupplier
protected boolean isEnabled()
public int getPushOperationCount()
public int getPushErrorCount()
public int getAveragePushDuration()
Copyright © 2016 JacORB. All rights reserved.