There is no correlation with Mina 1.x. Its very low level and you gotta deal with that yourself.
Its my hope that Mina 2.0 or Netty has some sort of build in support for correlation in its core. But you gotta look at that yourself, so read the Mina or Netty documentation. On Wed, Mar 3, 2010 at 7:31 PM, Carlo Camerino <[email protected]> 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. >> >> > -- 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
