case EXECUTION_REPORT:
consumer = new ExecutionReportEventCreatingInputStreamConsumer(inputStream, serverCurrentVersion);
break;
case MARKET_DEPTH_UPDATE:
consumer = new MarketDepthUpdateEventCreatingInputStreamConsumer(inputStream, serverCurrentVersion);
break;
case MARKET_DEPTH_LEVEL_TWO_UPDATE:
consumer = new MarketDepthLevelTwoUpdateEventCreatingInputStreamConsumer(inputStream, serverCurrentVersion);
break;