public class SequenceProxyPushSupplierImpl extends AbstractProxyPushSupplier implements SequenceProxyPushSupplierOperations, SequenceProxyPushSupplierImplMBean
JMXManageable.JMXCallback
pushSync_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
SequenceProxyPushSupplierImpl(IAdmin admin,
ORB orb,
POA poa,
org.jacorb.config.Configuration config,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
connect_sequence_push_consumer(SequencePushConsumer consumer) |
protected void |
connectionResumed()
this is an extension point.
|
protected void |
connectionSuspended()
this is an extension point.
|
void |
disconnect_sequence_push_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
void |
flushPendingEvents() |
protected long |
getCost() |
ProxyType |
MyType() |
Servant |
newServant() |
boolean |
pushEvent() |
static long |
time2millis(long timeT) |
long |
timeT2millis() |
disableDelivery, 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, 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 SequenceProxyPushSupplierImpl(IAdmin admin, ORB orb, POA poa, org.jacorb.config.Configuration config, 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 flushPendingEvents()
flushPendingEvents
in class AbstractProxyPushSupplier
public void connect_sequence_push_consumer(SequencePushConsumer consumer) throws AlreadyConnected, TypeError
connect_sequence_push_consumer
in interface SequenceProxyPushSupplierOperations
AlreadyConnected
TypeError
protected void connectionResumed()
AbstractProxy
connectionResumed
in class AbstractProxy
protected void connectionSuspended()
AbstractProxy
connectionSuspended
in class AbstractProxy
public void disconnect_sequence_push_supplier()
disconnect_sequence_push_supplier
in interface SequencePushSupplierOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public long timeT2millis()
public static long time2millis(long timeT)
public Servant newServant()
newServant
in interface IServantLifecyle
protected long getCost()
getCost
in class AbstractProxySupplier