public class StructuredProxyPushSupplierImpl extends AbstractProxyPushSupplier implements StructuredProxyPushSupplierOperations, StructuredProxyPushSupplierImplMBean
JMXManageable.JMXCallback
pushSync_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
StructuredProxyPushSupplierImpl(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_structured_push_consumer(StructuredPushConsumer consumer) |
protected void |
connectionResumed()
this is an extension point.
|
void |
disconnect_structured_push_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
protected 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
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 StructuredProxyPushSupplierImpl(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 boolean pushEvent()
pushEvent
in class AbstractProxyPushSupplier
public void connect_structured_push_consumer(StructuredPushConsumer consumer) throws AlreadyConnected
connect_structured_push_consumer
in interface StructuredProxyPushSupplierOperations
AlreadyConnected
public void disconnect_structured_push_supplier()
disconnect_structured_push_supplier
in interface StructuredPushSupplierOperations
protected void connectionResumed()
AbstractProxy
connectionResumed
in class AbstractProxy
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public Servant newServant()
newServant
in interface IServantLifecyle
protected long getCost()
getCost
in class AbstractProxySupplier