public class FlowConstructStatistics extends AbstractFlowConstructStatistics implements QueueStatistics
Modifier and Type | Field and Description |
---|---|
protected ComponentStatistics |
flowStatistics |
enabled, flowConstructType, name, receivedEventASync, receivedEventSync
Constructor and Description |
---|
FlowConstructStatistics(String flowConstructType,
String name) |
FlowConstructStatistics(String flowConstructType,
String name,
int maxThreadSize) |
FlowConstructStatistics(String flowConstructType,
String name,
ProcessingStrategy processingStrategy) |
Modifier and Type | Method and Description |
---|---|
void |
addCompleteFlowExecutionTime(long time) |
void |
addFlowExecutionBranchTime(long time,
long total) |
void |
clear() |
void |
decQueuedEvent() |
long |
getAverageProcessingTime() |
long |
getAverageQueueSize() |
long |
getExecutionErrors() |
long |
getFatalErrors() |
long |
getMaxProcessingTime() |
long |
getMinProcessingTime() |
long |
getProcessedEvents() |
int |
getThreadPoolSize() |
long |
getTotalProcessingTime() |
void |
incExecutionError() |
void |
incFatalError() |
void |
incQueuedEvent() |
boolean |
isEnabled()
Are statistics logged
|
void |
setEnabled(boolean b)
Enable statistics logs (this is a dynamic parameter)
|
getAsyncEventsReceived, getFlowConstructType, getName, getSamplePeriod, getSyncEventsReceived, getTotalEventsReceived, incReceivedEventASync, incReceivedEventSync, setName
protected final ComponentStatistics flowStatistics
public FlowConstructStatistics(String flowConstructType, String name, ProcessingStrategy processingStrategy)
public FlowConstructStatistics(String flowConstructType, String name, int maxThreadSize)
public boolean isEnabled()
isEnabled
in interface Statistics
isEnabled
in class AbstractFlowConstructStatistics
public void incExecutionError()
public void incFatalError()
public void setEnabled(boolean b)
setEnabled
in class AbstractFlowConstructStatistics
public void clear()
clear
in class AbstractFlowConstructStatistics
public void addCompleteFlowExecutionTime(long time)
public void addFlowExecutionBranchTime(long time, long total)
public long getAverageProcessingTime()
public long getProcessedEvents()
public long getMaxProcessingTime()
public long getMinProcessingTime()
public long getTotalProcessingTime()
public long getExecutionErrors()
public long getFatalErrors()
public int getThreadPoolSize()
public void incQueuedEvent()
incQueuedEvent
in interface QueueStatistics
public void decQueuedEvent()
decQueuedEvent
in interface QueueStatistics
public long getAverageQueueSize()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.