Hi, To send or receive multiple Message types, I think you can use GenericWritable. You can also implement your own GenericMessage and contribute it to our project!
Hope this helps you. On Thu, May 17, 2012 at 7:48 AM, Aditya Sarawgi <[email protected]> wrote: > Hi Guys, > > I am wondering how do the receive queues in hama work. Consider this case > that I want to sent a different type of BSPMessage in 2 consecutive > superstep. > In this first superstep I am sending IntMessage and in the next one I am > sending a ArrayMessage ( custom message class). > > Now in the second super step when I do a > while ((arrayMessage = (ArrayMessage) peer.getCurrentMessage()) != null) { > > it is throwing a java.lang.ClassCastException, which is obvious since its > trying to cast IntMessage to ArrayMessage. > I thought the message is dropped from the queue after it is read, is this > not the case ? > And if it is not, how can this be handled elegantly ? > > -- > Cheers, > Aditya Sarawgi -- Best Regards, Edward J. Yoon @eddieyoon
