public class ProxyPushSupplierImpl extends AbstractProxyPushSupplier implements ProxyPushSupplierOperations
JMXManageable.JMXCallback
pushSync_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
ProxyPushSupplierImpl(IAdmin admin,
ORB orb,
POA poa,
org.jacorb.config.Configuration conf,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
connect_any_push_consumer(PushConsumer pushConsumer) |
protected void |
connectionResumed()
this is an extension point.
|
void |
disconnect_push_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
long |
getCost() |
ProxyType |
MyType() |
Servant |
newServant() |
boolean |
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
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
registerDisposable
public ProxyPushSupplierImpl(IAdmin admin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin) throws org.jacorb.config.ConfigurationException
org.jacorb.config.ConfigurationException
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void disconnect_push_supplier()
disconnect_push_supplier
in interface PushSupplierOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public boolean pushEvent()
pushEvent
in class AbstractProxyPushSupplier
public void connect_any_push_consumer(PushConsumer pushConsumer) throws AlreadyConnected
connect_any_push_consumer
in interface ProxyPushSupplierOperations
AlreadyConnected
protected void connectionResumed()
AbstractProxy
connectionResumed
in class AbstractProxy
public Servant newServant()
newServant
in interface IServantLifecyle
public long getCost()
getCost
in class AbstractProxySupplier