1 22 package org.jboss.mq.il.uil2.msgs; 23 24 import java.io.ObjectOutputStream ; 25 import java.io.IOException ; 26 import java.io.ObjectInputStream ; 27 import org.jboss.mq.ReceiveRequest; 28 29 33 public class ReceiveRequestMsg extends BaseMsg 34 { 35 private ReceiveRequest[] messages; 36 37 public ReceiveRequestMsg() 38 { 39 this(null); 40 } 41 42 public ReceiveRequestMsg(ReceiveRequest[] messages) 43 { 44 super(MsgTypes.m_receiveRequest); 45 this.messages = messages; 46 } 47 48 public ReceiveRequest[] getMessages() 49 { 50 return messages; 51 } 52 53 public void trimTheMessages() 54 { 55 messages = null; 56 } 57 58 public void write(ObjectOutputStream out) throws IOException 59 { 60 super.write(out); 61 if (messages == null) 62 out.writeInt(0); 63 else 64 { 65 out.writeInt(messages.length); 66 for (int i = 0; i < messages.length; ++i) 67 messages[i].writeExternal(out); 68 } 69 } 70 71 public void read(ObjectInputStream in) throws IOException , ClassNotFoundException 72 { 73 super.read(in); 74 int count = in.readInt(); 75 messages = new ReceiveRequest[count]; 76 for (int i = 0; i < count; ++i) 77 { 78 messages[i] = new ReceiveRequest(); 79 messages[i].readExternal(in); 80 } 81 } 82 83 } 84 | Popular Tags |