org.openorb.notify
Interface ChannelManagement

All Known Implementing Classes:
EventChannelImpl

public interface ChannelManagement

Author:
Olivier Modica

Method Summary
 boolean canConnectConsumer()
          Method invoked to check if the MaxConsumers admin property applies
 boolean canConnectSupplier()
          Method invoked to check if the MaxSuppliers admin property applies
 boolean canDispatchNewEvent()
          Method invoked to check if the MaxQueueLength admin property applies
 void consumerAdminRecovered(int id, ConsumerAdminImpl consumerAdmin)
          This method is invoked when a ConsumerAdmin was recovered
 java.lang.String getId()
          Get the ID of the channel
 java.lang.Object getNotifyProperty(java.lang.String key)
          Method invoked to get the value of a property defined in the notification module
 boolean isConsumerAdminMaxPerformance()
          The methods returns true if the consumer admin threads should be configured as MaxPerformance
 boolean isConsumerProxyMaxPerformance()
          The methods returns true if the supplier proxy threads should be configured as MaxPerformance
 boolean isEventQueueLogged()
          TODO
 boolean isFilterEvaluationLogged()
          TODO
 boolean isQueueMaxPerformance()
          The methods returns true if the event queue should be configured as MaxPerformance
 boolean isSupplierAdminMaxPerformance()
          The methods returns true if the supplier admin threads should be configured as MaxPerformance
 boolean isSupplierProxyMaxPerformance()
          The methods returns true if the consumer proxy threads should be configured as MaxPerformance
 void reportConsumerAdminDestruction(byte[] adminPid)
          A consumer admin has been destroyed
 void reportConsumerConnection()
          A proxy consumer has been created
 void reportConsumerDisconnection()
          A proxy consumer has been destroyed
 void reportEventDelivery(int consumerAdminId, int eventPid)
          An event has been delivered or discarded
 void reportEventTypesPublished(EventType[] published, EventType[] unpublished, org.omg.CORBA.Object source)
          Method invoked when an EventType is being published or not published by a supplier
 void reportEventTypesSubscribed(EventType[] subscribed, EventType[] unsubscribed, org.omg.CORBA.Object source)
          Method invoked when an EventType is being subscribed or unsubscribed by a consumer
 void reportSupplierAdminDestruction(byte[] adminPid)
          A supplier admin has been destroyed
 void reportSupplierConnection()
          A proxy supplier has been created
 void reportSupplierDisconnection()
          A proxy supplier has been destroyed
 void supplierAdminRecovered(int id, SupplierAdminImpl supplierAdmin)
          This method is invoked when a SupplierAdmin was recovered
 

Method Detail

getId

java.lang.String getId()
Get the ID of the channel


consumerAdminRecovered

void consumerAdminRecovered(int id,
                            ConsumerAdminImpl consumerAdmin)
This method is invoked when a ConsumerAdmin was recovered


supplierAdminRecovered

void supplierAdminRecovered(int id,
                            SupplierAdminImpl supplierAdmin)
This method is invoked when a SupplierAdmin was recovered


reportConsumerAdminDestruction

void reportConsumerAdminDestruction(byte[] adminPid)
A consumer admin has been destroyed


reportSupplierAdminDestruction

void reportSupplierAdminDestruction(byte[] adminPid)
A supplier admin has been destroyed


reportConsumerConnection

void reportConsumerConnection()
A proxy consumer has been created


reportSupplierConnection

void reportSupplierConnection()
A proxy supplier has been created


canConnectSupplier

boolean canConnectSupplier()
Method invoked to check if the MaxSuppliers admin property applies


canConnectConsumer

boolean canConnectConsumer()
Method invoked to check if the MaxConsumers admin property applies


reportSupplierDisconnection

void reportSupplierDisconnection()
A proxy supplier has been destroyed


reportConsumerDisconnection

void reportConsumerDisconnection()
A proxy consumer has been destroyed


reportEventDelivery

void reportEventDelivery(int consumerAdminId,
                         int eventPid)
An event has been delivered or discarded


canDispatchNewEvent

boolean canDispatchNewEvent()
Method invoked to check if the MaxQueueLength admin property applies


reportEventTypesSubscribed

void reportEventTypesSubscribed(EventType[] subscribed,
                                EventType[] unsubscribed,
                                org.omg.CORBA.Object source)
Method invoked when an EventType is being subscribed or unsubscribed by a consumer


reportEventTypesPublished

void reportEventTypesPublished(EventType[] published,
                               EventType[] unpublished,
                               org.omg.CORBA.Object source)
Method invoked when an EventType is being published or not published by a supplier


getNotifyProperty

java.lang.Object getNotifyProperty(java.lang.String key)
Method invoked to get the value of a property defined in the notification module


isQueueMaxPerformance

boolean isQueueMaxPerformance()
The methods returns true if the event queue should be configured as MaxPerformance


isSupplierAdminMaxPerformance

boolean isSupplierAdminMaxPerformance()
The methods returns true if the supplier admin threads should be configured as MaxPerformance


isConsumerAdminMaxPerformance

boolean isConsumerAdminMaxPerformance()
The methods returns true if the consumer admin threads should be configured as MaxPerformance


isSupplierProxyMaxPerformance

boolean isSupplierProxyMaxPerformance()
The methods returns true if the consumer proxy threads should be configured as MaxPerformance


isConsumerProxyMaxPerformance

boolean isConsumerProxyMaxPerformance()
The methods returns true if the supplier proxy threads should be configured as MaxPerformance


isEventQueueLogged

boolean isEventQueueLogged()
TODO


isFilterEvaluationLogged

boolean isFilterEvaluationLogged()
TODO