org.openorb.notify

Interface ChannelManagement

public interface ChannelManagement

Author: Olivier Modica

Method Summary
booleancanConnectConsumer()
Method invoked to check if the MaxConsumers admin property applies
booleancanConnectSupplier()
Method invoked to check if the MaxSuppliers admin property applies
booleancanDispatchNewEvent()
Method invoked to check if the MaxQueueLength admin property applies
voidconsumerAdminRecovered(int id, ConsumerAdminImpl consumerAdmin)
This method is invoked when a ConsumerAdmin was recovered
StringgetId()
Get the ID of the channel
ObjectgetNotifyProperty(String key)
Method invoked to get the value of a property defined in the notification module
booleanisConsumerAdminMaxPerformance()
The methods returns true if the consumer admin threads should be configured as MaxPerformance
booleanisConsumerProxyMaxPerformance()
The methods returns true if the supplier proxy threads should be configured as MaxPerformance
booleanisEventQueueLogged()
TODO
booleanisFilterEvaluationLogged()
TODO
booleanisQueueMaxPerformance()
The methods returns true if the event queue should be configured as MaxPerformance
booleanisSupplierAdminMaxPerformance()
The methods returns true if the supplier admin threads should be configured as MaxPerformance
booleanisSupplierProxyMaxPerformance()
The methods returns true if the consumer proxy threads should be configured as MaxPerformance
voidreportConsumerAdminDestruction(byte[] adminPid)
A consumer admin has been destroyed
voidreportConsumerConnection()
A proxy consumer has been created
voidreportConsumerDisconnection()
A proxy consumer has been destroyed
voidreportEventDelivery(int consumerAdminId, int eventPid)
An event has been delivered or discarded
voidreportEventTypesPublished(EventType[] published, EventType[] unpublished, Object source)
Method invoked when an EventType is being published or not published by a supplier
voidreportEventTypesSubscribed(EventType[] subscribed, EventType[] unsubscribed, Object source)
Method invoked when an EventType is being subscribed or unsubscribed by a consumer
voidreportSupplierAdminDestruction(byte[] adminPid)
A supplier admin has been destroyed
voidreportSupplierConnection()
A proxy supplier has been created
voidreportSupplierDisconnection()
A proxy supplier has been destroyed
voidsupplierAdminRecovered(int id, SupplierAdminImpl supplierAdmin)
This method is invoked when a SupplierAdmin was recovered

Method Detail

canConnectConsumer

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

canConnectSupplier

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

canDispatchNewEvent

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

consumerAdminRecovered

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

getId

public String getId()
Get the ID of the channel

getNotifyProperty

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

isConsumerAdminMaxPerformance

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

isConsumerProxyMaxPerformance

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

isEventQueueLogged

public boolean isEventQueueLogged()
TODO

isFilterEvaluationLogged

public boolean isFilterEvaluationLogged()
TODO

isQueueMaxPerformance

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

isSupplierAdminMaxPerformance

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

isSupplierProxyMaxPerformance

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

reportConsumerAdminDestruction

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

reportConsumerConnection

public void reportConsumerConnection()
A proxy consumer has been created

reportConsumerDisconnection

public void reportConsumerDisconnection()
A proxy consumer has been destroyed

reportEventDelivery

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

reportEventTypesPublished

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

reportEventTypesSubscribed

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

reportSupplierAdminDestruction

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

reportSupplierConnection

public void reportSupplierConnection()
A proxy supplier has been created

reportSupplierDisconnection

public void reportSupplierDisconnection()
A proxy supplier has been destroyed

supplierAdminRecovered

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