1 package com.quikj.server.framework; 2 3 public class AceIPCMessageParser 4 { 5 protected AceIPCMessageParser(byte[] message, int length) 6 throws AceException 7 { 8 switch (message[AceIPCMessageInterface.MSG_TYPE_OFFSET]) 9 { 10 case AceIPCMessageInterface.CONN_REQ_MSG : 11 aceIPCMessage = 12 new AceIPCConnReqMessage(message, 13 length); 14 break; 15 case AceIPCMessageInterface.CONN_RESP_MSG : 16 aceIPCMessage = 17 new AceIPCConnRespMessage(message, 18 length); 19 break; 20 case AceIPCMessageInterface.DISCONNECT_MSG : 21 aceIPCMessage = 22 new AceIPCDiscMessage(message, 23 length); 24 break; 25 case AceIPCMessageInterface.HB_MSG : 26 aceIPCMessage = 27 new AceIPCHeartbeatMessage(message, 28 length); 29 break; 30 case AceIPCMessageInterface.USER_MSG : 31 aceIPCMessage = 32 new AceIPCUserMessage(message, 33 length); 34 break; 35 default : 36 throw new AceException( 37 "Invalid IPC message type = " 38 + message[AceIPCMessageInterface.MSG_TYPE_OFFSET]); 39 } 40 41 } 44 45 protected AceIPCMessageInterface getMessage() 46 { 47 return aceIPCMessage; 48 } 49 50 protected int getMessageType() 51 { 52 return aceIPCMessage.getIPCMsgType(); 53 } 54 55 private AceIPCMessageInterface aceIPCMessage; 56 } 57 | Popular Tags |