org.openorb.notify.persistence

Interface EventChannel

public interface EventChannel extends StorageObject

This storagetype describes an EventChannel
Method Summary
Property[]admin_properties()
AdminProperties
Property[]admin_properties(ForUpdate fu)
voidadmin_properties(Property[] arg)
AdminProperties
intconnected_consumers()
The number of currently connected consumers - enforce the MaxConsumers admin property
voidconnected_consumers(int arg)
The number of currently connected consumers - enforce the MaxConsumers admin property
intconnected_suppliers()
The number of currently connected suppliers - enforce the MaxSuppliers admin property
voidconnected_suppliers(int arg)
The number of currently connected suppliers - enforce the MaxSuppliers admin property
ConnectionInfo[]consumer_admins()
ConsumerAdmins
ConnectionInfo[]consumer_admins(ForUpdate fu)
voidconsumer_admins(ConnectionInfo[] arg)
ConsumerAdmins
ConnectionInfodef_consumer_admin()
DefaultConsumerAdmin
ConnectionInfodef_consumer_admin(ForUpdate fu)
voiddef_consumer_admin(ConnectionInfo arg)
DefaultConsumerAdmin
ConnectionInfodef_supplier_admin()
DefaultSupplierAdmin
ConnectionInfodef_supplier_admin(ForUpdate fu)
voiddef_supplier_admin(ConnectionInfo arg)
DefaultSupplierAdmin
intid()
ChannelID
voidid(int arg)
ChannelID
intnext_consumer_admin_id()
Indicates the next pull consumer id
voidnext_consumer_admin_id(int arg)
Indicates the next pull consumer id
intnext_supplier_admin_id()
Indicates the next push consumer id
voidnext_supplier_admin_id(int arg)
Indicates the next push consumer id
EventTypeInfo[]published_events()
The EventTypes being published within the channel
EventTypeInfo[]published_events(ForUpdate fu)
voidpublished_events(EventTypeInfo[] arg)
The EventTypes being published within the channel
Property[]qos_properties()
QoSProperties
Property[]qos_properties(ForUpdate fu)
voidqos_properties(Property[] arg)
QoSProperties
EventTypeInfo[]subscribed_events()
The EventTypes being subscribed within the channel
EventTypeInfo[]subscribed_events(ForUpdate fu)
voidsubscribed_events(EventTypeInfo[] arg)
The EventTypes being subscribed within the channel
ConnectionInfo[]supplier_admins()
SupplierAdmins
ConnectionInfo[]supplier_admins(ForUpdate fu)
voidsupplier_admins(ConnectionInfo[] arg)
SupplierAdmins

Method Detail

admin_properties

public Property[] admin_properties()
AdminProperties

admin_properties

public Property[] admin_properties(ForUpdate fu)

admin_properties

public void admin_properties(Property[] arg)
AdminProperties

connected_consumers

public int connected_consumers()
The number of currently connected consumers - enforce the MaxConsumers admin property

connected_consumers

public void connected_consumers(int arg)
The number of currently connected consumers - enforce the MaxConsumers admin property

connected_suppliers

public int connected_suppliers()
The number of currently connected suppliers - enforce the MaxSuppliers admin property

connected_suppliers

public void connected_suppliers(int arg)
The number of currently connected suppliers - enforce the MaxSuppliers admin property

consumer_admins

public ConnectionInfo[] consumer_admins()
ConsumerAdmins

consumer_admins

public ConnectionInfo[] consumer_admins(ForUpdate fu)

consumer_admins

public void consumer_admins(ConnectionInfo[] arg)
ConsumerAdmins

def_consumer_admin

public ConnectionInfo def_consumer_admin()
DefaultConsumerAdmin

def_consumer_admin

public ConnectionInfo def_consumer_admin(ForUpdate fu)

def_consumer_admin

public void def_consumer_admin(ConnectionInfo arg)
DefaultConsumerAdmin

def_supplier_admin

public ConnectionInfo def_supplier_admin()
DefaultSupplierAdmin

def_supplier_admin

public ConnectionInfo def_supplier_admin(ForUpdate fu)

def_supplier_admin

public void def_supplier_admin(ConnectionInfo arg)
DefaultSupplierAdmin

id

public int id()
ChannelID

id

public void id(int arg)
ChannelID

next_consumer_admin_id

public int next_consumer_admin_id()
Indicates the next pull consumer id

next_consumer_admin_id

public void next_consumer_admin_id(int arg)
Indicates the next pull consumer id

next_supplier_admin_id

public int next_supplier_admin_id()
Indicates the next push consumer id

next_supplier_admin_id

public void next_supplier_admin_id(int arg)
Indicates the next push consumer id

published_events

public EventTypeInfo[] published_events()
The EventTypes being published within the channel

published_events

public EventTypeInfo[] published_events(ForUpdate fu)

published_events

public void published_events(EventTypeInfo[] arg)
The EventTypes being published within the channel

qos_properties

public Property[] qos_properties()
QoSProperties

qos_properties

public Property[] qos_properties(ForUpdate fu)

qos_properties

public void qos_properties(Property[] arg)
QoSProperties

subscribed_events

public EventTypeInfo[] subscribed_events()
The EventTypes being subscribed within the channel

subscribed_events

public EventTypeInfo[] subscribed_events(ForUpdate fu)

subscribed_events

public void subscribed_events(EventTypeInfo[] arg)
The EventTypes being subscribed within the channel

supplier_admins

public ConnectionInfo[] supplier_admins()
SupplierAdmins

supplier_admins

public ConnectionInfo[] supplier_admins(ForUpdate fu)

supplier_admins

public void supplier_admins(ConnectionInfo[] arg)
SupplierAdmins