collector/TaskThread.java
file name: MessageUtil.java
Change-Id: I6f5700f731f62ef34fb33f9107564293a0e91d54
Issue-ID: VFC-829
Signed-off-by: ajay priyadarshi <ajay.priyadarshi@ril.com>
public class TaskThread implements Runnable {
private static final Log log = LogFactory.getLog(TaskThread.class);
- private MessageChannel pmResultChannel; //This should also be private. Need to change in TastThreadTest
+ private MessageChannel pmResultChannel;
private MessageChannel cmResultChannel;
private CollectMsg data;
return pmResultChannel;
}
- public void setPmResultChannel(MessageChannel pmResultChannel) {
- this.pmResultChannel = pmResultChannel;
+ public void setPmResultChannel(MessageChannel pmResChannel) {
+ this.pmResultChannel = pmResChannel;
}
}
dis.readFully(inputB);
short startSign = ois.readShort();
if (startSign != Msg.StartSign) {
- throw new Exception("start sign is [" + Msg.StartSign
+ throw new IOException("start sign is [" + Msg.StartSign
+ "],not is [" + startSign + "]");
}
int msgType = ois.readByte();
msg.setTimeStamp(timeStamp);
int bodylength = ois.readShort();
msg.setLenOfBody(bodylength);
- byte b[] = new byte[bodylength];
+ byte[] b = new byte[bodylength];
dis.readFully(b);
msg.newBodyfromBytes(b);
} catch (Exception e) {