我创建了一个流,它使用来自 RabbitMQ 的消息,然后使用路由器按类型分配给适当的服务。服务中的方法需要参数Message<?>
,因为我需要在那里使用标头。但是在这种方法中,我只收到带有 type 的消息有效负载,java.lang.String
并且org.springframework.messaging.Message
收到错误消息java.lang.ClassCastException: java.lang.String cannot be cast to org.springframework.messaging.Message
。
Payload 不适合我,因为我需要从消息中获取标头。
@Bean
public IntegrationFlow testFlow(String queueName,
ConnectionFactory connectionFactory,
Service1 service1,
Service2 service2) {
SimpleMessageListenerContainer consumerListener = new SimpleMessageListenerContainer(connectionFactory);
consumerListener.addQueueNames(queueName);
return IntegrationFlows.from(Amqp.inboundAdapter(consumerListener))
.transform(s -> s, ConsumerEndpointSpec::transactional)
.<Message<?>, String>route(HeadersUtil::getType, m -> m
.subFlowMapping(Type.SERVICE_1, sf -> sf.handle(service1::handleProcedure))
.subFlowMapping(Type.SERVICE_2, sf -> sf.handle(service2::handleProcedure)))
.get();
}
该方法的签名handleProcedure
如下:
void handleProcedure(Message<?> message)
我希望Message
在方法中获得标题handleProcedure
,但现在我得到了异常。