當通過Mule ESB中的VM端點時，會話變量被消除（使用AMQP）

我使用非常簡單的流程，從第一個流程中，我從AMQP（確認模式：Manual）中獲取消息並將其傳遞給第二個流通過VM流動，在第二個流程中，我使用AMQP確認處理器確認每條消息。當通過Mule ESB中的VM端點時，會話變量被消除（使用AMQP）

當我們使用VM時，交付標籤和通道標籤都將被清除（這對於此地址AMQP acknowledgement mule中描述的AMQP確認消息處理器是必需的）。所以我試圖在會話變量中保存交付標籤和amqp.channel。

第一次我想知道，存儲在會話變量中的通道值在通過虛擬機時被刪除，但能夠看到交付標籤。

觀察：

而不是如果我們使用flow-ref。它工作正常。但在我的情況下，我只需要使用虛擬機。

amqp.delivery標籤type（java.lang.Long中） amqp.channel type（com.rabbitmq.client.impl.ChannelN）。

如果'類型'的amqp.channel導致問題。如果是這樣，我怎麼能保存這個會話變量。請建議。請找到我的配置xml。

<flow name="testrabbitmqFlow1" doc:name="testrabbitmqFlow1" > 
<amqp:inbound-endpoint queueName="amqp.test.queue" exchangeDurable="true" queueDurable="true" responseTimeout="1000000" connector-ref="AMQP_Test" doc:name="AMQP"> 
<amqp:transaction recoverStrategy="REQUEUE" action="ALWAYS_BEGIN"/> 
</amqp:inbound-endpoint> 
<byte-array-to-string-transformer doc:name="Byte Array to String"/> 
<set-session-variable variableName="storedeliveryTag" value="#[flowVars['amqp.delivery-tag']]" doc:name="Session Variable"/> 
<set-session-variable variableName="storeChannel" value="#[flowVars['amqp.channel']]" doc:name="Session Variable"/> 
<vm:outbound-endpoint exchange-pattern="one-way" path="/test" doc:name="VM"> 
    <vm:transaction action="NONE"/> 
</vm:outbound-endpoint>

是否有任何人知道如何解決這個問題。

來源

2015-01-21 star

，因爲考慮到該模式是單向原來的線程將結束，該消息將被放置在一個SEDA隊列不同的線程池這行不通

<vm:outbound-endpoint exchange-pattern="one-way" ...

第一。

然後，因爲當你在VM，Http等傳輸器上放置消息時，即使你試圖序列化它們並將它們發送到另一個主機，流程變量也會丟失，並且對象實例也不會感覺到另一個主機，即：打開一個文件，嘗試以某種方式序列化描述符並將其發送到另一個主機，這是沒有意義的。

我的推薦是使用flow-ref而不是vm。

來源

2015-01-21 13:12:30

當通過Mule ESB中的VM端點時，會話變量被消除（使用AMQP）

回答

相關問題