我的应用程序应该将某个事件从组件传播到某个rabbit消息发布者。
我的组件使用ApplicationEventPublisher.publishEvent(e)触发事件
另一方面，消息生产者应该接收事件，处理它，然后将它发布到rabbit队列。
我正在使用spring cloud stream和spring cloud function用于消息传递部分：

@Configurationn
MessagingConfig {
@Autowired
StreamBridge sb; 

@EventListener
void handleEvent(Event e){
sb.send("topic", e)
}

有没有靠功能而不是StreamBridge

@Bean
Supplier<Event> messageProducer(){
//Get the event and publish it
}

或将ApplicationEventListener视为绑定器

Function<Event, Event> messageProcessor(){
// redirect event to rabbit binder
}

我很困惑，谢谢你的帮助。