public class OperationInvokingMessageHandler extends AbstractReplyProducingMessageHandler
AbstractMessageHandler.handleMessage(Message)
メソッドに送信されたメッセージに基づいて JMX 操作を呼び出すための MessageHandler
実装。MBean で呼び出される 'objectName' および 'operationName' を解決するときに、最初にメッセージヘッダーがチェックされます。これらの値は、それぞれ JmxHeaders.OBJECT_NAME
および JmxHeaders.OPERATION_NAME
として定義されたメッセージヘッダーで提供されます。いずれの場合も、ヘッダーが存在しない場合は、このインスタンスでそれぞれ setObjectName(String)
および setOperationName(String)
を介して構成されている場合は、値の解決はデフォルトにフォールバックします。操作パラメーターがある場合は、処理するメッセージのペイロード内で使用できる必要があります。ターゲット操作が複数のパラメーターを予期している場合、リスト型またはマップ型のペイロードで提供できます。
AbstractReplyProducingMessageHandler.RequestHandler
IntegrationManagement.ManagementOverrides
messagingTemplate
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
OperationInvokingMessageHandler(MBeanServerConnectionSE server) 提供された MBeanServerConnection SE に基づいてインスタンスを構築します。 |
修飾子と型 | メソッドと説明 |
---|---|
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
IntegrationPatternType | getIntegrationPatternType() このコンポーネントが実装するパターン型を返します。 |
protected ObjectSE | handleRequestMessage(Message<?> requestMessage) サブクラスはこのメソッドを実装して、リクエストメッセージを処理する必要があります。 |
void | setExpectReply(boolean expectReply) 返信メッセージが必要かどうかを指定します。 |
void | setObjectName(StringSE objectName) 処理されるメッセージでそのようなヘッダーが使用できない場合に使用するデフォルトの ObjectName を指定します。 |
void | setOperationName(StringSE operationName) 処理中のメッセージに該当するヘッダーがない場合に呼び出される操作名を指定します。 |
doInit, doInvokeAdvisedRequestHandler, getBeanClassLoader, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, messageBuilderForReply, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput, updateNotPropagatedHeaders
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrack
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getThisAs
getBeanName, getComponentName
public OperationInvokingMessageHandler(MBeanServerConnectionSE server)
MBeanServerConnection
SE に基づいてインスタンスを構築します。server
- 使用する MBeanServerConnection
SE。public void setObjectName(StringSE objectName)
objectName
- オブジェクト名。public void setOperationName(StringSE operationName)
operationName
- 操作名。public void setExpectReply(boolean expectReply)
expectReply
- 応答が期待される場合は true。public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
MessageHandlerSupport
の getComponentType
public IntegrationPatternType getIntegrationPatternType()
IntegrationPattern
IntegrationPattern
の getIntegrationPatternType
AbstractReplyProducingMessageHandler
の getIntegrationPatternType
IntegrationPatternType
protected ObjectSE handleRequestMessage(Message<?> requestMessage)
AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler
の handleRequestMessage
requestMessage
- リクエストメッセージ。null