如何使用Spring Streams将RabbitMQ消息广播给所有监听器

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>

@EnableBinding(Source.class)
public class MessageProducer {

    private final Source source;

    public MessageProducer(Source source) {
        this.source = source;
    }

    public void sendMessage(String message) {
        source.output().send(MessageBuilder.withPayload(message).build());
    }
}

@EnableBinding(Sink.class)
public class MessageConsumer {

    @StreamListener(Sink.INPUT)
    public void receiveMessage(String message) {
        // 处理接收到的消息
    }
}

spring:
  cloud:
    stream:
      bindings:
        output:
          destination: <exchange_name>
          content-type: application/json
        input:
          destination: <exchange_name>
          content-type: application/json

@Autowired
private MessageProducer producer;

public void broadcastMessage(String message) {
    producer.sendMessage(message);
}