if your question is not answered yet, please post your route. carlo c wrote: > > i used sync =true, i'm still got replies from another thread.... > > On Thu, Mar 4, 2010 at 2:20 AM, anandsk <[email protected]> wrote: >> >> when you use from it becomes the consumer and listens on that port if >> your >> app is running on host. >> >> If you are trying to identify the corresponding reply to a request, I >> beleive you need to have something in message to identify it uniquely. >> other >> alternative is using synchronus request/reply by setting sync flag to >> true. >> >> Thanks, >> Anand >> >> >> >> carlo c wrote: >>> >>> i was able to use codec successfully, >>> >>> however, i am having problems with the replies, >>> >>> sometimes i get the reply of another thread using the camel mina >>> component. >>> >>> how do i ensure that i am getting the proper reply >>> >>> i used the following >>> >>> mina:tcp://host:port?codec=#codecFactory >>> >>> how can i ensure that the reply is for me? >>> >>> what i did was to limit the number of consumers to 1 however i don't >>> wnt to do this in the future, >>> >>> the alternative that i could think is to set a separate >>> >>> from("mina:tcp://host:port?codec=#codecFactory") thread, is this the >>> correct way to handle this and set sync to false.... >>> >>> On Wed, Mar 3, 2010 at 5:04 AM, anandsk <[email protected]> wrote: >>>> >>>> If I understand your question correctly, you may want to look at codec >>>> option >>>> of camel-mina component. >>>> >>>> Thanks, >>>> Anand >>>> >>>> >>>> carlo c wrote: >>>>> >>>>> hi there, >>>>> >>>>> thanks a lot!! >>>>> i'm trying to understand the code in camel-mina and it seems that you >>>>> can configure it to signify that it is a textline? correct? >>>>> but what if the message returning isn't a text line. >>>>> In our case for example, the sample code that i use is >>>>> >>>>> dis.available() to determine if a message arrived, >>>>> afterwards, i configure a new byte[] in order to be able to read the >>>>> message >>>>> >>>>> Here is my source code using native java.io api >>>>> // input stream declaration coming from Socket >>>>> DataInputStream dis = **/ >>>>> // i'm checking this method (dis.available()) --> this returns the >>>>> number of bytes that an incoming message contains >>>>> byte[] responseByte = new byte[dis.available()]; >>>>> // >>>>> dis.readFully(responseByte); >>>>> >>>>> i somehow do it like this, >>>>> is there anyway that i can do this in camel mina? >>>>> i need to be able to get a response via the size of the input stream >>>>> coming back. >>>>> >>>>> thanks >>>>> carlo >>>>> >>>>> >>>> >>>> -- >>>> View this message in context: >>>> http://old.nabble.com/Question-On-Camel-Mina---Multiple-Messages-With-One-IOSession-tp27756509p27761139.html >>>> Sent from the Camel - Users mailing list archive at Nabble.com. >>>> >>>> >>> >>> >> >> -- >> View this message in context: >> http://old.nabble.com/Question-On-Camel-Mina---Multiple-Messages-With-One-IOSession-tp27756509p27771764.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > >
-- View this message in context: http://old.nabble.com/Question-On-Camel-Mina---Multiple-Messages-With-One-IOSession-tp27756509p27772724.html Sent from the Camel - Users mailing list archive at Nabble.com.
