public class TypedProxyPushSupplierImpl extends AbstractProxyPushSupplier implements TypedProxyPushSupplierOperations, ITypedProxy
JMXManageable.JMXCallback
pushSync_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
TypedProxyPushSupplierImpl(ITypedAdmin admin,
ConsumerAdmin consumerAdmin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
void |
connect_typed_push_consumer(TypedPushConsumer typedPushConsumer) |
void |
disconnect_push_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
protected long |
getCost() |
String |
getSupportedInterface() |
void |
isIDLAssignable(String ifName) |
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, connectionResumed, 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
compareTo
registerDisposable
public TypedProxyPushSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager) throws ConfigurationException
ConfigurationException
public void disconnect_push_supplier()
disconnect_push_supplier
in interface PushSupplierOperations
public void connect_typed_push_consumer(TypedPushConsumer typedPushConsumer) throws AlreadyConnected, TypeError
connect_typed_push_consumer
in interface TypedProxyPushSupplierOperations
AlreadyConnected
TypeError
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void isIDLAssignable(String ifName) throws IllegalArgumentException
IllegalArgumentException
public boolean pushEvent()
pushEvent
in class AbstractProxyPushSupplier
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public Servant newServant()
newServant
in interface IServantLifecyle
protected long getCost()
getCost
in class AbstractProxySupplier
public String getSupportedInterface()
Copyright © 2017 JacORB. All rights reserved.