public class ThroughputSamplerMessageHandler
extends java.lang.Object
implements org.springframework.messaging.MessageHandlerstartMessage と endMessage で Message を受信する間の経過時間にわたってメッセージをカウントすることによってスループットをサンプリングし、指定された TimeUnit でスループットを報告します。| コンストラクターと説明 |
|---|
ThroughputSamplerMessageHandler()String START を開始メッセージとして使用し、String END を終了メッセージとして使用して ThroughputSamplerMessageHandler を作成し、スループットを秒単位で測定します。 |
ThroughputSamplerMessageHandler(java.lang.Object startMessage, java.lang.Object endMessage, java.util.concurrent.TimeUnit sampleUnit) |
ThroughputSamplerMessageHandler(java.lang.String startMessage, java.lang.String endMessage, java.lang.String sampleUnit) |
| 修飾子と型 | メソッドと説明 |
|---|---|
java.lang.Object | getEndMessage() |
java.util.concurrent.TimeUnit | getSampleUnit() |
java.lang.Object | getStartMessage() |
void | handleMessage(org.springframework.messaging.Message<?> message) |
void | setEndMessage(java.lang.Object endMessage) |
void | setSampleUnit(java.lang.String sampleUnit) |
void | setSampleUnit(java.util.concurrent.TimeUnit sampleUnit) |
void | setStartMessage(java.lang.Object startMessage) |
public ThroughputSamplerMessageHandler()
String START を開始メッセージとして使用し、String END を終了メッセージとして使用して ThroughputSamplerMessageHandler を作成し、スループットを秒単位で測定します。public ThroughputSamplerMessageHandler(java.lang.Object startMessage,
java.lang.Object endMessage,
java.util.concurrent.TimeUnit sampleUnit)public ThroughputSamplerMessageHandler(java.lang.String startMessage,
java.lang.String endMessage,
java.lang.String sampleUnit)public java.lang.Object getStartMessage()
public void setStartMessage(java.lang.Object startMessage)
public java.lang.Object getEndMessage()
public void setEndMessage(java.lang.Object endMessage)
public java.util.concurrent.TimeUnit getSampleUnit()
public void setSampleUnit(java.lang.String sampleUnit)
public void setSampleUnit(java.util.concurrent.TimeUnit sampleUnit)
public void handleMessage(org.springframework.messaging.Message<?> message)
throws org.springframework.messaging.MessagingExceptionorg.springframework.messaging.MessageHandler 内の handleMessage org.springframework.messaging.MessagingException