2013-07-05 32 views
0

在我的騾應用程序中,我試圖發送消息(xml)到兔子MQ交換。 在我的應用程序定義:騾子和兔子AMQP - 試圖發送到交換

<scripting:component doc:name="CreateXML"> 
<scripting:script engine="Groovy"><![ 
def xml = "" //previously created xml 
return xml]]></scripting:script> 
</scripting:component> 
<amqp:outbound-endpoint 
      exchangeName="test-exchange.srv" 
      routingKey="auc.guest1.test" 
      connector-ref="AMQPRabbitConnector" /> 

而我的連接器,以兔MQ樣子:

<amqp:connector 
      name="AMQPRabbitConnector" 
      virtualHost="dev" 
      username="guest" 
      password="guest" 
      activeDeclarationsOnly="false"/> 

當我運行我的應用我是越來越異常後一段時間,我發信息:

ERROR 2013-07-05 10:53:34,020 [[fis-bps-pgm-mule].AMQPRabbitConnector.dispatcher.01] org.mule.exception.DefaultMessagingExceptionStrategy: 
******************************************************************************** 
Message    : Failed to route event via endpoint: DefaultOutboundEndpoint{endpointUri=amqp://test-exchange.srv, connector=AmqpConnector 
{ 
    name=AMQPRabbitConnector 
    lifecycle=start 
    this=2bfec68b 
    numberOfConcurrentTransactedReceivers=4 
    createMultipleTransactedReceivers=true 
    connected=true 
    supportedProtocols=[amqp] 
    serviceOverrides=<none> 
} 
} 
, name='endpoint.amqp.test-exchange.srv', mep=ONE_WAY, properties={routingKey=auc.guest1.test}, transactionConfig=Transaction{factory=null, action=INDIFFERENT, timeout=0}, deleteUnacceptedMessages=false, initialState=started, responseTimeout=10000, endpointEncoding=UTF-8, disableTransportTransformer=false}. Message payload is of type: AmqpMessage 
Type     : org.mule.api.transport.DispatchException 
Code     : MULE_ERROR--2 
Payload    : [email protected][consumerTag=<null>,[email protected],body={60,63,120,109,108,32,118,101,114,115,105,111,110,61,39,49,46,48,39,63,62,10,60,99,114,101,9 
+1

你能分享異常的整個棧跟蹤嗎? – genjosanzo

+0

你確定'test-exchange.srv'交換預先存在嗎?這是因爲你正在使用被動聲明。 –

回答

0

我解決了問題。 在流程的前置元素中,我設置了出站屬性,沒有該連接器正常工作。