Tag: spring cloud dataflow

Spring Cloud数据流类型转换在处理器组件中不起作用?

我有一个处理器,它将byte[]有效负载转换为MyClass有效负载: @Slf4j @EnableBinding(Processor.class) public class MyDecoder { @ServiceActivator(inputChannel = Processor.INPUT, outputChannel = Processor.OUTPUT) public MyClass decode(final byte[] payload) { MyClass decoded = doStuff(payload); if (decoded != null) { log.info(“Successfully decoded!”); } return decoded; } } 我尝试创建以下DSL: some-source | my-decoder | some-sink some-source | my-decoder | some-sink some-source | my-decoder | some-sink和some-sink报告错误,因为它在classLoader中没有MyClass类。 这是预期的行为。 我尝试在my-decoder上应用类型转换,例如: some-source | […]