@@ -222,40 +222,40 @@ public static <T> Consumer<FuncEmitTaskBuilder> event(
222222 *
223223 * @param type CloudEvent type
224224 * @param function function that maps workflow input to {@link CloudEventData}
225- * @param clazz expected input class for conversion
225+ * @param inputClass expected input class for conversion
226226 * @param <T> input type
227227 * @return a consumer to configure {@link FuncEmitTaskBuilder}
228228 */
229229 public static <T > Consumer <FuncEmitTaskBuilder > event (
230- String type , Function <T , CloudEventData > function , Class <T > clazz ) {
231- return OPS .event (type , function , clazz );
230+ String type , Function <T , CloudEventData > function , Class <T > inputClass ) {
231+ return OPS .event (type , function , inputClass );
232232 }
233233
234234 /**
235235 * Emit a JSON CloudEvent for a POJO input type. Sets {@code contentType=application/json} and
236236 * serializes the input to bytes using the configured JSON mapper.
237237 *
238238 * @param type CloudEvent type
239- * @param clazz input POJO class (used for typing and conversion)
239+ * @param inputClass input POJO class (used for typing and conversion)
240240 * @param <T> input type
241241 * @return a consumer to configure {@link FuncEmitTaskBuilder}
242242 */
243- public static <T > Consumer <FuncEmitTaskBuilder > eventJson (String type , Class <T > clazz ) {
244- return b -> new FuncEmitSpec ().type (type ).jsonData (clazz ).accept (b );
243+ public static <T > Consumer <FuncEmitTaskBuilder > eventJson (String type , Class <T > inputClass ) {
244+ return b -> new FuncEmitSpec ().type (type ).jsonData (inputClass ).accept (b );
245245 }
246246
247247 /**
248248 * Emit a CloudEvent with arbitrary bytes payload generated by a custom serializer.
249249 *
250250 * @param type CloudEvent type
251251 * @param serializer function producing bytes from the input
252- * @param clazz expected input class for conversion
252+ * @param inputClass expected input class for conversion
253253 * @param <T> input type
254254 * @return a consumer to configure {@link FuncEmitTaskBuilder}
255255 */
256256 public static <T > Consumer <FuncEmitTaskBuilder > eventBytes (
257- String type , Function <T , byte []> serializer , Class <T > clazz ) {
258- return b -> new FuncEmitSpec ().type (type ).bytesData (serializer , clazz ).accept (b );
257+ String type , Function <T , byte []> serializer , Class <T > inputClass ) {
258+ return b -> new FuncEmitSpec ().type (type ).bytesData (serializer , inputClass ).accept (b );
259259 }
260260
261261 /**
@@ -284,13 +284,13 @@ public static FuncPredicateEventConfigurer event(String type) {
284284 * type.
285285 *
286286 * @param fn the function to execute at runtime
287- * @param clazz expected input class for model conversion
287+ * @param inputClass expected input class for model conversion
288288 * @param <T> input type
289289 * @param <R> result type
290290 * @return a call step which supports chaining (e.g., {@code .exportAs(...).when(...)})
291291 */
292- public static <T , R > FuncCallStep <T , R > function (Function <T , R > fn , Class <T > clazz ) {
293- return new FuncCallStep <>(fn , clazz );
292+ public static <T , R > FuncCallStep <T , R > function (Function <T , R > fn , Class <T > inputClass ) {
293+ return new FuncCallStep <>(fn , inputClass );
294294 }
295295
296296 /**
@@ -440,26 +440,26 @@ public static <T, R> FuncCallStep<T, R> withUniqueId(UniqueIdBiFunction<T, R> fn
440440 * Create a fire-and-forget side-effect step (unnamed). The consumer receives the typed input.
441441 *
442442 * @param consumer side-effect function
443- * @param clazz expected input class for conversion
443+ * @param inputClass expected input class for conversion
444444 * @param <T> input type
445445 * @return a {@link ConsumeStep} which can be chained and added via {@link
446446 * #tasks(FuncTaskConfigurer...)}
447447 */
448- public static <T > ConsumeStep <T > consume (Consumer <T > consumer , Class <T > clazz ) {
449- return new ConsumeStep <>(consumer , clazz );
448+ public static <T > ConsumeStep <T > consume (Consumer <T > consumer , Class <T > inputClass ) {
449+ return new ConsumeStep <>(consumer , inputClass );
450450 }
451451
452452 /**
453453 * Named variant of {@link #consume(Consumer, Class)}.
454454 *
455455 * @param name task name
456456 * @param consumer side-effect function
457- * @param clazz expected input class
457+ * @param inputClass expected input class
458458 * @param <T> input type
459459 * @return a named {@link ConsumeStep}
460460 */
461- public static <T > ConsumeStep <T > consume (String name , Consumer <T > consumer , Class <T > clazz ) {
462- return new ConsumeStep <>(name , consumer , clazz );
461+ public static <T > ConsumeStep <T > consume (String name , Consumer <T > consumer , Class <T > inputClass ) {
462+ return new ConsumeStep <>(name , consumer , inputClass );
463463 }
464464
465465 /**
@@ -506,8 +506,8 @@ public static <T, R> FuncCallStep<T, R> agent(
506506 * @return a call step
507507 */
508508 public static <T , R > FuncCallStep <T , R > function (Function <T , R > fn ) {
509- Class <T > clazz = ReflectionUtils .inferInputType (fn );
510- return new FuncCallStep <>(fn , clazz );
509+ Class <T > inputClass = ReflectionUtils .inferInputType (fn );
510+ return new FuncCallStep <>(fn , inputClass );
511511 }
512512
513513 /**
@@ -520,22 +520,23 @@ public static <T, R> FuncCallStep<T, R> function(Function<T, R> fn) {
520520 * @return a named call step
521521 */
522522 public static <T , R > FuncCallStep <T , R > function (String name , Function <T , R > fn ) {
523- Class <T > clazz = ReflectionUtils .inferInputType (fn );
524- return new FuncCallStep <>(name , fn , clazz );
523+ Class <T > inputClass = ReflectionUtils .inferInputType (fn );
524+ return new FuncCallStep <>(name , fn , inputClass );
525525 }
526526
527527 /**
528528 * Named variant of {@link #function(Function, Class)} with explicit input type.
529529 *
530530 * @param name task name
531531 * @param fn the function to execute
532- * @param clazz expected input class
532+ * @param inputClass expected input class
533533 * @param <T> input type
534534 * @param <R> output type
535535 * @return a named call step
536536 */
537- public static <T , R > FuncCallStep <T , R > function (String name , Function <T , R > fn , Class <T > clazz ) {
538- return new FuncCallStep <>(name , fn , clazz );
537+ public static <T , R > FuncCallStep <T , R > function (
538+ String name , Function <T , R > fn , Class <T > inputClass ) {
539+ return new FuncCallStep <>(name , fn , inputClass );
539540 }
540541
541542 // ------------------ tasks ---------------- //
@@ -606,51 +607,52 @@ public static <T> EmitStep emit(String name, String type, Function<T, CloudEvent
606607 * @param name task name
607608 * @param type CloudEvent type
608609 * @param serializer function producing bytes
609- * @param clazz expected input class
610+ * @param inputClass expected input class
610611 * @param <T> input type
611612 * @return a named {@link EmitStep}
612613 */
613614 public static <T > EmitStep emit (
614- String name , String type , Function <T , byte []> serializer , Class <T > clazz ) {
615- return new EmitStep (name , eventBytes (type , serializer , clazz ));
615+ String name , String type , Function <T , byte []> serializer , Class <T > inputClass ) {
616+ return new EmitStep (name , eventBytes (type , serializer , inputClass ));
616617 }
617618
618619 /**
619620 * Unnamed variant of {@link #emit(String, String, Function, Class)}.
620621 *
621622 * @param type CloudEvent type
622623 * @param serializer function producing bytes
623- * @param clazz expected input class
624+ * @param inputClass expected input class
624625 * @param <T> input type
625626 * @return an {@link EmitStep}
626627 */
627- public static <T > EmitStep emit (String type , Function <T , byte []> serializer , Class <T > clazz ) {
628- return new EmitStep (null , eventBytes (type , serializer , clazz ));
628+ public static <T > EmitStep emit (
629+ String type , Function <T , byte []> serializer , Class <T > inputClass ) {
630+ return new EmitStep (null , eventBytes (type , serializer , inputClass ));
629631 }
630632
631633 /**
632634 * Emit a JSON CloudEvent from a POJO input class (unnamed).
633635 *
634636 * @param type CloudEvent type
635- * @param clazz input POJO class
637+ * @param inputClass input POJO class
636638 * @param <T> input type
637639 * @return an {@link EmitStep}
638640 */
639- public static <T > EmitStep emitJson (String type , Class <T > clazz ) {
640- return new EmitStep (null , eventJson (type , clazz ));
641+ public static <T > EmitStep emitJson (String type , Class <T > inputClass ) {
642+ return new EmitStep (null , eventJson (type , inputClass ));
641643 }
642644
643645 /**
644646 * Emit a JSON CloudEvent from a POJO input class (named).
645647 *
646648 * @param name task name
647649 * @param type CloudEvent type
648- * @param clazz input POJO class
650+ * @param inputClass input POJO class
649651 * @param <T> input type
650652 * @return a named {@link EmitStep}
651653 */
652- public static <T > EmitStep emitJson (String name , String type , Class <T > clazz ) {
653- return new EmitStep (name , eventJson (type , clazz ));
654+ public static <T > EmitStep emitJson (String name , String type , Class <T > inputClass ) {
655+ return new EmitStep (name , eventJson (type , inputClass ));
654656 }
655657
656658 /**
0 commit comments