public class JmxFeed extends AbstractFeed
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();
}
| Modifier and Type | Class and Description |
|---|---|
static class |
JmxFeed.Builder |
BrooklynObject.TagSupport| Modifier and Type | Field and Description |
|---|---|
static ConfigKey<com.google.common.collect.SetMultimap<java.lang.String,JmxAttributePollConfig<?>>> |
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<com.google.common.collect.SetMultimap<javax.management.NotificationFilter,JmxNotificationSubscriptionConfig<?>>> |
NOTIFICATION_SUBSCRIPTIONS |
static ConfigKey<com.google.common.collect.SetMultimap<java.util.List<?>,JmxOperationPollConfig<?>>> |
OPERATION_POLLS |
static ConfigKey<java.lang.Boolean> |
OWN_HELPER |
ONLY_IF_SERVICE_UP| Constructor and Description |
|---|
JmxFeed()
For rebind; do not call directly; use builder
|
| Modifier and Type | Method and Description |
|---|---|
static JmxFeed.Builder |
builder() |
java.lang.String |
getJmxUri() |
void |
setEntity(EntityLocal entity) |
java.lang.String |
toString() |
destroy, getEntity, getRebindSupport, isActivated, isActive, isRunning, isSuspended, resume, start, stop, suspendconfigure, getAllConfig, getConfig, getConfigMap, getDisplayName, getName, getUniqueTag, isDestroyed, setConfig, setDisplayName, setName, tagsgetCatalogItemId, getId, getManagementContext, getTagSupport, init, rebind, setCatalogItemId, setManagementContextequals, getClass, hashCode, notify, notifyAll, wait, wait, waitgetId, getName, getUniqueTag, isDestroyedgetCatalogItemId, getDisplayName, getTagSupport, tagssetCatalogItemIdpublic static final org.slf4j.Logger log
public static final long JMX_CONNECTION_TIMEOUT_MS
public static final ConfigKey<java.lang.Boolean> OWN_HELPER
public static final ConfigKey<java.lang.String> JMX_URI
public static final ConfigKey<java.lang.Long> JMX_CONNECTION_TIMEOUT
public static final ConfigKey<com.google.common.collect.SetMultimap<java.lang.String,JmxAttributePollConfig<?>>> ATTRIBUTE_POLLS
public static final ConfigKey<com.google.common.collect.SetMultimap<java.util.List<?>,JmxOperationPollConfig<?>>> OPERATION_POLLS
public static final ConfigKey<com.google.common.collect.SetMultimap<javax.management.NotificationFilter,JmxNotificationSubscriptionConfig<?>>> NOTIFICATION_SUBSCRIPTIONS
public static JmxFeed.Builder builder()
public void setEntity(EntityLocal entity)
setEntity in class AbstractFeedpublic java.lang.String getJmxUri()
public java.lang.String toString()
toString in class AbstractEntityAdjunct