org.openorb.notify

Interface ConsumerAdminManagement

public interface ConsumerAdminManagement

Author: Olivier Modica

Method Summary
booleancanConnectConsumer()
Method invoked to check if the MaxConsumers admin property applies
StringgetId()
Get the ID ( ChannelID + ConsumerAdminID ) of the admin
ObjectgetNotifyProperty(String key)
Method invoked to get the value of a property defined in the notification module
ORBgetORB()
Get the ORB
POAgetPOA()
Get the POA
booleanisProxyMaxPerformance()
The methods returns true if the supplier proxy threads should be configured as MaxPerformance
booleanisQueueMaxPerformance()
The methods returns true if the event queue should be configured as MaxPerformance
voidproxySupplierRecovered(int id, Servant proxySupplier)
This method is invoked when a ProxySupplier was recovered
voidreportConsumerConnection()
A proxy supplier has been connected
voidreportEventDelivery(int proxyId, int eventPid)
An event has been delivered or discarded
voidreportPullConsumerDisconnection(byte[] proxyPid)
A pull proxy supplier has been destroyed
voidreportPushConsumerDisconnection(byte[] proxyPid)
A push proxy supplier has been destroyed

Method Detail

canConnectConsumer

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

getId

public String getId()
Get the ID ( ChannelID + ConsumerAdminID ) of the admin

getNotifyProperty

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

getORB

public ORB getORB()
Get the ORB

getPOA

public POA getPOA()
Get the POA

isProxyMaxPerformance

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

isQueueMaxPerformance

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

proxySupplierRecovered

public void proxySupplierRecovered(int id, Servant proxySupplier)
This method is invoked when a ProxySupplier was recovered

reportConsumerConnection

public void reportConsumerConnection()
A proxy supplier has been connected

reportEventDelivery

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

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