org.openorb.notify

Interface ChannelManagement

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
String	getId() Get the ID of the channel
Object	getNotifyProperty(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, Object source) Method invoked when an EventType is being published or not published by a supplier
void	reportEventTypesSubscribed(EventType[] subscribed, EventType[] unsubscribed, 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

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