@IntegrationManagedResource public class NullChannel extends java.lang.Object implements org.springframework.messaging.PollableChannel, MessageChannelMetrics, ConfigurableMetricsAware<AbstractMessageChannelMetrics>, org.springframework.beans.factory.BeanNameAware, NamedComponent
IntegrationManagement.ManagementOverrides
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
NullChannel() |
Modifier and Type | Method and Description |
---|---|
void |
configureMetrics(AbstractMessageChannelMetrics metrics) |
java.lang.String |
getComponentName() |
java.lang.String |
getComponentType() |
Statistics |
getErrorRate() |
double |
getMaxSendDuration() |
double |
getMeanErrorRate() |
double |
getMeanErrorRatio() |
double |
getMeanSendDuration() |
double |
getMeanSendRate() |
double |
getMinSendDuration() |
IntegrationManagement.ManagementOverrides |
getOverrides()
Return the overrides.
|
int |
getSendCount() |
long |
getSendCountLong() |
Statistics |
getSendDuration() |
int |
getSendErrorCount() |
long |
getSendErrorCountLong() |
Statistics |
getSendRate() |
double |
getStandardDeviationSendDuration() |
double |
getTimeSinceLastSend() |
boolean |
isCountsEnabled() |
boolean |
isLoggingEnabled() |
boolean |
isStatsEnabled() |
org.springframework.messaging.Message<?> |
receive() |
org.springframework.messaging.Message<?> |
receive(long timeout) |
void |
registerMetricsCaptor(MetricsCaptor registry)
Inject a
MetricsCaptor |
void |
reset() |
boolean |
send(org.springframework.messaging.Message<?> message) |
boolean |
send(org.springframework.messaging.Message<?> message,
long timeout) |
void |
setBeanName(java.lang.String beanName) |
void |
setCountsEnabled(boolean countsEnabled) |
void |
setLoggingEnabled(boolean loggingEnabled) |
void |
setStatsEnabled(boolean statsEnabled) |
java.lang.String |
toString() |
public void setBeanName(java.lang.String beanName)
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
public boolean isLoggingEnabled()
isLoggingEnabled
in interface IntegrationManagement
public void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled
in interface IntegrationManagement
public java.lang.String getComponentName()
getComponentName
in interface NamedComponent
public java.lang.String getComponentType()
getComponentType
in interface NamedComponent
public void registerMetricsCaptor(MetricsCaptor registry)
IntegrationManagement
MetricsCaptor
registerMetricsCaptor
in interface IntegrationManagement
registry
- the captor.public void configureMetrics(AbstractMessageChannelMetrics metrics)
configureMetrics
in interface ConfigurableMetricsAware<AbstractMessageChannelMetrics>
public void reset()
reset
in interface IntegrationManagement
public void setCountsEnabled(boolean countsEnabled)
setCountsEnabled
in interface IntegrationManagement
public boolean isCountsEnabled()
isCountsEnabled
in interface IntegrationManagement
public void setStatsEnabled(boolean statsEnabled)
setStatsEnabled
in interface IntegrationStatsManagement
public boolean isStatsEnabled()
isStatsEnabled
in interface IntegrationStatsManagement
public int getSendCount()
getSendCount
in interface MessageChannelMetrics
public long getSendCountLong()
getSendCountLong
in interface MessageChannelMetrics
public int getSendErrorCount()
getSendErrorCount
in interface MessageChannelMetrics
public long getSendErrorCountLong()
getSendErrorCountLong
in interface MessageChannelMetrics
public double getTimeSinceLastSend()
getTimeSinceLastSend
in interface MessageChannelMetrics
public double getMeanSendRate()
getMeanSendRate
in interface MessageChannelMetrics
public double getMeanErrorRate()
getMeanErrorRate
in interface MessageChannelMetrics
public double getMeanErrorRatio()
getMeanErrorRatio
in interface MessageChannelMetrics
public double getMeanSendDuration()
getMeanSendDuration
in interface MessageChannelMetrics
public double getMinSendDuration()
getMinSendDuration
in interface MessageChannelMetrics
public double getMaxSendDuration()
getMaxSendDuration
in interface MessageChannelMetrics
public double getStandardDeviationSendDuration()
getStandardDeviationSendDuration
in interface MessageChannelMetrics
public Statistics getSendDuration()
getSendDuration
in interface MessageChannelMetrics
public Statistics getSendRate()
getSendRate
in interface MessageChannelMetrics
public Statistics getErrorRate()
getErrorRate
in interface MessageChannelMetrics
public IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagement
getOverrides
in interface IntegrationManagement
public boolean send(org.springframework.messaging.Message<?> message, long timeout)
send
in interface org.springframework.messaging.MessageChannel
public boolean send(org.springframework.messaging.Message<?> message)
send
in interface org.springframework.messaging.MessageChannel
public org.springframework.messaging.Message<?> receive()
receive
in interface org.springframework.messaging.PollableChannel
public org.springframework.messaging.Message<?> receive(long timeout)
receive
in interface org.springframework.messaging.PollableChannel
public java.lang.String toString()
toString
in class java.lang.Object