flex.management.runtime.messaging
Class MessageBrokerControl

java.lang.Object
  flex.management.BaseControl
      flex.management.runtime.messaging.MessageBrokerControl

All Implemented Interfaces:

BaseControlMBean, MessageBrokerControlMBean, MBeanRegistration

public class MessageBrokerControl
extends BaseControl
implements MessageBrokerControlMBean

The MessageBrokerControl class is the MBean implemenation for monitoring and managing a MessageBroker at runtime.

Field Summary

Fields inherited from class flex.management.BaseControl

DOMAIN_PREFIX

Constructor Summary

MessageBrokerControl(MessageBroker broker)
Constructs a new MessageBrokerControl instance, assigning its backing MessageBroker.

Method Summary

void	addEndpoint(Endpoint value) Adds an Endpoint for an endpoint registered with the backing MessageBroker.
void	addService(ObjectName value) Adds an ObjectName for a service registered with the backing MessageBroker.
Long	getAMFThroughput() Returns the total number of bytes passing through all AMF endpoints.
ObjectName[]	getEndpoints() Returns the ObjectNames for endpoints that are registered with the managed MessageBroker.
Integer	getEnterpriseConnectionCount() Returns the number of Enterprise Connections across all Enterprise Endpoints.
Long	getEnterpriseThroughput() Returns the total number of bytes passing through all Enterprise endpoints.
Integer	getFlexSessionCount() Returns Flex session count for the MessageBroker.
Long	getHTTPThroughput() Returns the total number of bytes passing through all HTTP endpoints.
String	getId() Returns the id for this MBean.
Integer	getMaxFlexSessionsInCurrentHour() Returns the maximum concurrent Flex session count for the MessageBroker in the current hour.
ObjectName[]	getServices() Returns the ObjectNames for services that are registered with the managed MessageBroker.
Date	getStartTimestamp() Returns the start timestamp for the MessageBroker.
Long	getStreamingAMFThroughput() Returns the total number of bytes passing through all streaming AMF endpoints.
Long	getStreamingHTTPThroughput() Returns the total number of bytes passing through all streaming HTTP endpoints.
String	getType() Returns the type for this MBean.
Boolean	isRunning() Returns true if the MessageBroker is running.
void	removeEndpoint(ObjectName value) Removes an ObjectName for an endpoint registered with the backing MessageBroker.
void	removeService(ObjectName value) Removes an ObjectName for a service registered with the backing MessageBroker.
void	setFlexSessionCount(int connectionCount) Sets the flex session count for the managed MessageBroker.
void	setMaxFlexSessionsInCurrentHour(int currentConnectionCountMax)

Methods inherited from class flex.management.BaseControl

getApplicationId, getMBeanServer, getObjectName, getParent, getParentControl, getRegistrar, postDeregister, postRegister, preDeregister, preRegister, register, setStartTimestamp, unregister

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface flex.management.BaseControlMBean

getParent

Constructor Detail

MessageBrokerControl

public MessageBrokerControl(MessageBroker broker)

Constructs a new MessageBrokerControl instance, assigning its backing MessageBroker.

Parameters:

broker - The MessageBroker managed by this MBean.

Method Detail

getId

public String getId()

Description copied from interface: BaseControlMBean

Returns the id for this MBean. This is the value that is set for the id key in the ObjectName for this MBean.

Specified by:

getId in interface BaseControlMBean

Specified by:

getId in class BaseControl

Returns:

The MBean instance id.

getType

public String getType()

Description copied from interface: BaseControlMBean

Returns the type for this MBean. This is the value that is set for the type key in the ObjectName for this MBean.

Specified by:

getType in interface BaseControlMBean

Specified by:

getType in class BaseControl

Returns:

The MBean instance type.

isRunning

public Boolean isRunning()

Description copied from interface: MessageBrokerControlMBean

Returns true if the MessageBroker is running.

Specified by:

isRunning in interface MessageBrokerControlMBean

Returns:

true if the MessageBroker is running.

getStartTimestamp

public Date getStartTimestamp()

Description copied from interface: MessageBrokerControlMBean

Returns the start timestamp for the MessageBroker.

Specified by:

getStartTimestamp in interface MessageBrokerControlMBean

Returns:

The start timestamp for the MessageBroker.

getEndpoints

public ObjectName[] getEndpoints()
                          throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the ObjectNames for endpoints that are registered with the managed MessageBroker.

Specified by:

getEndpoints in interface MessageBrokerControlMBean

Returns:

The ObjectNames for endpoints registered with the managed MessageBroker.

Throws:

IOException - Throws IOException.

addEndpoint

public void addEndpoint(Endpoint value)

Adds an Endpoint for an endpoint registered with the backing MessageBroker.

Parameters:

value - The endpoint Endpoint.

removeEndpoint

public void removeEndpoint(ObjectName value)

Removes an ObjectName for an endpoint registered with the backing MessageBroker.

Parameters:

value - The endpoint ObjectName.

getServices

public ObjectName[] getServices()
                         throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the ObjectNames for services that are registered with the managed MessageBroker.

Specified by:

getServices in interface MessageBrokerControlMBean

Returns:

The ObjectNames for services registered with the managed MessageBroker.

Throws:

IOException - Throws IOException.

addService

public void addService(ObjectName value)

Adds an ObjectName for a service registered with the backing MessageBroker.

Parameters:

value - The service ObjectName.

removeService

public void removeService(ObjectName value)

Removes an ObjectName for a service registered with the backing MessageBroker.

Parameters:

value - The service ObjectName.

getFlexSessionCount

public Integer getFlexSessionCount()

Description copied from interface: MessageBrokerControlMBean

Returns Flex session count for the MessageBroker.

Specified by:

getFlexSessionCount in interface MessageBrokerControlMBean

Returns:

Flex session count for the MessageBroker.

setFlexSessionCount

public void setFlexSessionCount(int connectionCount)

Sets the flex session count for the managed MessageBroker.

Parameters:

connectionCount - The flex session count for the managed MessageBroker.

getMaxFlexSessionsInCurrentHour

public Integer getMaxFlexSessionsInCurrentHour()

Description copied from interface: MessageBrokerControlMBean

Returns the maximum concurrent Flex session count for the MessageBroker in the current hour.

Specified by:

getMaxFlexSessionsInCurrentHour in interface MessageBrokerControlMBean

Returns:

The maximum concurrent Flex session count for the MessageBroker in the last hour.

setMaxFlexSessionsInCurrentHour

public void setMaxFlexSessionsInCurrentHour(int currentConnectionCountMax)

getEnterpriseConnectionCount

public Integer getEnterpriseConnectionCount()
                                     throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the number of Enterprise Connections across all Enterprise Endpoints.

Specified by:

getEnterpriseConnectionCount in interface MessageBrokerControlMBean

Returns:

The number of Enterprise Connections

Throws:

IOException - Throws IOException.

getAMFThroughput

public Long getAMFThroughput()
                      throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the total number of bytes passing through all AMF endpoints.

Specified by:

getAMFThroughput in interface MessageBrokerControlMBean

Returns:

The total number of bytes passing through all AMF endpoints.

Throws:

IOException - Throws IOException.

getHTTPThroughput

public Long getHTTPThroughput()
                       throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the total number of bytes passing through all HTTP endpoints.

Specified by:

getHTTPThroughput in interface MessageBrokerControlMBean

Returns:

The total number of bytes passing through all HTTP endpoints.

Throws:

IOException - Throws IOException.

getEnterpriseThroughput

public Long getEnterpriseThroughput()
                             throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the total number of bytes passing through all Enterprise endpoints.

Specified by:

getEnterpriseThroughput in interface MessageBrokerControlMBean

Returns:

The total number of bytes passing through all Enterprise endpoints.

Throws:

IOException - Throws IOException.

getStreamingAMFThroughput

public Long getStreamingAMFThroughput()
                               throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the total number of bytes passing through all streaming AMF endpoints.

Specified by:

getStreamingAMFThroughput in interface MessageBrokerControlMBean

Returns:

The total number of bytes passing through all streaming AMF endpoints.

Throws:

IOException - Throws IOException.

getStreamingHTTPThroughput

public Long getStreamingHTTPThroughput()
                                throws IOException

Description copied from interface: MessageBrokerControlMBean

Returns the total number of bytes passing through all streaming HTTP endpoints.

Specified by:

getStreamingHTTPThroughput in interface MessageBrokerControlMBean

Returns:

The total number of bytes passing through all streaming HTTP endpoints.

Throws:

IOException - Throws IOException.