1 package org.oxerr.okcoin.fix.fix44;
2
3 import quickfix.Message;
4 import quickfix.fix44.MessageFactory;
5
6
7
8
9 public class OKCoinMessageFactory extends MessageFactory {
10
11 @Override
12 public Message create(String beginString, String msgType) {
13 if (AccountInfoRequest.MSGTYPE.equals(msgType)) {
14 return new AccountInfoRequest();
15 }
16
17 if (AccountInfoResponse.MSGTYPE.equals(msgType)) {
18 return new AccountInfoResponse();
19 }
20
21 if (ExceptionResponseMessage.MSGTYPE.equals(msgType)) {
22 return new ExceptionResponseMessage();
23 }
24
25 return super.create(beginString, msgType);
26 }
27
28 }