@@ -2401,292 +2401,6 @@ public B log(LoggingHandler.Level level, @Nullable String category, @Nullable Ex
24012401 return wireTap (loggerChannel );
24022402 }
24032403
2404- /**
2405- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2406- * with the {@link LoggingHandler} subscriber for the {@code INFO}
2407- * logging level and {@code org.springframework.integration.handler.LoggingHandler}
2408- * as a default logging category.
2409- * <p> The full request {@link Message} will be logged.
2410- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2411- * if the {@code replyChannel} header is present.
2412- * <p> This operator can be used only in the end of flow.
2413- * @return an {@link IntegrationFlow} instance based on this builder.
2414- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2415- * @see #log()
2416- * @see #bridge()
2417- */
2418- @ Deprecated
2419- public IntegrationFlow logAndReply () {
2420- return logAndReply (LoggingHandler .Level .INFO );
2421- }
2422-
2423- /**
2424- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2425- * with the {@link LoggingHandler} subscriber for provided {@link LoggingHandler.Level}
2426- * logging level and {@code org.springframework.integration.handler.LoggingHandler}
2427- * as a default logging category.
2428- * <p> The full request {@link Message} will be logged.
2429- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2430- * if the {@code replyChannel} header is present.
2431- * <p> This operator can be used only in the end of flow.
2432- * @param level the {@link LoggingHandler.Level}.
2433- * @return an {@link IntegrationFlow} instance based on this builder.
2434- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2435- * @see #log()
2436- * @see #bridge()
2437- */
2438- @ Deprecated
2439- public IntegrationFlow logAndReply (LoggingHandler .Level level ) {
2440- return logAndReply (level , (String ) null );
2441- }
2442-
2443- /**
2444- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2445- * with the {@link LoggingHandler} subscriber for the provided logging category
2446- * and {@code INFO} logging level.
2447- * <p> The full request {@link Message} will be logged.
2448- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2449- * if the {@code replyChannel} header is present.
2450- * <p> This operator can be used only in the end of flow.
2451- * @param category the logging category to use.
2452- * @return an {@link IntegrationFlow} instance based on this builder.
2453- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2454- * @see #log()
2455- * @see #bridge()
2456- */
2457- @ Deprecated
2458- public IntegrationFlow logAndReply (String category ) {
2459- return logAndReply (LoggingHandler .Level .INFO , category );
2460- }
2461-
2462- /**
2463- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2464- * with the {@link LoggingHandler} subscriber for the provided
2465- * {@link LoggingHandler.Level} logging level and logging category.
2466- * <p> The full request {@link Message} will be logged.
2467- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2468- * if the {@code replyChannel} header is present.
2469- * <p> This operator can be used only in the end of flow.
2470- * @param level the {@link LoggingHandler.Level}.
2471- * @param category the logging category to use.
2472- * @return an {@link IntegrationFlow} instance based on this builder.
2473- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2474- * @see #log()
2475- * @see #bridge()
2476- */
2477- @ Deprecated
2478- public IntegrationFlow logAndReply (LoggingHandler .Level level , @ Nullable String category ) {
2479- return logAndReply (level , category , (Expression ) null );
2480- }
2481-
2482- /**
2483- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2484- * with the {@link LoggingHandler} subscriber for the provided
2485- * {@link LoggingHandler.Level} logging level, logging category
2486- * and SpEL expression for the log message.
2487- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2488- * if the {@code replyChannel} header is present.
2489- * <p> This operator can be used only in the end of flow.
2490- * @param level the {@link LoggingHandler.Level}.
2491- * @param category the logging category.
2492- * @param logExpression the SpEL expression to evaluate logger message at runtime
2493- * against the request {@link Message}.
2494- * @return an {@link IntegrationFlow} instance based on this builder.
2495- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2496- * @see #log()
2497- * @see #bridge()
2498- */
2499- @ Deprecated
2500- public IntegrationFlow logAndReply (LoggingHandler .Level level , String category , String logExpression ) {
2501- Assert .hasText (logExpression , "'logExpression' must not be empty" );
2502- return logAndReply (level , category , PARSER .parseExpression (logExpression ));
2503- }
2504-
2505- /**
2506- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2507- * with the {@link LoggingHandler} subscriber for the {@code INFO} logging level,
2508- * the {@code org.springframework.integration.handler.LoggingHandler}
2509- * as a default logging category and {@link Function} for the log message.
2510- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2511- * if the {@code replyChannel} header is present.
2512- * <p> This operator can be used only in the end of flow.
2513- * @param function the function to evaluate logger message at runtime
2514- * @param <P> the expected payload type.
2515- * against the request {@link Message}.
2516- * @return an {@link IntegrationFlow} instance based on this builder.
2517- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2518- * @see #log()
2519- * @see #bridge()
2520- */
2521- @ Deprecated
2522- public <P > IntegrationFlow logAndReply (Function <Message <P >, Object > function ) {
2523- Assert .notNull (function , FUNCTION_MUST_NOT_BE_NULL );
2524- return logAndReply (new FunctionExpression <>(function ));
2525- }
2526-
2527- /**
2528- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2529- * with the {@link LoggingHandler} subscriber for the {@code INFO} logging level,
2530- * the {@code org.springframework.integration.handler.LoggingHandler}
2531- * as a default logging category and SpEL expression to evaluate
2532- * logger message at runtime against the request {@link Message}.
2533- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2534- * if the {@code replyChannel} header is present.
2535- * <p> This operator can be used only in the end of flow.
2536- * @param logExpression the {@link Expression} to evaluate logger message at runtime
2537- * against the request {@link Message}.
2538- * @return an {@link IntegrationFlow} instance based on this builder.
2539- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2540- * @see #log()
2541- * @see #bridge()
2542- */
2543- @ Deprecated
2544- public IntegrationFlow logAndReply (Expression logExpression ) {
2545- return logAndReply (LoggingHandler .Level .INFO , logExpression );
2546- }
2547-
2548- /**
2549- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2550- * with the {@link LoggingHandler} subscriber for the provided
2551- * {@link LoggingHandler.Level} logging level,
2552- * the {@code org.springframework.integration.handler.LoggingHandler}
2553- * as a default logging category and SpEL expression to evaluate
2554- * logger message at runtime against the request {@link Message}.
2555- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2556- * if the {@code replyChannel} header is present.
2557- * <p> This operator can be used only in the end of flow.
2558- * @param level the {@link LoggingHandler.Level}.
2559- * @param logExpression the {@link Expression} to evaluate logger message at runtime
2560- * against the request {@link Message}.
2561- * @return an {@link IntegrationFlow} instance based on this builder.
2562- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2563- * @see #log()
2564- * @see #bridge()
2565- */
2566- @ Deprecated
2567- public IntegrationFlow logAndReply (LoggingHandler .Level level , Expression logExpression ) {
2568- return logAndReply (level , null , logExpression );
2569- }
2570-
2571- /**
2572- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2573- * with the {@link LoggingHandler} subscriber for the {@code INFO}
2574- * {@link LoggingHandler.Level} logging level,
2575- * the provided logging category and SpEL expression to evaluate
2576- * logger message at runtime against the request {@link Message}.
2577- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2578- * if the {@code replyChannel} header is present.
2579- * <p> This operator can be used only in the end of flow.
2580- * @param category the logging category.
2581- * @param logExpression the {@link Expression} to evaluate logger message at runtime
2582- * against the request {@link Message}.
2583- * @return an {@link IntegrationFlow} instance based on this builder.
2584- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2585- * @see #log()
2586- * @see #bridge()
2587- */
2588- @ Deprecated
2589- public IntegrationFlow logAndReply (String category , Expression logExpression ) {
2590- return logAndReply (LoggingHandler .Level .INFO , category , logExpression );
2591- }
2592-
2593- /**
2594- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2595- * with the {@link LoggingHandler} subscriber for the provided
2596- * {@link LoggingHandler.Level} logging level,
2597- * the {@code org.springframework.integration.handler.LoggingHandler}
2598- * as a default logging category and {@link Function} for the log message.
2599- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2600- * if the {@code replyChannel} header is present.
2601- * <p> This operator can be used only in the end of flow.
2602- * @param level the {@link LoggingHandler.Level}.
2603- * @param function the function to evaluate logger message at runtime
2604- * @param <P> the expected payload type.
2605- * against the request {@link Message}.
2606- * @return an {@link IntegrationFlow} instance based on this builder.
2607- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2608- * @see #log()
2609- * @see #bridge()
2610- */
2611- @ Deprecated
2612- public <P > IntegrationFlow logAndReply (LoggingHandler .Level level , Function <Message <P >, Object > function ) {
2613- return logAndReply (level , null , function );
2614- }
2615-
2616- /**
2617- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2618- * with the {@link LoggingHandler} subscriber for the provided
2619- * {@link LoggingHandler.Level} logging level,
2620- * the provided logging category and {@link Function} for the log message.
2621- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2622- * if the {@code replyChannel} header is present.
2623- * <p> This operator can be used only in the end of flow.
2624- * @param category the logging category.
2625- * @param function the function to evaluate logger message at runtime
2626- * @param <P> the expected payload type.
2627- * against the request {@link Message}.
2628- * @return an {@link IntegrationFlow} instance based on this builder.
2629- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2630- * @see #log()
2631- * @see #bridge()
2632- */
2633- @ Deprecated
2634- public <P > IntegrationFlow logAndReply (String category , Function <Message <P >, Object > function ) {
2635- return logAndReply (LoggingHandler .Level .INFO , category , function );
2636- }
2637-
2638- /**
2639- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2640- * with the {@link LoggingHandler} subscriber for the provided
2641- * {@link LoggingHandler.Level} logging level, logging category
2642- * and {@link Function} for the log message.
2643- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2644- * if the {@code replyChannel} header is present.
2645- * <p> This operator can be used only in the end of flow.
2646- * @param level the {@link LoggingHandler.Level}.
2647- * @param category the logging category.
2648- * @param function the function to evaluate logger message at runtime
2649- * @param <P> the expected payload type.
2650- * against the request {@link Message}.
2651- * @return an {@link IntegrationFlow} instance based on this builder.
2652- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2653- * @see #log()
2654- * @see #bridge()
2655- */
2656- @ Deprecated
2657- public <P > IntegrationFlow logAndReply (LoggingHandler .Level level , @ Nullable String category ,
2658- Function <Message <P >, Object > function ) {
2659-
2660- Assert .notNull (function , FUNCTION_MUST_NOT_BE_NULL );
2661- return logAndReply (level , category , new FunctionExpression <>(function ));
2662- }
2663-
2664- /**
2665- * Populate a {@link WireTap} for the {@link #currentMessageChannel}
2666- * with the {@link LoggingHandler} subscriber for the provided
2667- * {@link LoggingHandler.Level} logging level, logging category
2668- * and SpEL expression for the log message.
2669- * <p> A {@link #bridge()} is added after this operator to make the flow reply-producing
2670- * if the {@code replyChannel} header is present.
2671- * <p> This operator can be used only in the end of flow.
2672- * @param level the {@link LoggingHandler.Level}.
2673- * @param category the logging category.
2674- * @param logExpression the {@link Expression} to evaluate logger message at runtime
2675- * against the request {@link Message}.
2676- * @return an {@link IntegrationFlow} instance based on this builder.
2677- * @deprecated since 6.0 in favor of {@link #log} in the end of flow.
2678- * @see #log()
2679- * @see #bridge()
2680- */
2681- @ Deprecated
2682- public IntegrationFlow logAndReply (LoggingHandler .Level level , @ Nullable String category ,
2683- @ Nullable Expression logExpression ) {
2684-
2685- return log (level , category , logExpression )
2686- .bridge ()
2687- .get ();
2688- }
2689-
26902404 /**
26912405 * Populate a {@link ScatterGatherHandler} to the current integration flow position
26922406 * based on the provided {@link MessageChannel} for scattering function
0 commit comments