@UriEndpoint(scheme="metrics", title="Metrics", syntax="metrics:metricsType:metricsName", producerOnly=true, label="monitoring") public class MetricsEndpoint extends DefaultEndpoint
Modifier and Type | Field and Description |
---|---|
protected String |
metricsName |
protected MetricsType |
metricsType |
protected com.codahale.metrics.MetricRegistry |
registry |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
Constructor and Description |
---|
MetricsEndpoint(String uri,
Component component,
com.codahale.metrics.MetricRegistry registry,
MetricsType metricsType,
String metricsName) |
Modifier and Type | Method and Description |
---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event
Driven Consumer which consumes messages from the endpoint using the
given processor
|
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint
|
MetricsTimerAction |
getAction() |
Long |
getDecrement() |
Long |
getIncrement() |
Long |
getMark() |
String |
getMetricsName() |
MetricsType |
getMetricsType() |
com.codahale.metrics.MetricRegistry |
getRegistry() |
Long |
getValue() |
boolean |
isSingleton()
Whether this class supports being singleton or not.
|
void |
setAction(MetricsTimerAction action) |
void |
setDecrement(Long decrement) |
void |
setIncrement(Long increment) |
void |
setMark(Long mark) |
void |
setValue(Long value) |
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 final com.codahale.metrics.MetricRegistry registry
@UriPath(description="Type of metrics") @Metadata(required="true") protected final MetricsType metricsType
@UriPath(description="Name of metrics") @Metadata(required="true") protected final String metricsName
public MetricsEndpoint(String uri, Component component, com.codahale.metrics.MetricRegistry registry, MetricsType metricsType, String metricsName)
public Consumer createConsumer(Processor processor) throws Exception
Endpoint
processor
- the given processorException
- can be thrownpublic Producer createProducer() throws Exception
Endpoint
Exception
- can be thrownpublic boolean isSingleton()
IsSingleton
public com.codahale.metrics.MetricRegistry getRegistry()
public String getMetricsName()
public MetricsType getMetricsType()
public MetricsTimerAction getAction()
public void setAction(MetricsTimerAction action)
public Long getMark()
public void setMark(Long mark)
public Long getValue()
public void setValue(Long value)
public Long getIncrement()
public void setIncrement(Long increment)
public Long getDecrement()
public void setDecrement(Long decrement)
Copyright © 2007–2016 The Apache Software Foundation. All rights reserved.