org.openorb.notify
Interface ConsumerAdminManagement

All Known Implementing Classes:

ConsumerAdminImpl

public interface ConsumerAdminManagement

Author:

Olivier Modica

Method Summary

boolean	canConnectConsumer() Method invoked to check if the MaxConsumers admin property applies
java.lang.String	getId() Get the ID ( ChannelID + ConsumerAdminID ) of the admin
java.lang.Object	getNotifyProperty(java.lang.String key) Method invoked to get the value of a property defined in the notification module
org.omg.CORBA.ORB	getORB() Get the ORB
org.omg.PortableServer.POA	getPOA() Get the POA
boolean	isProxyMaxPerformance() The methods returns true if the supplier proxy threads should be configured as MaxPerformance
boolean	isQueueMaxPerformance() The methods returns true if the event queue should be configured as MaxPerformance
void	proxySupplierRecovered(int id, org.omg.PortableServer.Servant proxySupplier) This method is invoked when a ProxySupplier was recovered
void	reportConsumerConnection() A proxy supplier has been connected
void	reportEventDelivery(int proxyId, int eventPid) An event has been delivered or discarded
void	reportPullConsumerDisconnection(byte[] proxyPid) A pull proxy supplier has been destroyed
void	reportPushConsumerDisconnection(byte[] proxyPid) A push proxy supplier has been destroyed

Method Detail

getId

public java.lang.String getId()

Get the ID ( ChannelID + ConsumerAdminID ) of the admin

proxySupplierRecovered

public void proxySupplierRecovered(int id,
                                   org.omg.PortableServer.Servant proxySupplier)

This method is invoked when a ProxySupplier was recovered

getORB

public org.omg.CORBA.ORB getORB()

Get the ORB

getPOA

public org.omg.PortableServer.POA getPOA()

Get the POA

reportConsumerConnection

public void reportConsumerConnection()

A proxy supplier has been connected

canConnectConsumer

public boolean canConnectConsumer()

Method invoked to check if the MaxConsumers admin property applies

reportPullConsumerDisconnection

public void reportPullConsumerDisconnection(byte[] proxyPid)

A pull proxy supplier has been destroyed

reportPushConsumerDisconnection

public void reportPushConsumerDisconnection(byte[] proxyPid)

A push proxy supplier has been destroyed

reportEventDelivery

public void reportEventDelivery(int proxyId,
                                int eventPid)

An event has been delivered or discarded

isQueueMaxPerformance

public boolean isQueueMaxPerformance()

The methods returns true if the event queue should be configured as MaxPerformance

isProxyMaxPerformance

public boolean isProxyMaxPerformance()

The methods returns true if the supplier proxy threads should be configured as MaxPerformance

getNotifyProperty

public java.lang.Object getNotifyProperty(java.lang.String key)

Method invoked to get the value of a property defined in the notification module