@UriEndpoint(scheme="jmx", title="JMX", syntax="jmx:serverURL", consumerOnly=true, consumerClass=JMXConsumer.class, label="monitoring") public class JMXEndpoint extends org.apache.camel.impl.DefaultEndpoint
jmx://platform?options
A remote mbean server url can be provided following the initial JMX scheme like so:
jmx:service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi?options
You can append query options to the URI in the following format, ?options=value&option2=value&...Modifier and Type | Field and Description |
---|---|
protected static String |
ERR_GAUGE_NOTIFY |
protected static String |
ERR_OBSERVED_ATTRIBUTE |
protected static String |
ERR_PLATFORM_SERVER |
protected static String |
ERR_STRING_NOTIFY |
protected static String |
ERR_STRING_TO_COMPARE |
protected static String |
ERR_THRESHOLD_HIGH |
protected static String |
ERR_THRESHOLD_LOW |
Constructor and Description |
---|
JMXEndpoint(String aEndpointUri,
JMXComponent aComponent) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor aProcessor) |
org.apache.camel.Producer |
createProducer() |
String |
getFormat() |
long |
getGranularityPeriod() |
Object |
getHandback() |
int |
getInitThreshold() |
protected ObjectName |
getJMXObjectName() |
int |
getModulus() |
String |
getMonitorType() |
NotificationFilter |
getNotificationFilter() |
String |
getObjectDomain() |
String |
getObjectName() |
Map<String,String> |
getObjectProperties() |
String |
getObservedAttribute() |
int |
getOffset() |
String |
getPassword() |
int |
getReconnectDelay() |
boolean |
getReconnectOnConnectionFailure() |
protected String |
getServerURL() |
String |
getStringToCompare() |
boolean |
getTestConnectionOnStartup() |
Double |
getThresholdHigh() |
Double |
getThresholdLow() |
String |
getUser() |
boolean |
isDifferenceMode() |
boolean |
isNotifyDiffer() |
boolean |
isNotifyHigh() |
boolean |
isNotifyLow() |
boolean |
isNotifyMatch() |
boolean |
isPlatformServer() |
boolean |
isSingleton() |
boolean |
isXML() |
void |
setDifferenceMode(boolean aDifferenceMode) |
void |
setFormat(String aFormat) |
void |
setGranularityPeriod(long aGranularityPeriod) |
void |
setHandback(Object aHandback) |
void |
setInitThreshold(int aInitThreshold) |
protected void |
setJMXObjectName(ObjectName aCachedObjectName) |
void |
setModulus(int aModulus) |
void |
setMonitorType(String aMonitorType) |
void |
setNotificationFilter(NotificationFilter aFilterRef) |
void |
setNotifyDiffer(boolean aNotifyDiffer) |
void |
setNotifyHigh(boolean aNotifyHigh) |
void |
setNotifyLow(boolean aNotifyLow) |
void |
setNotifyMatch(boolean aNotifyMatch) |
void |
setObjectDomain(String aObjectDomain) |
void |
setObjectName(String aObjectName) |
void |
setObjectProperties(Map<String,String> objectProperties)
Setter for the ObjectProperties is either called by reflection when
processing the URI or manually by the component.
|
void |
setObservedAttribute(String aObservedAttribute) |
void |
setOffset(int aOffset) |
void |
setPassword(String aPassword) |
void |
setReconnectDelay(int reconnectDelay) |
void |
setReconnectOnConnectionFailure(boolean reconnectOnConnectionFailure) |
protected void |
setServerURL(String aServerURL) |
void |
setStringToCompare(String aStringToCompare) |
void |
setTestConnectionOnStartup(boolean testConnectionOnStartup) |
void |
setThresholdHigh(Double aThresholdHigh) |
void |
setThresholdLow(Double aThresholdLow) |
void |
setUser(String aUser) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected static final String ERR_PLATFORM_SERVER
protected static final String ERR_THRESHOLD_LOW
protected static final String ERR_THRESHOLD_HIGH
protected static final String ERR_GAUGE_NOTIFY
protected static final String ERR_STRING_NOTIFY
protected static final String ERR_STRING_TO_COMPARE
protected static final String ERR_OBSERVED_ATTRIBUTE
public JMXEndpoint(String aEndpointUri, JMXComponent aComponent)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor aProcessor) throws Exception
Exception
public boolean isSingleton()
public String getFormat()
public void setFormat(String aFormat)
public boolean isXML()
public boolean isPlatformServer()
public String getUser()
public void setUser(String aUser)
public String getPassword()
public void setPassword(String aPassword)
public String getObjectDomain()
public void setObjectDomain(String aObjectDomain)
public String getObjectName()
public void setObjectName(String aObjectName)
protected String getServerURL()
protected void setServerURL(String aServerURL)
public NotificationFilter getNotificationFilter()
public void setNotificationFilter(NotificationFilter aFilterRef)
public Object getHandback()
public void setHandback(Object aHandback)
public void setObjectProperties(Map<String,String> objectProperties)
protected ObjectName getJMXObjectName() throws MalformedObjectNameException
MalformedObjectNameException
protected void setJMXObjectName(ObjectName aCachedObjectName)
public String getObservedAttribute()
public void setObservedAttribute(String aObservedAttribute)
public long getGranularityPeriod()
public void setGranularityPeriod(long aGranularityPeriod)
public String getMonitorType()
public void setMonitorType(String aMonitorType)
public int getInitThreshold()
public void setInitThreshold(int aInitThreshold)
public int getOffset()
public void setOffset(int aOffset)
public int getModulus()
public void setModulus(int aModulus)
public boolean isDifferenceMode()
public void setDifferenceMode(boolean aDifferenceMode)
public boolean isNotifyHigh()
public void setNotifyHigh(boolean aNotifyHigh)
public boolean isNotifyLow()
public void setNotifyLow(boolean aNotifyLow)
public Double getThresholdHigh()
public void setThresholdHigh(Double aThresholdHigh)
public Double getThresholdLow()
public void setThresholdLow(Double aThresholdLow)
public boolean isNotifyDiffer()
public void setNotifyDiffer(boolean aNotifyDiffer)
public boolean isNotifyMatch()
public void setNotifyMatch(boolean aNotifyMatch)
public String getStringToCompare()
public void setStringToCompare(String aStringToCompare)
public boolean getTestConnectionOnStartup()
public void setTestConnectionOnStartup(boolean testConnectionOnStartup)
public boolean getReconnectOnConnectionFailure()
public void setReconnectOnConnectionFailure(boolean reconnectOnConnectionFailure)
public int getReconnectDelay()
public void setReconnectDelay(int reconnectDelay)
Apache Camel