org.apache.brooklyn.feed.jmx

Class JmxFeed

java.lang.Object

org.apache.brooklyn.core.objs.AbstractBrooklynObject

org.apache.brooklyn.core.objs.AbstractEntityAdjunct

org.apache.brooklyn.core.feed.AbstractFeed

org.apache.brooklyn.feed.jmx.JmxFeed

All Implemented Interfaces:

Rebindable, BrooklynObject, Configurable, EntityAdjunct, Identifiable, Feed, BrooklynObjectInternal

public class JmxFeed
extends AbstractFeed

Provides a feed of attribute values, by polling or subscribing over jmx. Example usage (e.g. in an entity that extends SoftwareProcessImpl):

 
 private JmxFeed feed;
 
 //@Override
 protected void connectSensors() {
   super.connectSensors();
   
   feed = JmxFeed.builder()
       .entity(this)
       .period(500, TimeUnit.MILLISECONDS)
       .pollAttribute(new JmxAttributePollConfig<Integer>(ERROR_COUNT)
           .objectName(requestProcessorMbeanName)
           .attributeName("errorCount"))
       .pollAttribute(new JmxAttributePollConfig<Boolean>(SERVICE_UP)
           .objectName(serverMbeanName)
           .attributeName("Started")
           .onError(Functions.constant(false)))
       .build();
 }
 
 {@literal @}Override
 protected void disconnectSensors() {
   super.disconnectSensors();
   if (feed != null) feed.stop();
 }
 
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JmxFeed.Builder

Nested classes/interfaces inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

AbstractEntityAdjunct.AdjunctTagSupport, AbstractEntityAdjunct.BasicSubscriptionSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.Configurable

Configurable.ConfigurationSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

BrooklynObjectInternal.ConfigurationSupportInternal, BrooklynObjectInternal.RelationSupportInternal<T extends BrooklynObject>, BrooklynObjectInternal.SubscriptionSupportInternal

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigKey<<any>>	ATTRIBUTE_POLLS
static ConfigKey<JmxHelper>	HELPER
static ConfigKey<java.lang.Long>	JMX_CONNECTION_TIMEOUT
static long	JMX_CONNECTION_TIMEOUT_MS
static ConfigKey<java.lang.String>	JMX_URI
static org.slf4j.Logger	log
static ConfigKey<<any>>	NOTIFICATION_SUBSCRIPTIONS
static ConfigKey<<any>>	OPERATION_POLLS
static ConfigKey<java.lang.Boolean>	OWN_HELPER

Fields inherited from class org.apache.brooklyn.core.feed.AbstractFeed

ONLY_IF_SERVICE_UP

Fields inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

HIGHLIGHT_NAME_LAST_ACTION, HIGHLIGHT_NAME_LAST_CONFIRMATION, HIGHLIGHT_NAME_LAST_VIOLATION, HIGHLIGHT_NAME_TRIGGERS

Constructor Summary

Constructors

Constructor and Description
JmxFeed() For rebind; do not call directly; use builder

Method Summary

Modifier and Type	Method and Description
static JmxFeed.Builder	builder()
java.lang.String	getJmxUri()
void	setEntity(EntityLocal entity)
java.lang.String	toString()

Methods inherited from class org.apache.brooklyn.core.feed.AbstractFeed

destroy, getEntity, getRebindSupport, isActivated, isRunning, isSuspended, relations, resume, start, stop, suspend

Methods inherited from class org.apache.brooklyn.core.objs.AbstractEntityAdjunct

config, configure, getAdjunctType, getConfig, getDisplayName, getExecutionContext, getHighlights, getManagementContext, getUniqueTag, isDestroyed, setDisplayName, setHighlights, subscriptions, tags

Methods inherited from class org.apache.brooklyn.core.objs.AbstractBrooklynObject

addSearchPath, getCatalogItemId, getCatalogItemIdSearchPath, getId, init, rebind, setCatalogItemId, setCatalogItemIdAndSearchPath, setManagementContext, stackCatalogItemId

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.brooklyn.api.objs.EntityAdjunct

getHighlights, getId, getUniqueTag, isDestroyed

Methods inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

getCatalogItemId, getCatalogItemIdSearchPath, getDisplayName, subscriptions, tags

Methods inherited from interface org.apache.brooklyn.api.objs.Configurable

config, getConfig

Methods inherited from interface org.apache.brooklyn.core.objs.BrooklynObjectInternal

addSearchPath, setCatalogItemId, setCatalogItemIdAndSearchPath, stackCatalogItemId

Field Detail

log

public static final org.slf4j.Logger log

JMX_CONNECTION_TIMEOUT_MS

public static final long JMX_CONNECTION_TIMEOUT_MS

See Also:

Constant Field Values

HELPER

public static final ConfigKey<JmxHelper> HELPER

OWN_HELPER

public static final ConfigKey<java.lang.Boolean> OWN_HELPER

JMX_URI

public static final ConfigKey<java.lang.String> JMX_URI

JMX_CONNECTION_TIMEOUT

public static final ConfigKey<java.lang.Long> JMX_CONNECTION_TIMEOUT

ATTRIBUTE_POLLS

public static final ConfigKey<<any>> ATTRIBUTE_POLLS

OPERATION_POLLS

public static final ConfigKey<<any>> OPERATION_POLLS

NOTIFICATION_SUBSCRIPTIONS

public static final ConfigKey<<any>> NOTIFICATION_SUBSCRIPTIONS

Constructor Detail

JmxFeed

public JmxFeed()

For rebind; do not call directly; use builder

Method Detail

builder

public static JmxFeed.Builder builder()

setEntity

public void setEntity(EntityLocal entity)

Overrides:

setEntity in class AbstractFeed

getJmxUri

public java.lang.String getJmxUri()

toString

public java.lang.String toString()

Overrides:

toString in class AbstractEntityAdjunct