public class TypedProxyPushSupplierImpl extends AbstractProxyPushSupplier implements TypedProxyPushSupplierOperations, ITypedProxy, TypedProxyPushSupplierImplMBean
JMXManageable.JMXCallback
pushSync_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
TypedProxyPushSupplierImpl(ITypedAdmin admin,
ConsumerAdmin consumerAdmin,
ORB orb,
POA poa,
org.jacorb.config.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() |
java.lang.String |
getSupportedInterface() |
void |
isIDLAssignable(java.lang.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
getAveragePushDuration, getPushErrorCount, getPushOperationCount, getRetryStrategy, resetErrorCounter, setRetryStrategy
clearPendingMessageQueue, getDiscardPolicy, getMaxEventsPerConsumer, getNumberOfDiscardedMessages, getOrderPolicy, getPendingMessagesCount, setMaxEventsPerConsumer
destroy, getClientIOR, getConnected, getErrorCounter, getInterFilterGroupOperator, getStatus
incErrorCounter, isRetryAllowed
destroy, isDestroyed, queueMessage
registerDisposable
public TypedProxyPushSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager) throws org.jacorb.config.ConfigurationException
org.jacorb.config.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(java.lang.String ifName) throws java.lang.IllegalArgumentException
java.lang.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 java.lang.String getSupportedInterface()
getSupportedInterface
in interface TypedProxyPushSupplierImplMBean