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)
void	admin_properties(Property[] arg) AdminProperties
int	connected_consumers() The number of currently connected consumers - enforce the MaxConsumers admin property
void	connected_consumers(int arg) The number of currently connected consumers - enforce the MaxConsumers admin property
int	connected_suppliers() The number of currently connected suppliers - enforce the MaxSuppliers admin property
void	connected_suppliers(int arg) The number of currently connected suppliers - enforce the MaxSuppliers admin property
ConnectionInfo[]	consumer_admins() ConsumerAdmins
ConnectionInfo[]	consumer_admins(ForUpdate fu)
void	consumer_admins(ConnectionInfo[] arg) ConsumerAdmins
ConnectionInfo	def_consumer_admin() DefaultConsumerAdmin
ConnectionInfo	def_consumer_admin(ForUpdate fu)
void	def_consumer_admin(ConnectionInfo arg) DefaultConsumerAdmin
ConnectionInfo	def_supplier_admin() DefaultSupplierAdmin
ConnectionInfo	def_supplier_admin(ForUpdate fu)
void	def_supplier_admin(ConnectionInfo arg) DefaultSupplierAdmin
int	id() ChannelID
void	id(int arg) ChannelID
int	next_consumer_admin_id() Indicates the next pull consumer id
void	next_consumer_admin_id(int arg) Indicates the next pull consumer id
int	next_supplier_admin_id() Indicates the next push consumer id
void	next_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)
void	published_events(EventTypeInfo[] arg) The EventTypes being published within the channel
Property[]	qos_properties() QoSProperties
Property[]	qos_properties(ForUpdate fu)
void	qos_properties(Property[] arg) QoSProperties
EventTypeInfo[]	subscribed_events() The EventTypes being subscribed within the channel
EventTypeInfo[]	subscribed_events(ForUpdate fu)
void	subscribed_events(EventTypeInfo[] arg) The EventTypes being subscribed within the channel
ConnectionInfo[]	supplier_admins() SupplierAdmins
ConnectionInfo[]	supplier_admins(ForUpdate fu)
void	supplier_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