B - BaseIntegrationFlowDefinition 実装型。public abstract class BaseIntegrationFlowDefinition<B extends BaseIntegrationFlowDefinition<B>> extends ObjectSE
Builder パターン実装。アプリケーションコンテキストでの将来の登録のために、Spring Integration コンポーネントを IntegrationFlow に取り込むためのさまざまな方法を提供します。IntegrationFlowBeanPostProcessor| 修飾子と型 | クラスと説明 |
|---|---|
static class | BaseIntegrationFlowDefinition.ReplyProducerCleaner |
| 修飾子と型 | フィールドと説明 |
|---|---|
protected MapSE<ObjectSE, StringSE> | integrationComponents |
protected static SpelExpressionParser | PARSER |
| 修飾子 | コンストラクターと説明 |
|---|---|
protected | BaseIntegrationFlowDefinition() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected B | _this() |
protected B | addComponent(ObjectSE component) |
protected B | addComponent(ObjectSE component, StringSE beanName) |
protected B | addComponents(MapSE<ObjectSE, StringSE> components) |
B | aggregate()AggregatingMessageHandler にデフォルトオプションを入力します。 |
B | aggregate(java.util.function.ConsumerSE<AggregatorSpec> aggregator)AggregatingMessageHandler に AggregatorSpec から提供されたオプションを入力します。 |
B | barrier(long timeout) 提供されたタイムアウトの BarrierMessageHandler インスタンスを作成します。 |
B | barrier(long timeout, java.util.function.ConsumerSE<BarrierSpec> barrierConfigurer)BarrierSpec から提供されたタイムアウトとオプション、および GenericEndpointSpec からエンドポイントオプションの BarrierMessageHandler インスタンスを作成します。 |
B | bridge()BridgeHandler を現在の統合フロー位置に取り込みます。 |
B | bridge(java.util.function.ConsumerSE<GenericEndpointSpec<BridgeHandler>> endpointConfigurer)BridgeHandler を現在の統合フロー位置に取り込みます。 |
B | channel(java.util.function.FunctionSE<Channels, MessageChannelSpec<?,?>> channels) |
B | channel(MessageChannel messageChannel) 提供された MessageChannel インスタンスを現在の IntegrationFlow チェーン位置に入力します。 |
B | channel(MessageChannelSpec<?,?> messageChannelSpec) |
B | channel(StringSE messageChannelName)MessageChannelReference インスタンスを現在の IntegrationFlow チェーン位置に取り込みます。 |
protected void | checkReuse(MessageProducer replyHandler) |
B | claimCheckIn(MessageStore messageStore) |
B | claimCheckIn(MessageStore messageStore, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) |
B | claimCheckOut(MessageStore messageStore) |
B | claimCheckOut(MessageStore messageStore, boolean removeMessage)ClaimCheckOutTransformer の MessageTransformingHandler に、提供された MessageStore および removeMessage フラグを取り込みます。 |
B | claimCheckOut(MessageStore messageStore, boolean removeMessage, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)ClaimCheckOutTransformer の MessageTransformingHandler に、提供された MessageStore および removeMessage フラグを取り込みます。 |
B | controlBus() |
B | controlBus(java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) |
<P> B | convert(ClassSE<P> payloadType) 提供された payloadType の MessageTransformingHandler インスタンスを生成して、実行時に変換します。 |
<P> B | convert(ClassSE<P> payloadType, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) 提供された payloadType の MessageTransformingHandler インスタンスを生成して、実行時に変換します。 |
protected B | currentComponent(ObjectSE component) |
protected InterceptableChannel | currentInterceptableChannel()InterceptableChannel の場合は現在のチャネルを返し、そうでない場合はフローに新しい暗黙の DirectChannel を登録してそのチャネルを返します。 |
protected B | currentMessageChannel(MessageChannel currentMessageChannel) |
B | delay(StringSE groupId) デフォルトのオプションを使用して、 DelayHandler を現在の統合フロー位置に取り込みます。 |
B | delay(StringSE groupId, java.util.function.ConsumerSE<DelayerEndpointSpec> endpointConfigurer)DelayHandler を現在の統合フロー位置に取り込みます。 |
B | enrich(java.util.function.ConsumerSE<EnricherSpec> enricherConfigurer) 指定されたオプションを使用して、 ContentEnricher を現在の統合フロー位置に取り込みます。 |
B | enrichHeaders(java.util.function.ConsumerSE<HeaderEnricherSpec> headerEnricherConfigurer) |
B | enrichHeaders(MapSE<StringSE, ObjectSE> headers) |
B | enrichHeaders(MapSE<StringSE, ObjectSE> headers, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) |
B | enrichHeaders(MapBuilder<?,StringSE, ObjectSE> headers) |
B | enrichHeaders(MapBuilder<?,StringSE, ObjectSE> headers, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer) |
protected static ObjectSE | extractProxyTarget(ObjectSE target) |
<P> B | filter(ClassSE<P> payloadType, GenericSelector<P> genericSelector) |
<P> B | filter(ClassSE<P> payloadType, GenericSelector<P> genericSelector, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer) |
B | filter(MessageProcessorSpec<?> messageProcessorSpec) |
B | filter(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer) |
B | filter(ObjectSE service) 提供されたサービスの検出されたメソッドのために、 MessageFilter に MethodInvokingSelector を取り込みます。 |
B | filter(ObjectSE service, StringSE methodName) 提供されたサービスのメソッドのために、 MessageFilter に MethodInvokingSelector を取り込みます。 |
B | filter(ObjectSE service, StringSE methodName, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer) 提供されたサービスのメソッドのために、 MessageFilter に MethodInvokingSelector を取り込みます。 |
B | filter(StringSE expression) 指定された SpEL 式の MessageFilter に MessageSelector を入力します。 |
B | filter(StringSE expression, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer) 指定された SpEL 式の MessageFilter に MessageSelector を入力します。 |
B | fixedSubscriberChannel() 現在の IntegrationFlow チェーン位置に FixedSubscriberChannel インスタンスを作成します。 |
B | fixedSubscriberChannel(StringSE messageChannelName) 現在の IntegrationFlow チェーン位置に FixedSubscriberChannel インスタンスを作成します。 |
<I,O> B | fluxTransform(java.util.function.FunctionSE<? super reactor.core.publisher.Flux<Message<I>>,? extends org.reactivestreams.Publisher<O>> fluxFunction)FluxMessageChannel にデータを入力して上流データのリアクティブ処理を開始し、それを Flux にラップし、提供された FunctionSE を Flux.transform(Function) を介して適用し、結果を下流のフローでサブスクライブされている 1 つ以上の FluxMessageChannel に送信します。 |
B | gateway(IntegrationFlow flow) 提供された subflow の「人工」GatewayMessageHandler にデータを入力します。 |
B | gateway(IntegrationFlow flow, java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer) |
B | gateway(MessageChannel requestChannel) 提供された requestChannel の「人工」GatewayMessageHandler にデータを入力して、デフォルトオプションでリクエストを送信します。 |
B | gateway(MessageChannel requestChannel, java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer) 提供された requestChannel の「人工」GatewayMessageHandler にデータを入力して、GatewayEndpointSpec からオプションを使用してリクエストを送信します。 |
B | gateway(StringSE requestChannel) 提供された requestChannel の「人工」GatewayMessageHandler にデータを入力して、デフォルトオプションでリクエストを送信します。 |
B | gateway(StringSE requestChannel, java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer) 提供された requestChannel の「人工」GatewayMessageHandler にデータを入力して、GatewayEndpointSpec からオプションを使用してリクエストを送信します。 |
protected StandardIntegrationFlow | get() |
protected ObjectSE | getCurrentComponent() |
protected MessageChannel | getCurrentMessageChannel() |
protected MapSE<ObjectSE, StringSE> | getIntegrationComponents() |
<P> B | handle(ClassSE<P> payloadType, GenericHandler<P> handler) |
<P> B | handle(ClassSE<P> payloadType, GenericHandler<P> handler, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer) |
<H extends MessageHandler> | handle(H messageHandler, java.util.function.ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer) 提供された MessageHandler 実装の ServiceActivatingHandler を生成します。 |
B | handle(MessageHandler messageHandler) 提供された MessageHandler 実装の ServiceActivatingHandler を生成します。 |
<H extends MessageHandler> | handle(MessageHandlerSpec<?,H> messageHandlerSpec)Namespace Factory から、選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を生成します。
|
<H extends MessageHandler> |
handle(MessageHandlerSpec<?,H> messageHandlerSpec,
java.util.function.ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer)
Populate a
ServiceActivatingHandler for the selected protocol specific
MessageHandler implementation from Namespace Factory:
In addition accept options for the integration endpoint using GenericEndpointSpec. |
B |
handle(MessageProcessorSpec<?> messageProcessorSpec)
Populate a
ServiceActivatingHandler for the
MessageProcessor from the provided
MessageProcessorSpec. |
B |
handle(MessageProcessorSpec<?> messageProcessorSpec,
java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
Populate a
ServiceActivatingHandler for the
MessageProcessor from the provided
MessageProcessorSpec. |
B |
handle(ObjectSE service)
Populate a
ServiceActivatingHandler for the
MethodInvokingMessageProcessor
to invoke the discovered method for provided service at runtime. |
B |
handle(ObjectSE service,
StringSE methodName)
Populate a
ServiceActivatingHandler for the
MethodInvokingMessageProcessor
to invoke the method for provided bean at runtime. |
B |
handle(ObjectSE service,
StringSE methodName,
java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
Populate a
ServiceActivatingHandler for the
MethodInvokingMessageProcessor
to invoke the method for provided bean at runtime. |
B |
handle(StringSE beanName,
StringSE methodName)
Populate a
ServiceActivatingHandler for the
MethodInvokingMessageProcessor
to invoke the method for provided bean at runtime. |
B |
handle(StringSE beanName,
StringSE methodName,
java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
Populate a
ServiceActivatingHandler for the
MethodInvokingMessageProcessor
to invoke the method for provided bean at runtime. |
B |
headerFilter(HeaderFilter headerFilter,
java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
Populate the provided
MessageTransformingHandler for the provided
HeaderFilter. |
B |
headerFilter(StringSE... headersToRemove)
Provide the
HeaderFilter to the current StandardIntegrationFlow. |
B |
headerFilter(StringSE headersToRemove,
boolean patternMatch)
Provide the
HeaderFilter to the current StandardIntegrationFlow. |
B |
intercept(ChannelInterceptor... interceptorArray)
Add one or more
ChannelInterceptor implementations
to the current currentMessageChannel, in the given order, after any interceptors already registered. |
protected boolean |
isImplicitChannel() |
protected boolean |
isOutputChannelRequired() |
B |
log()
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO
logging level and org.springframework.integration.handler.LoggingHandler
as a default logging category. |
B |
log(Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and SpEL expression to evaluate
logger message at runtime against the request Message. |
<P> B |
log(java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and FunctionSE for the log message. |
B |
log(LoggingHandler.Level level)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for provided LoggingHandler.Level
logging level and org.springframework.integration.handler.LoggingHandler
as a default logging category. |
B |
log(LoggingHandler.Level level,
Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and SpEL expression to evaluate
logger message at runtime against the request Message. |
<P> B |
log(LoggingHandler.Level level,
java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and FunctionSE for the log message. |
B |
log(LoggingHandler.Level level,
StringSE category)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level and logging category. |
B |
log(LoggingHandler.Level level,
StringSE category,
Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level, logging category
and SpEL expression for the log message. |
<P> B |
log(LoggingHandler.Level level,
StringSE category,
java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level, logging category
and FunctionSE for the log message. |
B |
log(LoggingHandler.Level level,
StringSE category,
StringSE logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level, logging category
and SpEL expression for the log message. |
B |
log(StringSE category)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided logging category
and INFO logging level. |
B |
log(StringSE category,
Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO
LoggingHandler.Level logging level,
the provided logging category and SpEL expression to evaluate
logger message at runtime against the request Message. |
<P> B |
log(StringSE category,
java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level,
the provided logging category and FunctionSE for the log message. |
IntegrationFlow |
logAndReply()
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO
logging level and org.springframework.integration.handler.LoggingHandler
as a default logging category. |
IntegrationFlow |
logAndReply(Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and SpEL expression to evaluate
logger message at runtime against the request Message. |
<P> IntegrationFlow |
logAndReply(java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and FunctionSE for the log message. |
IntegrationFlow |
logAndReply(LoggingHandler.Level level)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for provided LoggingHandler.Level
logging level and org.springframework.integration.handler.LoggingHandler
as a default logging category. |
IntegrationFlow |
logAndReply(LoggingHandler.Level level,
Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and SpEL expression to evaluate
logger message at runtime against the request Message. |
<P> IntegrationFlow |
logAndReply(LoggingHandler.Level level,
java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level,
the org.springframework.integration.handler.LoggingHandler
as a default logging category and FunctionSE for the log message. |
IntegrationFlow |
logAndReply(LoggingHandler.Level level,
StringSE category)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level and logging category. |
IntegrationFlow |
logAndReply(LoggingHandler.Level level,
StringSE category,
Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level, logging category
and SpEL expression for the log message. |
<P> IntegrationFlow |
logAndReply(LoggingHandler.Level level,
StringSE category,
java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level, logging category
and FunctionSE for the log message. |
IntegrationFlow |
logAndReply(LoggingHandler.Level level,
StringSE category,
StringSE logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level, logging category
and SpEL expression for the log message. |
IntegrationFlow |
logAndReply(StringSE category)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided logging category
and INFO logging level. |
IntegrationFlow |
logAndReply(StringSE category,
Expression logExpression)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the INFO
LoggingHandler.Level logging level,
the provided logging category and SpEL expression to evaluate
logger message at runtime against the request Message. |
<P> IntegrationFlow |
logAndReply(StringSE category,
java.util.function.FunctionSE<Message<P>,ObjectSE> function)
Populate a
WireTap for the currentMessageChannel
with the LoggingHandler subscriber for the provided
LoggingHandler.Level logging level,
the provided logging category and FunctionSE for the log message. |
IntegrationFlow |
nullChannel()
Add a bean into this flow
definition as a terminal operator.
|
protected MessageChannel |
obtainInputChannelFromFlow(IntegrationFlow flow) |
B |
publishSubscribeChannel(BroadcastCapableChannel broadcastCapableChannel,
java.util.function.ConsumerSE<BroadcastPublishSubscribeSpec> publishSubscribeChannelConfigurer)
The
BroadcastCapableChannel channel(java.lang.String)
method specific implementation to allow the use of the 'subflow' subscriber capability. |
B |
publishSubscribeChannel(java.util.function.ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
The
PublishSubscribeChannel channel(java.lang.String)
method specific implementation to allow the use of the 'subflow' subscriber capability. |
B |
publishSubscribeChannel(ExecutorSE executor,
java.util.function.ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
The
PublishSubscribeChannel channel(java.lang.String)
method specific implementation to allow the use of the 'subflow' subscriber capability. |
protected <S extends ConsumerEndpointSpec<? super S,? extends MessageHandler>> |
register(S endpointSpec,
java.util.function.ConsumerSE<S> endpointConfigurer) |
protected B |
registerOutputChannelIfCan(MessageChannel outputChannel) |
B |
resequence()
Populate the
ResequencingMessageHandler with
default options. |
B |
resequence(java.util.function.ConsumerSE<ResequencerSpec> resequencer)
Populate the
ResequencingMessageHandler with
provided options from ResequencerSpec. |
B |
route(AbstractMessageRouter router)
Populate the provided
AbstractMessageRouter implementation to the
current integration flow position. |
<P,T> B |
route(ClassSE<P> payloadType,
java.util.function.FunctionSE<P,T> router,
java.util.function.ConsumerSE<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)
Populate the
MethodInvokingRouter for provided FunctionSE
and payload type and options from RouterSpec. |
<S,T> B |
route(ClassSE<S> payloadType,
java.util.function.FunctionSE<S,T> router)
Populate the
MethodInvokingRouter for provided FunctionSE
and payload type with default options. |
B |
route(MessageProcessorSpec<?> messageProcessorSpec)
Populate the
MethodInvokingRouter for the
MessageProcessor
from the provided MessageProcessorSpec with default options. |
B |
route(MessageProcessorSpec<?> messageProcessorSpec,
java.util.function.ConsumerSE<RouterSpec<ObjectSE,MethodInvokingRouter>> routerConfigurer)
Populate the
MethodInvokingRouter for the
MessageProcessor
from the provided MessageProcessorSpec with default options. |
B |
route(ObjectSE service)
Populate the
MethodInvokingRouter for the discovered method
of the provided service and its method with default options. |
B |
route(ObjectSE service,
StringSE methodName)
Populate the
MethodInvokingRouter for the method
of the provided service and its method with default options. |
B |
route(ObjectSE service,
StringSE methodName,
java.util.function.ConsumerSE<RouterSpec<ObjectSE,MethodInvokingRouter>> routerConfigurer)
Populate the
MethodInvokingRouter for the method
of the provided service and its method with provided options from RouterSpec. |
<R extends AbstractMessageRouter> |
route(R router,
java.util.function.ConsumerSE<GenericEndpointSpec<R>> endpointConfigurer)
Populate the provided
AbstractMessageRouter implementation to the
current integration flow position. |
protected <R extends AbstractMessageRouter,S extends AbstractRouterSpec<? super S,R>> |
route(S routerSpec,
java.util.function.ConsumerSE<S> routerConfigurer) |
B |
route(StringSE expression)
Populate the
ExpressionEvaluatingRouter for provided SpEL expression
with default options. |
<T> B |
route(StringSE expression,
java.util.function.ConsumerSE<RouterSpec<T,ExpressionEvaluatingRouter>> routerConfigurer)
Populate the
ExpressionEvaluatingRouter for provided SpEL expression
with provided options from RouterSpec. |
B |
route(StringSE beanName,
StringSE method)
Populate the
MethodInvokingRouter for provided bean and its method
with default options. |
B |
route(StringSE beanName,
StringSE method,
java.util.function.ConsumerSE<RouterSpec<ObjectSE,MethodInvokingRouter>> routerConfigurer)
Populate the
MethodInvokingRouter for provided bean and its method
with provided options from RouterSpec. |
B |
routeByException(java.util.function.ConsumerSE<RouterSpec<ClassSE<? extends ThrowableSE>,ErrorMessageExceptionTypeRouter>> routerConfigurer)
Populate the
ErrorMessageExceptionTypeRouter with options from the RouterSpec. |
B |
routeToRecipients(java.util.function.ConsumerSE<RecipientListRouterSpec> routerConfigurer)
Populate the
RecipientListRouter with options from the RecipientListRouterSpec. |
B |
scatterGather(java.util.function.ConsumerSE<RecipientListRouterSpec> scatterer)
Populate a
ScatterGatherHandler to the current integration flow position
based on the provided RecipientListRouterSpec for scattering function
and default AggregatorSpec for gathering function. |
B |
scatterGather(java.util.function.ConsumerSE<RecipientListRouterSpec> scatterer,
java.util.function.ConsumerSE<AggregatorSpec> gatherer)
Populate a
ScatterGatherHandler to the current integration flow position
based on the provided RecipientListRouterSpec for scattering function
and AggregatorSpec for gathering function. |
B |
scatterGather(java.util.function.ConsumerSE<RecipientListRouterSpec> scatterer,
java.util.function.ConsumerSE<AggregatorSpec> gatherer,
java.util.function.ConsumerSE<ScatterGatherSpec> scatterGather)
Populate a
ScatterGatherHandler to the current integration flow position
based on the provided RecipientListRouterSpec for scattering function
and AggregatorSpec for gathering function. |
B |
scatterGather(MessageChannel scatterChannel)
Populate a
ScatterGatherHandler to the current integration flow position
based on the provided MessageChannel for scattering function
and default AggregatorSpec for gathering function. |
B |
scatterGather(MessageChannel scatterChannel,
java.util.function.ConsumerSE<AggregatorSpec> gatherer)
Populate a
ScatterGatherHandler to the current integration flow position
based on the provided MessageChannel for scattering function
and AggregatorSpec for gathering function. |
B |
scatterGather(MessageChannel scatterChannel,
java.util.function.ConsumerSE<AggregatorSpec> gatherer,
java.util.function.ConsumerSE<ScatterGatherSpec> scatterGather)
Populate a
ScatterGatherHandler to the current integration flow position
based on the provided MessageChannel for scattering function
and AggregatorSpec for gathering function. |
protected void |
setImplicitChannel(boolean implicitChannel) |
B |
split()
Populate the
DefaultMessageSplitter with default options
to the current integration flow position. |
B |
split(AbstractMessageSplitter splitter)
Populate the provided
AbstractMessageSplitter to the current integration
flow position. |
<P> B |
split(ClassSE<P> payloadType,
java.util.function.FunctionSE<P,?> splitter)
Populate the
MethodInvokingSplitter to evaluate the provided
FunctionSE at runtime. |
<P> B |
split(ClassSE<P> payloadType,
java.util.function.FunctionSE<P,?> splitter,
java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
Populate the
MethodInvokingSplitter to evaluate the provided
FunctionSE at runtime. |
B |
split(java.util.function.ConsumerSE<SplitterEndpointSpec<DefaultMessageSplitter>> endpointConfigurer)
Populate the
DefaultMessageSplitter with provided options
to the current integration flow position. |
<S extends AbstractMessageSplitter> |
split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec)
Populate the provided
AbstractMessageSplitter to the current integration
flow position. |
<S extends AbstractMessageSplitter> |
split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec,
java.util.function.ConsumerSE<SplitterEndpointSpec<S>> endpointConfigurer)
Populate the provided
AbstractMessageSplitter to the current integration
flow position. |
B |
split(MessageProcessorSpec<?> messageProcessorSpec)
Populate the
MethodInvokingSplitter to evaluate the
MessageProcessor at runtime
from provided MessageProcessorSpec. |
B |
split(MessageProcessorSpec<?> messageProcessorSpec,
java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
Populate the
MethodInvokingSplitter to evaluate the
MessageProcessor at runtime
from provided MessageProcessorSpec. |
B |
split(ObjectSE service)
|
B |
split(ObjectSE service,
StringSE methodName)
|
B |
split(ObjectSE service,
StringSE methodName,
java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
|
<S extends AbstractMessageSplitter> |
split(S splitter,
java.util.function.ConsumerSE<SplitterEndpointSpec<S>> endpointConfigurer)
Populate the provided
AbstractMessageSplitter to the current integration
flow position. |
B |
split(StringSE expression)
Populate the
ExpressionEvaluatingSplitter with provided
SpEL expression. |
B |
split(StringSE expression,
java.util.function.ConsumerSE<SplitterEndpointSpec<ExpressionEvaluatingSplitter>> endpointConfigurer)
Populate the
ExpressionEvaluatingSplitter with provided
SpEL expression. |
B |
split(StringSE beanName,
StringSE methodName)
|
B |
split(StringSE beanName,
StringSE methodName,
java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
|
protected <T> org.reactivestreams.Publisher<Message<T>> |
toReactivePublisher()
Represent an Integration Flow as a Reactive Streams
Publisher bean. |
<P,T> B |
transform(ClassSE<P> payloadType,
GenericTransformer<P,T> genericTransformer)
Populate the
MessageTransformingHandler instance for the provided
GenericTransformer for the specific payloadType to convert at
runtime. |
<P,T> B |
transform(ClassSE<P> payloadType,
GenericTransformer<P,T> genericTransformer,
java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
Populate the
MessageTransformingHandler instance for the provided GenericTransformer
for the specific payloadType to convert at runtime. |
B |
transform(MessageProcessorSpec<?> messageProcessorSpec)
Populate the
MessageTransformingHandler instance for the
MessageProcessor from provided MessageProcessorSpec. |
B |
transform(MessageProcessorSpec<?> messageProcessorSpec,
java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
Populate the
MessageTransformingHandler instance for the
MessageProcessor from provided MessageProcessorSpec. |
B |
transform(ObjectSE service)
Populate the
MessageTransformingHandler for the MethodInvokingTransformer
to invoke the discovered service method at runtime. |
B |
transform(ObjectSE service,
StringSE methodName)
Populate the
MessageTransformingHandler for the MethodInvokingTransformer
to invoke the service method at runtime. |
B |
transform(ObjectSE service,
StringSE methodName,
java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
Populate the
MessageTransformingHandler for the MethodInvokingTransformer
to invoke the service method at runtime. |
B |
transform(StringSE expression)
|
B |
transform(StringSE expression,
java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
|
B |
trigger(MessageTriggerAction triggerAction)
Populate a
ServiceActivatingHandler instance to perform MessageTriggerAction. |
B |
trigger(MessageTriggerAction triggerAction,
java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
Populate a
ServiceActivatingHandler instance to perform MessageTriggerAction
and endpoint options from GenericEndpointSpec. |
B |
trigger(StringSE triggerActionId)
Populate a
ServiceActivatingHandler instance to perform MessageTriggerAction. |
B |
trigger(StringSE triggerActionId,
java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
Populate a
ServiceActivatingHandler instance to perform MessageTriggerAction
and endpoint options from GenericEndpointSpec. |
B |
wireTap(IntegrationFlow flow)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
B |
wireTap(IntegrationFlow flow,
java.util.function.ConsumerSE<WireTapSpec> wireTapConfigurer)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
B |
wireTap(MessageChannel wireTapChannel)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
B |
wireTap(MessageChannel wireTapChannel,
java.util.function.ConsumerSE<WireTapSpec> wireTapConfigurer)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
B |
wireTap(StringSE wireTapChannel)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
B |
wireTap(StringSE wireTapChannel,
java.util.function.ConsumerSE<WireTapSpec> wireTapConfigurer)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
B |
wireTap(WireTapSpec wireTapSpec)
Populate the
Wire Tap EI Pattern specific
ChannelInterceptor implementation
to the current currentMessageChannel. |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected static final SpelExpressionParser PARSER
protected B currentMessageChannel(@Nullable MessageChannel currentMessageChannel)
@Nullable protected MessageChannel getCurrentMessageChannel()
protected InterceptableChannel currentInterceptableChannel()
InterceptableChannel の場合は現在のチャネルを返し、そうでない場合はフローに新しい暗黙の DirectChannel を登録してそのチャネルを返します。protected void setImplicitChannel(boolean implicitChannel)
protected boolean isImplicitChannel()
public B fixedSubscriberChannel()
IntegrationFlow チェーン位置に FixedSubscriberChannel インスタンスを生成します。「Bean 名」は、Bean 登録フェーズ中に生成されます。BaseIntegrationFlowDefinition。public B fixedSubscriberChannel(StringSE messageChannelName)
IntegrationFlow チェーンの位置に FixedSubscriberChannel インスタンスを入力します。提供された messageChannelName は、Bean 登録に使用されます。messageChannelName - 使用する Bean 名。BaseIntegrationFlowDefinition。public B channel(StringSE messageChannelName)
IntegrationFlow チェーンの位置に MessageChannelReference インスタンスを入力します。アプリケーションコンテキストにそのような Bean がない場合、提供された messageChannelName は Bean 登録(DirectChannel)に使用されます。それ以外の場合は、既存の MessageChannel Bean を使用して統合エンドポイントを接続します。messageChannelName - 使用する Bean 名。BaseIntegrationFlowDefinition。public B channel(MessageChannelSpec<?,?> messageChannelSpec)
messageChannelSpec - 使用する MessageChannelSpec。BaseIntegrationFlowDefinition。MessageChannelspublic B channel(MessageChannel messageChannel)
MessageChannel インスタンスを現在の IntegrationFlow チェーン位置に入力します。messageChannel は、既存の Bean または新規インスタンスにすることができます。その場合、IntegrationFlowBeanPostProcessor は、生成された名前で Bean としてそれを生成します。messageChannel - 投入する MessageChannelBaseIntegrationFlowDefinition。public B channel(java.util.function.FunctionSE<Channels,MessageChannelSpec<?,?>> channels)
channels - 使用する FunctionSE。BaseIntegrationFlowDefinition。public B publishSubscribeChannel(java.util.function.ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
PublishSubscribeChannel channel(java.lang.String) メソッド固有の実装。「サブフロー」サブスクライバー機能の使用を許可します。publishSubscribeChannelConfigurer - ConsumerSE は、「サブフロー」定義を含む PublishSubscribeSpec オプションを指定します。BaseIntegrationFlowDefinition。public B publishSubscribeChannel(ExecutorSE executor, java.util.function.ConsumerSE<PublishSubscribeSpec> publishSubscribeChannelConfigurer)
PublishSubscribeChannel channel(java.lang.String) メソッド固有の実装。ターゲットサブスクライバーには、提供されている ExecutorSE を使用します。executor - 使用する ExecutorSE。publishSubscribeChannelConfigurer - ConsumerSE は、「サブフロー」定義を含む PublishSubscribeSpec オプションを指定します。BaseIntegrationFlowDefinition。public B publishSubscribeChannel(BroadcastCapableChannel broadcastCapableChannel, java.util.function.ConsumerSE<BroadcastPublishSubscribeSpec> publishSubscribeChannelConfigurer)
BroadcastCapableChannel channel(java.lang.String) メソッド固有の実装。「サブフロー」サブスクライバー機能の使用を許可します。broadcastCapableChannel - BroadcastCapableChannel からサブスクライバーへのサブフロー。publishSubscribeChannelConfigurer - BroadcastPublishSubscribeSpec の「サブフロー」定義を指定する ConsumerSE。BaseIntegrationFlowDefinition。public B wireTap(IntegrationFlow flow)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
.filter("World"::equals)
.wireTap(sf -> sf.<String, String>transform(String::toUpperCase))
.handle(p -> process(p))
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。flow - wireTapChannel の代替としての、ワイヤータップサブフロー用の IntegrationFlowBaseIntegrationFlowDefinition。public B wireTap(StringSE wireTapChannel)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
f -> f.wireTap("tapChannel")
.handle(p -> process(p))
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。wireTapChannel - 盗聴する MessageChannel Bean の名前。BaseIntegrationFlowDefinition。public B wireTap(MessageChannel wireTapChannel)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
.transform("payload")
.wireTap(tapChannel())
.channel("foo")
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。wireTapChannel - ワイヤータップする MessageChannelBaseIntegrationFlowDefinition。public B wireTap(IntegrationFlow flow, java.util.function.ConsumerSE<WireTapSpec> wireTapConfigurer)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
.transform("payload")
.wireTap(sf -> sf.<String, String>transform(String::toUpperCase), wt -> wt.selector("payload == 'foo'"))
.channel("foo")
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。flow - wireTapChannel の代替としての、ワイヤータップサブフロー用の IntegrationFlowwireTapConfigurer - WireTap のオプションを受け入れる ConsumerSEBaseIntegrationFlowDefinition。protected MessageChannel obtainInputChannelFromFlow(IntegrationFlow flow)
public B wireTap(StringSE wireTapChannel, java.util.function.ConsumerSE<WireTapSpec> wireTapConfigurer)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
.transform("payload")
.wireTap("tapChannel", wt -> wt.selector(m -> m.getPayload().equals("foo")))
.channel("foo")
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。wireTapChannel - 盗聴する MessageChannel Bean の名前。wireTapConfigurer - WireTap のオプションを受け入れる ConsumerSEBaseIntegrationFlowDefinition。public B wireTap(MessageChannel wireTapChannel, java.util.function.ConsumerSE<WireTapSpec> wireTapConfigurer)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
.transform("payload")
.wireTap(tapChannel(), wt -> wt.selector(m -> m.getPayload().equals("foo")))
.channel("foo")
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。wireTapChannel - ワイヤータップする MessageChannelwireTapConfigurer - WireTap のオプションを受け入れる ConsumerSEBaseIntegrationFlowDefinition。public B wireTap(WireTapSpec wireTapSpec)
Wire Tap EI パターン固有の ChannelInterceptor 実装を現在の currentMessageChannel に入力します。 エンドポイント間で暗黙の MessageChannel が使用されている場合に役立ちます。
.transform("payload")
.wireTap(new WireTap(tapChannel().selector(m -> m.getPayload().equals("foo")))
.channel("foo")
このメソッドは、明示的な MessageChannel の channel(java.lang.String) の後で使用できますが、既存の ChannelInterceptor には影響しません。wireTapSpec - 使用する WireTapSpec。 この EIP メソッドをフローの最後で使用すると、nullChannel が追加されてフローが適切に終了します。それ以外の場合は、暗黙の DirectChannel に対して Dispatcher has no subscribers 例外がスローされます。
BaseIntegrationFlowDefinition。public B controlBus()
BaseIntegrationFlowDefinition。ExpressionCommandMessageProcessorpublic B controlBus(java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
endpointConfigurer - 統合エンドポイントオプションを受け入れる ConsumerSE。BaseIntegrationFlowDefinition。ExpressionCommandMessageProcessor, GenericEndpointSpecpublic B transform(StringSE expression)
expression - Transformer ExpressionBaseIntegrationFlowDefinition。ExpressionEvaluatingTransformerpublic B transform(StringSE expression, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
expression - Transformer ExpressionendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。ExpressionEvaluatingTransformerpublic B transform(ObjectSE service)
MethodInvokingTransformer の MessageTransformingHandler を設定します。service - 使用するサービス。BaseIntegrationFlowDefinition。ExpressionEvaluatingTransformerpublic B transform(ObjectSE service, StringSE methodName)
MethodInvokingTransformer の MessageTransformingHandler を設定して、実行時にサービスメソッドを呼び出します。service - 使用するサービス。methodName - 呼び出すメソッド。BaseIntegrationFlowDefinition。MethodInvokingTransformerpublic B transform(ObjectSE service, StringSE methodName, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
MethodInvokingTransformer の MessageTransformingHandler を設定して、実行時にサービスメソッドを呼び出します。service - 使用するサービス。methodName - 呼び出すメソッド。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。ExpressionEvaluatingTransformerpublic B transform(MessageProcessorSpec<?> messageProcessorSpec)
MessageProcessorSpec から MessageProcessor の MessageTransformingHandler インスタンスを生成します。
.transform(Scripts.script("classpath:myScript.py").variable("foo", bar()))
messageProcessorSpec - 使用する MessageProcessorSpec。BaseIntegrationFlowDefinition。MethodInvokingTransformerpublic B transform(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
MessageProcessorSpec から MessageProcessor の MessageTransformingHandler インスタンスを生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。
.transform(Scripts.script("classpath:myScript.py").variable("foo", bar()),
e -> e.autoStartup(false))
messageProcessorSpec - 使用する MessageProcessorSpec。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。MethodInvokingTransformerpublic <P> B convert(ClassSE<P> payloadType)
payloadType の MessageTransformingHandler インスタンスを生成して、実行時に変換します。P - ペイロード型 - ' に変換 '。payloadType - 予想されるペイロード型の ClassSEBaseIntegrationFlowDefinition。MethodInvokingTransformer, LambdaMessageProcessorpublic <P,T> B transform(ClassSE<P> payloadType, GenericTransformer<P,T> genericTransformer)
P - ペイロード型 - 'transform from' または Message.class。T - ターゲット型 - 「変換する」。payloadType - 予想されるペイロード型の ClassSE トランスフォーマー内のメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。genericTransformer - 投入する GenericTransformerBaseIntegrationFlowDefinition。MethodInvokingTransformer, LambdaMessageProcessorpublic <P> B convert(ClassSE<P> payloadType, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
payloadType の MessageTransformingHandler インスタンスに入力して、実行時に変換します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。P - ペイロード型 - 「変換する」。payloadType - 予想されるペイロード型の ClassSEendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpecpublic <P,T> B transform(ClassSE<P> payloadType, GenericTransformer<P,T> genericTransformer, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
payloadType が実行時に変換するために、提供された GenericTransformer の MessageTransformingHandler インスタンスを生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。P - ペイロード型 - 'transform from' または Message.class。T - ターゲット型 - 「変換する」。payloadType - 予想されるペイロード型の ClassSE トランスフォーマー内のメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。genericTransformer - 投入する GenericTransformerendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。MethodInvokingTransformer, LambdaMessageProcessor, GenericEndpointSpecpublic B filter(StringSE expression)
MessageFilter に MessageSelector を入力します。expression - SpEL 式。BaseIntegrationFlowDefinition。public B filter(StringSE expression, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)
MessageFilter に MessageSelector を入力します。さらに、FilterEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。
.filter("payload.hot"), e -> e.autoStartup(false))
expression - SpEL 式。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。FilterEndpointSpecpublic B filter(ObjectSE service)
MessageFilter に MethodInvokingSelector を取り込みます。service - 使用するサービス。BaseIntegrationFlowDefinition。MethodInvokingSelectorpublic B filter(ObjectSE service, StringSE methodName)
MessageFilter に MethodInvokingSelector を取り込みます。service - 使用するサービス。methodName - 呼び出すメソッド BaseIntegrationFlowDefinition。MethodInvokingSelectorpublic B filter(ObjectSE service, StringSE methodName, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)
MessageFilter に MethodInvokingSelector を取り込みます。service - 使用するサービス。methodName - 呼び出すメソッド endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。MethodInvokingSelectorpublic B filter(MessageProcessorSpec<?> messageProcessorSpec)
MessageFilter に、提供された MessageProcessorSpec から MessageProcessor の MethodInvokingSelector を取り込みます。
.filter(Scripts.script(scriptResource).lang("ruby"))
messageProcessorSpec - 使用する MessageProcessorSpec。BaseIntegrationFlowDefinition。public B filter(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)
MessageProcessorSpec から MessageProcessor の MethodInvokingSelector を MessageFilter に入力します。さらに、FilterEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。
.filter(Scripts.script(scriptResource).lang("ruby"),
e -> e.autoStartup(false))
messageProcessorSpec - 使用する MessageProcessorSpec。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public <P> B filter(ClassSE<P> payloadType, GenericSelector<P> genericSelector)
GenericSelector の MethodInvokingSelector を MessageFilter に入力します。通常、Java 8 ラムダ式で使用されます。
.filter(Date.class, p -> p.after(new Date()))
P - ソースのペイロード型または Message.classpayloadType - 予想されるペイロード型の ClassSE セレクターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。genericSelector - 使用する GenericSelector。BaseIntegrationFlowDefinition。LambdaMessageProcessorpublic <P> B filter(ClassSE<P> payloadType, GenericSelector<P> genericSelector, java.util.function.ConsumerSE<FilterEndpointSpec> endpointConfigurer)
GenericSelector の MethodInvokingSelector を MessageFilter に入力します。さらに、FilterEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.filter(Date.class, p -> p.after(new Date()), e -> e.autoStartup(false))
P - ソースのペイロード型または Message.classpayloadType - 予想されるペイロード型の ClassSE セレクターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。genericSelector - 使用する GenericSelector。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。LambdaMessageProcessor, FilterEndpointSpecpublic <H extends MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec)
Namespace Factory から、選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を生成します。
.handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"))
H - ターゲット MessageHandler 型。messageHandlerSpec - プロトコル固有の MessageHandler を構成する MessageHandlerSpec。BaseIntegrationFlowDefinition。public B handle(MessageHandler messageHandler)
MessageHandler 実装の ServiceActivatingHandler を生成します。Java 8 ラムダ式として使用できます。
.handle(m -> logger.info(m.getPayload())
messageHandler - 使用する MessageHandler。BaseIntegrationFlowDefinition。public B handle(StringSE beanName, StringSE methodName)
beanName - 使用する Bean 名。methodName - 呼び出すメソッド。BaseIntegrationFlowDefinition。public B handle(StringSE beanName, StringSE methodName, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
MethodInvokingMessageProcessor の ServiceActivatingHandler にデータを入力して、提供された bean の method を実行時に呼び出します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。beanName - 使用する Bean 名。methodName - 呼び出すメソッド。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B handle(ObjectSE service)
MethodInvokingMessageProcessor の ServiceActivatingHandler を入力して、実行時に提供された service のディスカバーされた method を呼び出します。service - 使用するサービスオブジェクト。BaseIntegrationFlowDefinition。public B handle(ObjectSE service, StringSE methodName)
MethodInvokingMessageProcessor の ServiceActivatingHandler にデータを入力して、提供された bean の method を実行時に呼び出します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。service - 使用するサービスオブジェクト。methodName - 呼び出すメソッド。BaseIntegrationFlowDefinition。public B handle(ObjectSE service, StringSE methodName, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
MethodInvokingMessageProcessor の ServiceActivatingHandler にデータを入力して、提供された bean の method を実行時に呼び出します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。service - 使用するサービスオブジェクト。methodName - 呼び出すメソッド。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public <P> B handle(ClassSE<P> payloadType, GenericHandler<P> handler)
GenericHandler を呼び出すために、MethodInvokingMessageProcessor の ServiceActivatingHandler を設定します。通常、Java 8 ラムダ式で使用されます。
.handle(Integer.class, (p, h) -> p / 2)
P - 期待するペイロード型、または Message.class。payloadType - 予想されるペイロード型の ClassSE ハンドラーでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。handler - 呼び出すハンドラー。BaseIntegrationFlowDefinition。LambdaMessageProcessorpublic <P> B handle(ClassSE<P> payloadType, GenericHandler<P> handler, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
GenericHandler を呼び出すために、MethodInvokingMessageProcessor の ServiceActivatingHandler を設定します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.handle(Integer.class, (p, h) -> p / 2, e -> e.autoStartup(false))
P - 期待するペイロード型または Message.class。payloadType - 予想されるペイロード型の ClassSE ハンドラーでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。handler - 呼び出すハンドラー。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。LambdaMessageProcessorpublic B handle(MessageProcessorSpec<?> messageProcessorSpec)
MessageProcessorSpec から MessageProcessor の ServiceActivatingHandler を生成します。
.handle(Scripts.script("classpath:myScript.ruby"))
messageProcessorSpec - 使用する MessageProcessorSpec。BaseIntegrationFlowDefinition。public B handle(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
MessageProcessorSpec から MessageProcessor の ServiceActivatingHandler を生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。
.handle(Scripts.script("classpath:myScript.ruby"), e -> e.autoStartup(false))
messageProcessorSpec - 使用する MessageProcessorSpec。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public <H extends MessageHandler> B handle(MessageHandlerSpec<?,H> messageHandlerSpec, java.util.function.ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer)
Namespace Factory から、選択したプロトコル固有の MessageHandler 実装の ServiceActivatingHandler を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"),
e -> e.autoStartup(false))
H - MessageHandler 型。messageHandlerSpec - プロトコル固有の MessageHandler を構成する MessageHandlerSpec。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public <H extends MessageHandler> B handle(H messageHandler, java.util.function.ConsumerSE<GenericEndpointSpec<H>> endpointConfigurer)
MessageHandler 実装の ServiceActivatingHandler を生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。Java 8 ラムダ式として使用できます。
.handle(m -> logger.info(m.getPayload()), e -> e.autoStartup(false))
H - MessageHandler 型。messageHandler - 使用する MessageHandler。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B bridge()
BridgeHandler を現在の統合フロー位置に取り込みます。BaseIntegrationFlowDefinition。bridge(Consumer)public B bridge(java.util.function.ConsumerSE<GenericEndpointSpec<BridgeHandler>> endpointConfigurer)
BridgeHandler に現在の統合フロー位置を入力します。通常、Java 8 ラムダ式で使用されます。
.bridge(s -> s.poller(Pollers.fixedDelay(100))
.autoStartup(false)
.id("priorityChannelBridge"))
endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。GenericEndpointSpecpublic B delay(StringSE groupId)
DelayHandler を現在の統合フロー位置に取り込みます。groupId - MessageGroupStore の遅延メッセージの groupId BaseIntegrationFlowDefinition。public B delay(StringSE groupId, java.util.function.ConsumerSE<DelayerEndpointSpec> endpointConfigurer)
DelayHandler を現在の統合フロー位置に取り込みます。groupId - MessageGroupStore の遅延メッセージの groupId endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。DelayerEndpointSpecpublic B enrich(java.util.function.ConsumerSE<EnricherSpec> enricherConfigurer)
ContentEnricher に現在の統合フロー位置を設定します。通常、Java 8 ラムダ式で使用されます。
.enrich(e -> e.requestChannel("enrichChannel")
.requestPayload(Message::getPayload)
.shouldClonePayload(false)
.autoStartup(false)
.<Map<String, String>>headerFunction("foo", m -> m.getPayload().get("name")))
enricherConfigurer - ContentEnricher オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。EnricherSpecpublic B enrichHeaders(MapBuilder<?,StringSE,ObjectSE> headers)
MapBuilder からのヘッダー値を使用して、HeaderEnricher の MessageTransformingHandler を生成します。Namespace Factory と一緒に使用できます。
.enrichHeaders(Mail.headers()
.subjectFunction(m -> "foo")
.from("foo@bar")
.toFunction(m -> new String[] {"bar@baz"}))
headers - 使用する MapBuilder。BaseIntegrationFlowDefinition。public B enrichHeaders(MapBuilder<?,StringSE,ObjectSE> headers, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
MapBuilder からのヘッダー値を使用して、HeaderEnricher の MessageTransformingHandler を生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。Namespace Factory と一緒に使用できます。
.enrichHeaders(Mail.headers()
.subjectFunction(m -> "foo")
.from("foo@bar")
.toFunction(m -> new String[] {"bar@baz"}),
e -> e.autoStartup(false))
headers - 使用する MapBuilder。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。GenericEndpointSpecpublic B enrichHeaders(MapSE<StringSE,ObjectSE> headers)
headers - エンリッチするヘッダーのマップ。IntegrationFlowDefinition。public B enrichHeaders(MapSE<StringSE,ObjectSE> headers, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
headers - エンリッチするヘッダーのマップ。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。GenericEndpointSpecpublic B enrichHeaders(java.util.function.ConsumerSE<HeaderEnricherSpec> headerEnricherConfigurer)
ConsumerSE の結果として、HeaderEnricher の MessageTransformingHandler を生成します。通常、Java 8 ラムダ式で使用されます。
.enrichHeaders(h -> h.header(FileHeaders.FILENAME, "foo.sitest")
.header("directory", new File(tmpDir, "fileWritingFlow")))
headerEnricherConfigurer - 使用する ConsumerSE。BaseIntegrationFlowDefinition。HeaderEnricherSpecpublic B split()
DefaultMessageSplitter に現在の統合フロー位置のデフォルトオプションを入力します。BaseIntegrationFlowDefinition。public B split(java.util.function.ConsumerSE<SplitterEndpointSpec<DefaultMessageSplitter>> endpointConfigurer)
DefaultMessageSplitter に、現在の統合フロー位置に提供されたオプションを入力します。通常、Java 8 ラムダ式で使用されます。
.split(s -> s.applySequence(false).delimiters(","))
endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE および DefaultMessageSplitterBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B split(StringSE expression)
ExpressionEvaluatingSplitter に入力します。expression - スプリッター SpEL 式。ExpressionEvaluatingSplitter の場合。BaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B split(StringSE expression, java.util.function.ConsumerSE<SplitterEndpointSpec<ExpressionEvaluatingSplitter>> endpointConfigurer)
ExpressionEvaluatingSplitter に入力します。expression - スプリッター SpEL 式。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE および ExpressionEvaluatingSplitterBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B split(ObjectSE service)
service - 使用するサービス。BaseIntegrationFlowDefinition。MethodInvokingSplitterpublic B split(ObjectSE service, StringSE methodName)
service - 使用するサービス。methodName - 呼び出すメソッド。BaseIntegrationFlowDefinition。MethodInvokingSplitterpublic B split(ObjectSE service, StringSE methodName, java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
bean の提供された method を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。service - 使用するサービス。methodName - 呼び出すメソッド。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE および MethodInvokingSplitterBaseIntegrationFlowDefinition。SplitterEndpointSpec, MethodInvokingSplitterpublic B split(StringSE beanName, StringSE methodName)
beanName - 使用する Bean 名。methodName - 実行時に呼び出すメソッド。BaseIntegrationFlowDefinition。public B split(StringSE beanName, StringSE methodName, java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
bean の提供された method を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。beanName - 使用する Bean 名。methodName - 実行時に呼び出すメソッド。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE および MethodInvokingSplitterBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B split(MessageProcessorSpec<?> messageProcessorSpec)
MessageProcessorSpec から実行時に MessageProcessor を評価するために、MethodInvokingSplitter を入力します。
.split(Scripts.script("classpath:myScript.ruby"))
messageProcessorSpec - スプリッター MessageProcessorSpecBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B split(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
MessageProcessorSpec から実行時に MessageProcessor を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。
.split(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000),
, e -> e.applySequence(false))
messageProcessorSpec - スプリッター MessageProcessorSpecendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE および MethodInvokingSplitterBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic <P> B split(ClassSE<P> payloadType, java.util.function.FunctionSE<P,?> splitter)
FunctionSE を評価するために、MethodInvokingSplitter を入力します。通常、Java 8 ラムダ式で使用されます。
.split(String.class, p ->
jdbcTemplate.execute("SELECT * from FOO",
(PreparedStatement ps) ->
new ResultSetIterator<Foo>(ps.executeQuery(),
(rs, rowNum) ->
new Foo(rs.getInt(1), rs.getString(2)))))
P - ペイロード型または Message.classpayloadType - 予想されるペイロード型の ClassSE スプリッターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。splitter - スプリッター FunctionSEBaseIntegrationFlowDefinition。LambdaMessageProcessorpublic <P> B split(ClassSE<P> payloadType, java.util.function.FunctionSE<P,?> splitter, java.util.function.ConsumerSE<SplitterEndpointSpec<MethodInvokingSplitter>> endpointConfigurer)
FunctionSE を評価するために、MethodInvokingSplitter を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.split(String.class, p ->
jdbcTemplate.execute("SELECT * from FOO",
(PreparedStatement ps) ->
new ResultSetIterator<Foo>(ps.executeQuery(),
(rs, rowNum) ->
new Foo(rs.getInt(1), rs.getString(2))))
, e -> e.applySequence(false))
P - ペイロード型または Message.classpayloadType - 予想されるペイロード型の ClassSE スプリッターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。splitter - スプリッター FunctionSEendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。LambdaMessageProcessor, SplitterEndpointSpecpublic <S extends AbstractMessageSplitter> B split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec)
AbstractMessageSplitter を現在の統合フロー位置に入力します。S - AbstractMessageSplittersplitterMessageHandlerSpec - 投入する MessageHandlerSpecBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic <S extends AbstractMessageSplitter> B split(MessageHandlerSpec<?,S> splitterMessageHandlerSpec, java.util.function.ConsumerSE<SplitterEndpointSpec<S>> endpointConfigurer)
AbstractMessageSplitter を現在の統合フロー位置に入力します。S - AbstractMessageSplittersplitterMessageHandlerSpec - 投入する MessageHandlerSpecendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B split(AbstractMessageSplitter splitter)
AbstractMessageSplitter を現在の統合フロー位置に入力します。splitter - 投入する AbstractMessageSplitterBaseIntegrationFlowDefinition。SplitterEndpointSpecpublic <S extends AbstractMessageSplitter> B split(S splitter, java.util.function.ConsumerSE<SplitterEndpointSpec<S>> endpointConfigurer)
AbstractMessageSplitter を現在の統合フロー位置に入力します。S - AbstractMessageSplittersplitter - 投入する AbstractMessageSplitterendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。SplitterEndpointSpecpublic B headerFilter(StringSE... headersToRemove)
HeaderFilter を現在の StandardIntegrationFlow に提供します。headersToRemove - MessageHeaders から削除するヘッダー(またはパターン)の配列。BaseIntegrationFlowDefinition。public B headerFilter(StringSE headersToRemove, boolean patternMatch)
HeaderFilter を現在の StandardIntegrationFlow に提供します。headersToRemove - MessageHeaders から削除するコンマ区切りのヘッダー(またはパターン)。patternMatch - boolean フラグ。headersToRemove をパターンまたは直接ヘッダー名として解釈する必要があるかどうかを示します。BaseIntegrationFlowDefinition。public B headerFilter(HeaderFilter headerFilter, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
HeaderFilter に提供された MessageTransformingHandler を取り込みます。headerFilter - 使用する HeaderFilter。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。GenericEndpointSpecpublic B claimCheckIn(MessageStore messageStore)
messageStore - 使用する MessageStore。BaseIntegrationFlowDefinition。public B claimCheckIn(MessageStore messageStore, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
ClaimCheckInTransformer の MessageTransformingHandler に、提供されている MessageStore を入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。messageStore - 使用する MessageStore。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。GenericEndpointSpecpublic B claimCheckOut(MessageStore messageStore)
ClaimCheckOutTransformer の MessageTransformingHandler に、提供されている MessageStore を入力します。ClaimCheckOutTransformer の removeMessage オプションは false に対するものです。messageStore - 使用する MessageStore。BaseIntegrationFlowDefinition。public B claimCheckOut(MessageStore messageStore, boolean removeMessage)
ClaimCheckOutTransformer の MessageTransformingHandler に、提供された MessageStore および removeMessage フラグを取り込みます。messageStore - 使用する MessageStore。removeMessage - removeMessage ブールフラグ。BaseIntegrationFlowDefinition。ClaimCheckOutTransformer.setRemoveMessage(boolean)public B claimCheckOut(MessageStore messageStore, boolean removeMessage, java.util.function.ConsumerSE<GenericEndpointSpec<MessageTransformingHandler>> endpointConfigurer)
MessageStore および removeMessage フラグを使用して、ClaimCheckOutTransformer の MessageTransformingHandler を生成します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。messageStore - 使用する MessageStore。removeMessage - removeMessage ブールフラグ。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。GenericEndpointSpec, ClaimCheckOutTransformer.setRemoveMessage(boolean)public B resequence()
ResequencingMessageHandler にデフォルトオプションを入力します。BaseIntegrationFlowDefinition。public B resequence(java.util.function.ConsumerSE<ResequencerSpec> resequencer)
ResequencerSpec から提供されるオプションを ResequencingMessageHandler に入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.resequence(r -> r.releasePartialSequences(true)
.correlationExpression("'foo'")
.phase(100))
resequencer - ResequencingMessageHandler オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。ResequencerSpecpublic B aggregate()
AggregatingMessageHandler にデフォルトオプションを入力します。BaseIntegrationFlowDefinition。public B aggregate(java.util.function.ConsumerSE<AggregatorSpec> aggregator)
AggregatorSpec から提供されるオプションを AggregatingMessageHandler に入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.aggregate(a -> a.correlationExpression("1")
.releaseStrategy(g -> g.size() == 25)
.phase(100))
aggregator - AggregatingMessageHandler オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。AggregatorSpecpublic B route(StringSE beanName, StringSE method)
MethodInvokingRouter とそのメソッドにデフォルトのオプションを入力します。beanName - 使用する Bean。method - 実行時に呼び出すメソッド。BaseIntegrationFlowDefinition。public B route(StringSE beanName, StringSE method, java.util.function.ConsumerSE<RouterSpec<ObjectSE,MethodInvokingRouter>> routerConfigurer)
MethodInvokingRouter と、そのメソッドに RouterSpec の提供されたオプションを入力します。beanName - 使用する Bean。method - 実行時に呼び出すメソッド。routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B route(ObjectSE service)
MethodInvokingRouter にデフォルトのオプションを入力します。service - 使用する Bean。BaseIntegrationFlowDefinition。MethodInvokingRouterpublic B route(ObjectSE service, StringSE methodName)
MethodInvokingRouter にデフォルトのオプションを入力します。service - 使用するサービス。methodName - 呼び出すメソッド。BaseIntegrationFlowDefinition。MethodInvokingRouterpublic B route(ObjectSE service, StringSE methodName, java.util.function.ConsumerSE<RouterSpec<ObjectSE,MethodInvokingRouter>> routerConfigurer)
MethodInvokingRouter に、RouterSpec から提供されたオプションを入力します。service - 使用するサービス。methodName - 呼び出すメソッド。routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。MethodInvokingRouterpublic B route(StringSE expression)
ExpressionEvaluatingRouter にデフォルトオプションを入力します。expression - 使用する式。BaseIntegrationFlowDefinition。public <T> B route(StringSE expression, java.util.function.ConsumerSE<RouterSpec<T,ExpressionEvaluatingRouter>> routerConfigurer)
ExpressionEvaluatingRouter に、RouterSpec から提供されたオプションを入力します。T - ターゲットの結果型。expression - 使用する式。routerConfigurer - ExpressionEvaluatingRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public <S,T> B route(ClassSE<S> payloadType, java.util.function.FunctionSE<S,T> router)
FunctionSE およびペイロード型の MethodInvokingRouter にデフォルトオプションを入力します。通常、Java 8 ラムダ式で使用されます。
.route(Integer.class, p -> p % 2 == 0)
S - ソースのペイロード型または Message.classT - ターゲットの結果型。payloadType - 予想されるペイロード型の ClassSE スプリッターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。router - 使用する FunctionSE。BaseIntegrationFlowDefinition。LambdaMessageProcessorpublic <P,T> B route(ClassSE<P> payloadType, java.util.function.FunctionSE<P,T> router, java.util.function.ConsumerSE<RouterSpec<T,MethodInvokingRouter>> routerConfigurer)
FunctionSE の MethodInvokingRouter を入力し、RouterSpec のペイロード型とオプションを入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。通常、Java 8 ラムダ式で使用されます。
.route(Integer.class, p -> p % 2 == 0,
m -> m.channelMapping("true", "evenChannel")
.subFlowMapping("false", f ->
f.<Integer>handle((p, h) -> p * 3))
.applySequence(false))
P - ソースのペイロード型または Message.classT - ターゲットの結果型。payloadType - 予想されるペイロード型の ClassSE スプリッターでメッセージ全体にアクセスする場合は、Message.class にすることもできます。必要に応じて、この型への変換が試行されます。router - 使用する FunctionSE。routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。LambdaMessageProcessorpublic B route(MessageProcessorSpec<?> messageProcessorSpec)
MessageProcessorSpec から MessageProcessor の MethodInvokingRouter を生成します。
.route(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000))
messageProcessorSpec - 使用する MessageProcessorSpec。BaseIntegrationFlowDefinition。public B route(MessageProcessorSpec<?> messageProcessorSpec, java.util.function.ConsumerSE<RouterSpec<ObjectSE,MethodInvokingRouter>> routerConfigurer)
MessageProcessorSpec から MessageProcessor の MethodInvokingRouter を生成します。
.route(Scripts.script(myScriptResource).lang("groovy").refreshCheckDelay(1000),
m -> m.channelMapping("true", "evenChannel")
.subFlowMapping("false", f ->
f.<Integer>handle((p, h) -> p * 3)))
messageProcessorSpec - 使用する MessageProcessorSpec。routerConfigurer - MethodInvokingRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。protected <R extends AbstractMessageRouter,S extends AbstractRouterSpec<? super S,R>> B route(S routerSpec, java.util.function.ConsumerSE<S> routerConfigurer)
public B routeToRecipients(java.util.function.ConsumerSE<RecipientListRouterSpec> routerConfigurer)
RecipientListRouterSpec のオプションを RecipientListRouter に入力します。通常、Java 8 ラムダ式で使用されます。
.routeToRecipients(r -> r
.recipient("bar-channel", m ->
m.getHeaders().containsKey("recipient") && (boolean) m.getHeaders().get("recipient"))
.recipientFlow("'foo' == payload or 'bar' == payload or 'baz' == payload",
f -> f.transform(String.class, p -> p.toUpperCase())
.channel(c -> c.queue("recipientListSubFlow1Result"))))
routerConfigurer - RecipientListRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B routeByException(java.util.function.ConsumerSE<RouterSpec<ClassSE<? extends ThrowableSE>,ErrorMessageExceptionTypeRouter>> routerConfigurer)
RouterSpec のオプションを ErrorMessageExceptionTypeRouter に入力します。通常、Java 8 ラムダ式で使用されます。
.routeByException(r -> r
.channelMapping(IllegalArgumentException.class, "illegalArgumentChannel")
.subFlowMapping(MessageHandlingException.class, sf ->
sf.handle(...))
)
routerConfigurer - ErrorMessageExceptionTypeRouter オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。ErrorMessageExceptionTypeRouterpublic B route(AbstractMessageRouter router)
AbstractMessageRouter 実装を現在の統合フロー位置に取り込みます。router - 投入する AbstractMessageRouterBaseIntegrationFlowDefinition。public <R extends AbstractMessageRouter> B route(R router, java.util.function.ConsumerSE<GenericEndpointSpec<R>> endpointConfigurer)
AbstractMessageRouter 実装を現在の統合フロー位置に入力します。さらに、GenericEndpointSpec を使用して統合エンドポイントのオプションを受け入れます。R - AbstractMessageRouter 型。router - 投入する AbstractMessageRouterendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B gateway(StringSE requestChannel)
requestChannel の「人工的な」GatewayMessageHandler を設定して、デフォルトのオプションでリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。requestChannel - MessageChannel Bean 名。BaseIntegrationFlowDefinition。public B gateway(StringSE requestChannel, java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer)
requestChannel の「人工」GatewayMessageHandler にデータを入力して、GatewayEndpointSpec のオプションを含むリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。requestChannel - MessageChannel Bean 名。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B gateway(MessageChannel requestChannel)
requestChannel の「人工的な」GatewayMessageHandler を設定して、デフォルトのオプションでリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。requestChannel - 使用する MessageChannel。BaseIntegrationFlowDefinition。public B gateway(MessageChannel requestChannel, java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer)
requestChannel の「人工」GatewayMessageHandler にデータを入力して、GatewayEndpointSpec のオプションを含むリクエストを送信します。バックグラウンドで RequestReplyExchanger プロキシを使用します。requestChannel - 使用する MessageChannel。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B gateway(IntegrationFlow flow)
subflow の「人工的な」GatewayMessageHandler に入力します。通常、Java 8 ラムダ式で使用されます。
.gateway(f -> f.transform("From Gateway SubFlow: "::concat))
flow - IntegrationFlow がリクエストメッセージを送信し、応答を待ちます。BaseIntegrationFlowDefinition。public B gateway(IntegrationFlow flow, java.util.function.ConsumerSE<GatewayEndpointSpec> endpointConfigurer)
subflow の「人工」GatewayMessageHandler に、GatewayEndpointSpec のオプションを入力します。通常、Java 8 ラムダ式で使用されます。
.gateway(f -> f.transform("From Gateway SubFlow: "::concat), e -> e.replyTimeout(100L))
flow - IntegrationFlow がリクエストメッセージを送信し、応答を待ちます。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B log()
currentMessageChannel の WireTap に、INFO ロギングレベルの LoggingHandler サブスクライバーと org.springframework.integration.handler.LoggingHandler をデフォルトのロギングカテゴリとして入力します。 完全なリクエスト Message がログに記録されます。
この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(LoggingHandler.Level level)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベルの LoggingHandler サブスクライバーと、デフォルトのロギングカテゴリとして org.springframework.integration.handler.LoggingHandler を設定します。 完全なリクエスト Message がログに記録されます。
この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
level - LoggingHandler.LevelBaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(StringSE category)
currentMessageChannel の WireTap に、指定されたロギングカテゴリと INFO ロギングレベルの LoggingHandler サブスクライバーを設定します。 完全なリクエスト Message がログに記録されます。
この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
category - 使用するロギングカテゴリ。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(LoggingHandler.Level level, StringSE category)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベルとロギングカテゴリの LoggingHandler サブスクライバーを設定します。 完全なリクエスト Message がログに記録されます。
この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
level - LoggingHandler.Levelcategory - 使用するロギングカテゴリ。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(LoggingHandler.Level level, StringSE category, StringSE logExpression)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベル、ロギングカテゴリ、ログメッセージの SpEL 式の LoggingHandler サブスクライバーを設定します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
level - LoggingHandler.Levelcategory - ロギングカテゴリ。logExpression - リクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public <P> B log(java.util.function.FunctionSE<Message<P>,ObjectSE> function)
currentMessageChannel の WireTap に、INFO ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、ログメッセージの FunctionSE を入力します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
P - リクエスト Message に対して、予想されるペイロード型。function - 実行時にロガーメッセージを評価する関数 BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(Expression logExpression)
currentMessageChannel の WireTap に、INFO ロギングレベルの LoggingHandler サブスクライバー、デフォルトのロギングカテゴリとしての org.springframework.integration.handler.LoggingHandler、およびリクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式を入力します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(LoggingHandler.Level level, Expression logExpression)
LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、リクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式を使用して、currentMessageChannel の WireTap を生成します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
level - LoggingHandler.LevellogExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(StringSE category, Expression logExpression)
currentMessageChannel の WireTap に、INFO の LoggingHandler サブスクライバーを入力します。LoggingHandler.Level ロギングレベル、提供されたロギングカテゴリ、SpEL 式を使用して、実行時にリクエスト Message に対してロガーメッセージを評価します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
category - ロギングカテゴリ。logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public <P> B log(LoggingHandler.Level level, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
currentMessageChannel の WireTap に、提供された LoggingHandler.Level ロギングレベルの LoggingHandler サブスクライバー、デフォルトのロギングカテゴリとしての org.springframework.integration.handler.LoggingHandler、およびログメッセージの FunctionSE を入力します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
P - リクエスト Message に対して、予想されるペイロード型。level - LoggingHandler.Levelfunction - 実行時にロガーメッセージを評価する関数 BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public <P> B log(StringSE category, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、提供されたログカテゴリ、ログメッセージの FunctionSE を入力します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
P - リクエスト Message に対して、予想されるペイロード型。category - ロギングカテゴリ。function - 実行時にロガーメッセージを評価する関数 BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public <P> B log(LoggingHandler.Level level, StringSE category, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
LoggingHandler.Level ログレベル、ログカテゴリ、ログメッセージの FunctionSE の LoggingHandler サブスクライバーを currentMessageChannel の WireTap に入力します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
P - リクエスト Message に対して、予想されるペイロード型。level - LoggingHandler.Levelcategory - ロギングカテゴリ。function - 実行時にロガーメッセージを評価する関数 BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public B log(LoggingHandler.Level level, StringSE category, Expression logExpression)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベル、ロギングカテゴリ、ログメッセージの SpEL 式の LoggingHandler サブスクライバーを設定します。 この演算子がフローの最後で使用される場合、続行するための応答がない一方向ハンドラーとして扱われます。logAndReply() は、リクエスト / 応答構成に使用する必要があります。
level - LoggingHandler.Levelcategory - ロギングカテゴリ。logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。BaseIntegrationFlowDefinition。wireTap(WireTapSpec)public IntegrationFlow logAndReply()
currentMessageChannel の WireTap に、INFO ロギングレベルの LoggingHandler サブスクライバーと org.springframework.integration.handler.LoggingHandler をデフォルトのロギングカテゴリとして入力します。 完全なリクエスト Message がログに記録されます。
このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(LoggingHandler.Level level)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベルの LoggingHandler サブスクライバーと、デフォルトのロギングカテゴリとして org.springframework.integration.handler.LoggingHandler を設定します。 完全なリクエスト Message がログに記録されます。
このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
level - LoggingHandler.LevelIntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(StringSE category)
currentMessageChannel の WireTap に、指定されたロギングカテゴリと INFO ロギングレベルの LoggingHandler サブスクライバーを設定します。 完全なリクエスト Message がログに記録されます。
このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
category - 使用するロギングカテゴリ。IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(LoggingHandler.Level level, StringSE category)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベルとロギングカテゴリの LoggingHandler サブスクライバーを設定します。 完全なリクエスト Message がログに記録されます。
このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
level - LoggingHandler.Levelcategory - 使用するロギングカテゴリ。IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(LoggingHandler.Level level, StringSE category, StringSE logExpression)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベル、ロギングカテゴリ、ログメッセージの SpEL 式の LoggingHandler サブスクライバーを設定します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
level - LoggingHandler.Levelcategory - ロギングカテゴリ。logExpression - リクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式。IntegrationFlow インスタンス log(), bridge()public <P> IntegrationFlow logAndReply(java.util.function.FunctionSE<Message<P>,ObjectSE> function)
currentMessageChannel の WireTap に、INFO ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、ログメッセージの FunctionSE を入力します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
P - リクエスト Message に対して、予想されるペイロード型。function - 実行時にロガーメッセージを評価する関数 IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(Expression logExpression)
currentMessageChannel の WireTap に、INFO ロギングレベルの LoggingHandler サブスクライバー、デフォルトのロギングカテゴリとしての org.springframework.integration.handler.LoggingHandler、およびリクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式を入力します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(LoggingHandler.Level level, Expression logExpression)
LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、デフォルトのログカテゴリとしての org.springframework.integration.handler.LoggingHandler、リクエスト Message に対して実行時にロガーメッセージを評価する SpEL 式を使用して、currentMessageChannel の WireTap を生成します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
level - LoggingHandler.LevellogExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(StringSE category, Expression logExpression)
currentMessageChannel の WireTap に、INFO の LoggingHandler サブスクライバーを入力します。LoggingHandler.Level ロギングレベル、提供されたロギングカテゴリ、SpEL 式を使用して、実行時にリクエスト Message に対してロガーメッセージを評価します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
category - ロギングカテゴリ。logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。IntegrationFlow インスタンス log(), bridge()public <P> IntegrationFlow logAndReply(LoggingHandler.Level level, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
currentMessageChannel の WireTap に、提供された LoggingHandler.Level ロギングレベルの LoggingHandler サブスクライバー、デフォルトのロギングカテゴリとしての org.springframework.integration.handler.LoggingHandler、およびログメッセージの FunctionSE を入力します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
P - リクエスト Message に対して、予想されるペイロード型。level - LoggingHandler.Levelfunction - 実行時にロガーメッセージを評価する関数 IntegrationFlow インスタンス log(), bridge()public <P> IntegrationFlow logAndReply(StringSE category, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
currentMessageChannel の WireTap に、提供された LoggingHandler.Level ログレベルの LoggingHandler サブスクライバー、提供されたログカテゴリ、ログメッセージの FunctionSE を入力します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
P - リクエスト Message に対して、予想されるペイロード型。category - ロギングカテゴリ。function - 実行時にロガーメッセージを評価する関数 IntegrationFlow インスタンス log(), bridge()public <P> IntegrationFlow logAndReply(LoggingHandler.Level level, StringSE category, java.util.function.FunctionSE<Message<P>,ObjectSE> function)
LoggingHandler.Level ログレベル、ログカテゴリ、ログメッセージの FunctionSE の LoggingHandler サブスクライバーを currentMessageChannel の WireTap に入力します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
P - リクエスト Message に対して、予想されるペイロード型。level - LoggingHandler.Levelcategory - ロギングカテゴリ。function - 実行時にロガーメッセージを評価する関数 IntegrationFlow インスタンス log(), bridge()public IntegrationFlow logAndReply(LoggingHandler.Level level, StringSE category, Expression logExpression)
currentMessageChannel の WireTap に、指定された LoggingHandler.Level ロギングレベル、ロギングカテゴリ、ログメッセージの SpEL 式の LoggingHandler サブスクライバーを設定します。 このオペレーターの後に bridge() が追加され、replyChannel ヘッダーが存在する場合にフローが応答を生成します。
この演算子は、フローの最後でのみ使用できます。
level - LoggingHandler.Levelcategory - ロギングカテゴリ。logExpression - Expression は、リクエスト Message に対して実行時にロガーメッセージを評価します。IntegrationFlow インスタンス log(), bridge()public B scatterGather(MessageChannel scatterChannel)
MessageChannel および収集関数用のデフォルトの AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。scatterChannel - スキャッティングリクエスト用の MessageChannelBaseIntegrationFlowDefinition。public B scatterGather(MessageChannel scatterChannel, java.util.function.ConsumerSE<AggregatorSpec> gatherer)
scatterChannel - スキャッティングリクエスト用の MessageChannelgatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。null にすることができます。BaseIntegrationFlowDefinition。public B scatterGather(MessageChannel scatterChannel, java.util.function.ConsumerSE<AggregatorSpec> gatherer, java.util.function.ConsumerSE<ScatterGatherSpec> scatterGather)
scatterChannel - スキャッティングリクエスト用の MessageChannelgatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。null にすることができます。scatterGather - ScatterGatherHandler およびそのエンドポイントを構成するための ScatterGatherSpec の ConsumerSE。null にすることができます。BaseIntegrationFlowDefinition。public B scatterGather(java.util.function.ConsumerSE<RecipientListRouterSpec> scatterer)
RecipientListRouterSpec および収集関数用のデフォルトの AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。scatterer - 散乱体を構成するための RecipientListRouterSpec の ConsumerSE。BaseIntegrationFlowDefinition。public B scatterGather(java.util.function.ConsumerSE<RecipientListRouterSpec> scatterer, @Nullable java.util.function.ConsumerSE<AggregatorSpec> gatherer)
RecipientListRouterSpec および収集関数用の AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。scatterer - 散乱体を構成するための RecipientListRouterSpec の ConsumerSE。null にすることができます。gatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。null にすることができます。BaseIntegrationFlowDefinition。public B scatterGather(java.util.function.ConsumerSE<RecipientListRouterSpec> scatterer, @Nullable java.util.function.ConsumerSE<AggregatorSpec> gatherer, @Nullable java.util.function.ConsumerSE<ScatterGatherSpec> scatterGather)
RecipientListRouterSpec および収集関数用の AggregatorSpec に基づいて、ScatterGatherHandler を現在の積分フロー位置に入力します。scatterer - 散乱体を構成するための RecipientListRouterSpec の ConsumerSE。gatherer - AggregatorSpec の ConsumerSE で Gatherer を構成します。scatterGather - ScatterGatherHandler およびそのエンドポイントを構成するための ScatterGatherSpec の ConsumerSE。null にすることができます。BaseIntegrationFlowDefinition。public B barrier(long timeout)
BarrierMessageHandler インスタンスを作成します。timeout - ミリ秒単位のタイムアウト。BaseIntegrationFlowDefinition。public B barrier(long timeout, java.util.function.ConsumerSE<BarrierSpec> barrierConfigurer)
BarrierSpec から提供されたタイムアウトとオプション、および GenericEndpointSpec からエンドポイントオプションの BarrierMessageHandler インスタンスを作成します。timeout - ミリ秒単位のタイムアウト。barrierConfigurer - BarrierMessageHandler オプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B trigger(StringSE triggerActionId)
MessageTriggerAction を実行するには、ServiceActivatingHandler インスタンスにデータを入力します。triggerActionId - MessageTriggerAction Bean ID。BaseIntegrationFlowDefinition。public B trigger(StringSE triggerActionId, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
GenericEndpointSpec から MessageTriggerAction およびエンドポイントオプションを実行するために、ServiceActivatingHandler インスタンスを入力します。triggerActionId - MessageTriggerAction Bean ID。endpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B trigger(MessageTriggerAction triggerAction)
MessageTriggerAction を実行するには、ServiceActivatingHandler インスタンスにデータを入力します。triggerAction - MessageTriggerActionBaseIntegrationFlowDefinition。public B trigger(MessageTriggerAction triggerAction, java.util.function.ConsumerSE<GenericEndpointSpec<ServiceActivatingHandler>> endpointConfigurer)
GenericEndpointSpec から MessageTriggerAction およびエンドポイントオプションを実行するために、ServiceActivatingHandler インスタンスを入力します。triggerAction - MessageTriggerActionendpointConfigurer - 統合エンドポイントオプションを提供する ConsumerSE。BaseIntegrationFlowDefinition。public B intercept(ChannelInterceptor... interceptorArray)
ChannelInterceptor 実装を現在の currentMessageChannel に指定された順序で追加します。interceptorArray - 1 つ以上の ChannelInterceptor。BaseIntegrationFlowDefinition。IllegalArgumentExceptionSE - 1 つ以上の null 引数が提供されている場合 public <I,O> B fluxTransform(java.util.function.FunctionSE<? super reactor.core.publisher.Flux<Message<I>>,? extends org.reactivestreams.Publisher<O>> fluxFunction)
FluxMessageChannel にデータを入力して上流データのリアクティブ処理を開始し、それを Flux にラップし、提供された FunctionSE を Flux.transform(Function) を介して適用し、結果を下流のフローでサブスクライブされている 1 つ以上の FluxMessageChannel に送信します。I - 入力ペイロードの型。O - 出力型。fluxFunction - FunctionSE を使用してデータをリアクティブに処理します。BaseIntegrationFlowDefinition。public IntegrationFlow nullChannel()
IntegrationFlow インスタンス。protected <T> org.reactivestreams.Publisher<Message<T>> toReactivePublisher()
Publisher Bean として表します。T - 予想される payload 型 Publisherprotected <S extends ConsumerEndpointSpec<? super S,? extends MessageHandler>> B register(S endpointSpec, java.util.function.ConsumerSE<S> endpointConfigurer)
protected B registerOutputChannelIfCan(MessageChannel outputChannel)
protected boolean isOutputChannelRequired()
protected final B _this()
protected StandardIntegrationFlow get()
protected void checkReuse(MessageProducer replyHandler)