rabbitmq - 在带有 TTY 扩展的 MuleSoft ESB 上使用 AMQP 连接器发布消息

Question

使用 MuleSoft ESB，我如何使用 AnyPoint 工作室的 AMQP 连接器将消息发布到rabbitMQ，该连接器将过期。

<amqp:inbound-endpoint queueName="reusableQueue" 
exchangeType="direct" 
exchangeDurable="true" 
queueDurable="true" 
responseTimeout="10000"  
connector-ref="amqpConnector" 
doc:name="AMQP-0-9"/>

Answer 1

传输用户指南的交换和队列声明参数部分解释了如何在端点上配置额外的参数。

下面的示例显示了此功能如何允许使用 RabbitMQ DLQ 扩展，因此您可以类似地使用它来利用RabbitMQ TTL 扩展。

<amqp:endpoint name="amqpEndpointWithArguments" exchangeName="target-exchange"
    exchangeType="fanout" exchangeDurable="true" exchangeAutoDelete="false"
    queueName="target-queue" queueDurable="true" queueAutoDelete="false"
    queueExclusive="true" routingKey="a.b.c">
    <properties>
        <spring:entry key="amqp-exchange.alternate-exchange"
            value="some-exchange" />
        <spring:entry key="amqp-queue.x-dead-letter-exchange"
            value="some-queue" />
    </properties>
</amqp:endpoint>