org.apache.camel.component.hystrix.metrics

Class HystrixEventStreamService

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.component.hystrix.metrics.HystrixEventStreamService

All Implemented Interfaces:

com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsPoller.MetricsAsJsonPollerListener, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.StaticService, org.apache.camel.SuspendableService

@ManagedResource(description="Managed Hystrix EventStreamService")
public class HystrixEventStreamService
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.StaticService, com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsPoller.MetricsAsJsonPollerListener

To gather hystrix metrics and offer the metrics over JMX and Java APIs.

If you want to expose the metrics over HTTP then you can use the HystrixEventStreamServlet servlet which provides such functionality.

Field Summary

Fields

Modifier and Type	Field and Description
static int	METRICS_QUEUE_SIZE

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
HystrixEventStreamService()

Method Summary

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
int	getDelay()
int	getPollerDelay()
int	getQueueSize()
void	handleJsonMetric(String json)
boolean	isPollerRunning()
String	oldestMetricsAsJSon()
void	pausePoller()
void	setDelay(int delay) Sets the delay in millis how often the poller runs
void	setQueueSize(int queueSize) Sets the queue size for how many metrics collected are stored in-memory in a backlog
void	startPoller()
Stream<String>	streamMetrics() Return a stream of the JSon metrics.

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.camel.Service

start, stop

Field Detail

METRICS_QUEUE_SIZE

public static final int METRICS_QUEUE_SIZE

See Also:

Constant Field Values

Constructor Detail

HystrixEventStreamService

public HystrixEventStreamService()

Method Detail

getDelay

public int getDelay()

setDelay

public void setDelay(int delay)

Sets the delay in millis how often the poller runs

getQueueSize

public int getQueueSize()

setQueueSize

public void setQueueSize(int queueSize)

Sets the queue size for how many metrics collected are stored in-memory in a backlog

streamMetrics

public Stream<String> streamMetrics()

Return a stream of the JSon metrics.

oldestMetricsAsJSon

@ManagedOperation(description="Returns the oldest metrics as JSon format")
public String oldestMetricsAsJSon()

startPoller

@ManagedOperation(description="Starts the metrics poller")
public void startPoller()

pausePoller

@ManagedOperation(description="Pauses the metrics poller")
public void pausePoller()

isPollerRunning

@ManagedAttribute(description="Is the metrics poller running")
public boolean isPollerRunning()

getPollerDelay

@ManagedAttribute(description="The delay in millis the poller is running")
public int getPollerDelay()

doStart

protected void doStart()
                throws Exception

Specified by:

doStart in class org.apache.camel.support.ServiceSupport

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Specified by:

doStop in class org.apache.camel.support.ServiceSupport

Throws:

Exception

handleJsonMetric

public void handleJsonMetric(String json)

Specified by:

handleJsonMetric in interface com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsPoller.MetricsAsJsonPollerListener