public class ECProxyPushSupplierImpl extends ProxyPushSupplierImpl implements ProxyPushSupplierOperations
JMXManageable.JMXCallback
pushSync_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
ECProxyPushSupplierImpl(IAdmin admin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory) |
Modifier and Type | Method and Description |
---|---|
void |
connect_push_consumer(PushConsumer pushConsumer) |
Servant |
newServant() |
connect_any_push_consumer, connectionResumed, disconnect_push_supplier, disconnectClient, getCost, MyType, pushEvent
disableDelivery, flushPendingEvents, getAveragePushDuration, getPushErrorCount, getPushOperationCount, getRetryStrategy, handleFailedPushOperation, isEnabled, messageQueued, resetErrorCounter, scheduleFlush, schedulePush, scheduleTask, setRetryStrategy
clearPendingMessageQueue, clientDisconnected, compareTo, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, 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, connectionSuspended, deactivate, destroy, 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, 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
disconnect_push_supplier
resume_connection, suspend_connection
lifetime_filter, lifetime_filter, MyAdmin, obtain_offered_types, priority_filter, priority_filter, validate_event_qos
get_qos, set_qos, validate_qos
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
subscription_change
incErrorCounter, isRetryAllowed
destroy, isDestroyed, queueMessage
compareTo
registerDisposable
public ECProxyPushSupplierImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory) throws ConfigurationException
ConfigurationException
public void connect_push_consumer(PushConsumer pushConsumer) throws AlreadyConnected
AlreadyConnected
public Servant newServant()
newServant
in interface IServantLifecyle
newServant
in class ProxyPushSupplierImpl
Copyright © 2016 JacORB. All rights reserved.