Hi Ah the issue is that you are doing request/reply over HTTP and send to a JMS queue which then also would use request/reply. But I bet you want to just send the message to the queue and then continue. For that you must use correct MEP patterns, eg InOnly
See this unit test I added http://svn.apache.org/viewvc?rev=897802&view=rev Then it works fine. On Mon, Jan 11, 2010 at 8:21 AM, ext2 <[email protected]> wrote: >>>Use .convertBodyTo(String.class) after the from. This will store the HTTP > data >>>as a String which can be safely duplicated when you do a multicast. > Is the problem is really caused by duplicating message? > > If it does, does the multi-cast support a strategy for end-user who can > control how to duplicate the data saved in message? > > > -----Original----- > Sender: Claus Ibsen [mailto:[email protected]] > Date: 2010-1-11 14:18 > Receiver: [email protected] > Subject: Re: Question about multicasting. > > On Mon, Jan 11, 2010 at 7:00 AM, ztesoft <[email protected]> wrote: >> >> Dears, I try to use multicast to save the received message into two files >> using >> > "from("jetty:http://0.0.0.0:8080/";).multicast().to("file://output","file://o > utput1");" >> It works correctly. Two files will be saved in /output/.camel/ and >> /output1/.camel/ folders separately. >> >> But if I use activemq for a endpoint, there may be something wrong. >> 1st. I use activemy queue instead of the second endpoint. >> >> > from("jetty:http://0.0.0.0:8080/";).multicast().to("file://output","test-jms: > queue:test.queue"); >> from("test-jms:queue:test.queue").process(new Processor() { >> public void process(Exchange e) throws IOException { >> System.out.println("Received exchange: " + >> e.getIn()); >> >> System.out.println(e.getIn().getBody(String.class)); >> } >> }); >> } >> }); >> In this case, when I send a HTTP request, the result is one file saved in >> /output/ folder and a message displayed in console. The content of this >> message is: >> "Received exchange: JmsMessage: ActiveMQBytesMessage {commandId = 5, >> responseRequired = true, messageId = > ID:chenyi-4710-1263188603156-2:2:1:1:1, >> originalDestination = null, originalTransactionId = null, producerId = >> ID:chenyi-4710-1263188603156-2:2:1:1, destination = queue://test.queue, >> transactionId = null, expiration = 1263188625859, timestamp = > 1263188605859, >> arrival = 0, brokerInTime = 1263188605859, brokerOutTime = 1263188605859, >> correlationId = 5a1b6157-a4cb-4f8a-aa78-82519a776bf0, replyTo = >> temp-queue://ID:chenyi-4710-1263188603156-2:1:1, persistent = true, type = >> null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = >> null, compressed = false, userID = null, content = >> org.apache.activemq.util.byteseque...@6a63d3, marshalledProperties = null, >> dataStructure = null, redeliveryCounter = 0, size = 1024, properties = >> {CamelHttpUrl=http://127.0.0.1:8080/, >> Content_HYPHEN_Type=text/xml;charset=UTF-8, Host=127.0.0.1:8080, >> CamelHttpMethod=POST, Content_HYPHEN_Length=681, >> SOAPAction="http://www.ctcc.com/service/sendSms";, >> CamelHttpCharacterEncoding=UTF-8, User_HYPHEN_Agent=Jakarta >> Commons-HttpClient/3.0.1, CamelHttpPath=/, CamelHttpUri=/}, >> readOnlyProperties = true, readOnlyBody = true, droppable = false} >> ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn = >> java.io.datainputstr...@bfed5a }" >> >> 2nd. >> I change the order for the multicast endpoint. >> >> > from("jetty:http://0.0.0.0:8080/";).multicast().to("test-jms:queue:test.queue > ","file://output"); >> from("test-jms:queue:test.queue").process(new Processor() { >> public void process(Exchange e) throws IOException { >> System.out.println("Received exchange: " + >> e.getIn()); >> >> System.out.println(e.getIn().getBody(String.class)); >> } >> }); >> } >> }); >> In this case, when I send a HTTP request, the message displayed correctly > in >> th console(the http request body displayed). But there is not any file > saved >> in any folder. >> >> Does anyone know the reasons and how to solve this problem? >> -- > > Use .convertBodyTo(String.class) after the from. This will store the > HTTP data as a String which can be safely duplicated when you do a > multicast. > > > >> View this message in context: > http://old.nabble.com/Question-about-multicasting.-tp27106219p27106219.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > > > > -- > Claus Ibsen > Apache Camel Committer > > Author of Camel in Action: http://www.manning.com/ibsen/ > Open Source Integration: http://fusesource.com > Blog: http://davsclaus.blogspot.com/ > Twitter: http://twitter.com/davsclaus > > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
