@Override
public void messageReceived(FudgeContext fudgeContext, FudgeMsgEnvelope msgEnvelope) {
s_logger.info("Got message {}", msgEnvelope);
FudgeMsg msg = msgEnvelope.getMessage();
CogdaMessageType msgType = CogdaMessageType.getFromMessage(msg);
switch (msgType) {
case SUBSCRIPTION_RESPONSE:
case SNAPSHOT_RESPONSE:
dispatchCommandResponse(msgType, msg);
break;