使用rabbitmq将消息从一个队列传递到另一个队列时出现异常答案

【问题标题】：Getting exception on passing a message from one queue to another in mule using rabbitmq使用rabbitmq将消息从一个队列传递到另一个队列时出现异常
【发布时间】：2014-03-07 05:11:35
【问题描述】：

我正在运行带有 3 个队列 (rabbitmq) 的 mule 流。这是我的配置xml

<mule xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:amqp="http://www.mulesoft.org/schema/mule/amqp" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
    xmlns:spring="http://www.springframework.org/schema/beans" version="EE-3.4.1"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd
http://www.mulesoft.org/schema/mule/amqp http://www.mulesoft.org/schema/mule/amqp/current/mule-amqp.xsd
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd">
    <amqp:connector name="AMQP_Connector1" validateConnections="true" fallbackAddresses="localhost:5672" doc:name="AMQP Connector1"/>
    <flow name="putToQueue1" doc:name="putToQueue1">
        <http:inbound-endpoint exchange-pattern="one-way" host="localhost" port="8081" path="message" doc:name="HTTP"/>
        <set-payload value="#[message.inboundProperties['msg']]" doc:name="Set Payload"/>        
            <processor-chain doc:name="Processor Chain">
                <amqp:outbound-endpoint queueName="test.queue1" responseTimeout="10000" doc:name="AMQP1" connector-ref="AMQP_Connector1"/>
                <custom-processor class="CustomProcessor" doc:name="Custom Processor"/>
                <amqp:outbound-endpoint queueName="test.queue2" responseTimeout="10000" doc:name="AMQP2" connector-ref="AMQP_Connector1"/>
                <custom-processor class="CustomProcessor" doc:name="Custom Processor"/>
                <amqp:outbound-endpoint queueName="test.queue3" responseTimeout="10000"  doc:name="AMQP3" connector-ref="AMQP_Connector1"/>
           </processor-chain>       
    </flow>
</mule>

这里是 CustomProcessor java 类

import org.mule.api.MuleEvent;
import org.mule.api.MuleException;
import org.mule.api.processor.MessageProcessor;


public class CustomProcessor implements MessageProcessor {

    @Override
    public MuleEvent process(MuleEvent event) throws MuleException {
        String message = (event.getMessage().getPayload() +" "+ System.currentTimeMillis());
        event.getMessage().setPayload(message);
        return event;
    }

}

当我在浏览器中点击 url（使用 http 端点）时，一条消息通过queue1 和queue2 传递到queue3。首先，将消息放在queue1，然后将其传输到queue2，然后将queue2 传输到queue3。将消息转移到其他队列后，前一个队列不应保留该消息。但是当我第二次点击网址时。我收到以下异常

Caused by: java.lang.LinkageError: loader (instance of  org/mule/module/launcher/plugin/MulePluginsClassLoader): attempted  duplicate class definition for name: "org/mule/transport/amqp/AmqpMuleMessageFactory"
    at java.lang.ClassLoader.defineClass1(Native Method)
    at java.lang.ClassLoader.defineClassCond(Unknown Source)
    ..............

【问题讨论】：

一些特定于版本的问题或配置细节，也许吧？我无法在 Centos 6.4 上使用 Studio 3.5.0 重现此异常，没有 Maven。

标签： queue rabbitmq mule mule-studio

【解决方案1】：

您尝试做的是重新创建已经存在的队列。把它想象成你在服务器上有queue1，然后你试图再次创建这个队列。 RabbitMQ 不知道这是一个错误还是您明确想要这样做。在第二种情况下，您需要在创建队列时传递passive 标志

看看这里：https://www.rabbitmq.com/amqp-0-9-1-reference.html

有点被动

如果设置，如果队列已经存在，服务器将回复 Declare-Ok 存在同名，如果不存在则引发错误。客户可以使用它来检查队列是否存在而不修改服务器状态。设置后，除 name 和 no-wait 之外的所有其他方法字段都是忽略。带有被动和无等待的声明无效。比较参数的语义等价性。

【讨论】：