org.apache.servicemix.nmr.management
Class ManagedEndpoint

java.lang.Object
  javax.management.StandardMBean
      org.apache.servicemix.nmr.management.ManagedEndpoint

All Implemented Interfaces:

DynamicMBean, MBeanRegistration, ManagedEndpointMBean

public class ManagedEndpoint
extends StandardMBean
implements ManagedEndpointMBean

Field Summary

protected InternalEndpoint	endpoint
protected org.fusesource.commons.management.Statistic	inboundExchangeRate
protected org.fusesource.commons.management.Statistic	inboundExchanges
protected org.fusesource.commons.management.ManagementStrategy	managementStrategy
protected org.fusesource.commons.management.Statistic	outboundExchangeRate
protected org.fusesource.commons.management.Statistic	outboundExchanges

Constructor Summary

ManagedEndpoint(InternalEndpoint endpoint, org.fusesource.commons.management.ManagementStrategy managementStrategy)

Method Summary

protected String	getDescription(MBeanFeatureInfo info)
protected String	getDescription(MBeanInfo info)
InternalEndpoint	getEndpoint()
long	getInboundExchangeCount() Get the Inbound MessageExchange count
double	getInboundExchangeRate() Get the Inbound MessageExchange rate (number/sec)
String	getName() Retrieve the name of the endpoint
long	getOutboundExchangeCount() Get the Outbound MessageExchange count
double	getOutboundExchangeRate() Get the Outbound MessageExchange rate (number/sec)
Map<String,?>	getProperties() Retrieve the properties of the endpoint
void	reset() reset the Stats

Methods inherited from class javax.management.StandardMBean

cacheMBeanInfo, getAttribute, getAttributes, getCachedMBeanInfo, getClassName, getConstructors, getDescription, getDescription, getDescription, getDescription, getDescription, getImpact, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, getParameterName, getParameterName, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation

Methods inherited from class java.lang.Object

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

Field Detail

endpoint

protected final InternalEndpoint endpoint

inboundExchanges

protected final org.fusesource.commons.management.Statistic inboundExchanges

outboundExchanges

protected final org.fusesource.commons.management.Statistic outboundExchanges

inboundExchangeRate

protected final org.fusesource.commons.management.Statistic inboundExchangeRate

outboundExchangeRate

protected final org.fusesource.commons.management.Statistic outboundExchangeRate

managementStrategy

protected final org.fusesource.commons.management.ManagementStrategy managementStrategy

Constructor Detail

ManagedEndpoint

public ManagedEndpoint(InternalEndpoint endpoint,
                       org.fusesource.commons.management.ManagementStrategy managementStrategy)
                throws NotCompliantMBeanException

Throws:

NotCompliantMBeanException

Method Detail

getEndpoint

public InternalEndpoint getEndpoint()

getName

public String getName()

Retrieve the name of the endpoint

Specified by:

getName in interface ManagedEndpointMBean

Returns:

the name of the endpoint

getProperties

public Map<String,?> getProperties()

Retrieve the properties of the endpoint

Specified by:

getProperties in interface ManagedEndpointMBean

Returns:

the properties of the endpoint

getInboundExchangeCount

public long getInboundExchangeCount()

Get the Inbound MessageExchange count

Specified by:

getInboundExchangeCount in interface ManagedEndpointMBean

Returns:

inbound count

getInboundExchangeRate

public double getInboundExchangeRate()

Get the Inbound MessageExchange rate (number/sec)

Specified by:

getInboundExchangeRate in interface ManagedEndpointMBean

Returns:

the inbound exchange rate

getOutboundExchangeCount

public long getOutboundExchangeCount()

Get the Outbound MessageExchange count

Specified by:

getOutboundExchangeCount in interface ManagedEndpointMBean

Returns:

outbound count

getOutboundExchangeRate

public double getOutboundExchangeRate()

Get the Outbound MessageExchange rate (number/sec)

Specified by:

getOutboundExchangeRate in interface ManagedEndpointMBean

Returns:

the outbound exchange rate

reset

public void reset()

reset the Stats

Specified by:

reset in interface ManagedEndpointMBean

getDescription

protected String getDescription(MBeanInfo info)

Overrides:

getDescription in class StandardMBean

getDescription

protected String getDescription(MBeanFeatureInfo info)

Overrides:

getDescription in class StandardMBean