@SuppressWarnings("unchecked")
private <E extends Event> EventCreatingConsumer<E> newEventCreatingConsumer(final IncomingMessageId messageId) {
EventCreatingConsumer<? extends Event> consumer = null;
switch (messageId) {
case TICK_PRICE:
consumer = new CompositeTickEventCreatingInputStreamConsumer(inputStream, serverCurrentVersion);
break;
case TICK_SIZE:
consumer = new TickSizeEventCreatingInputStreamConsumer(inputStream, serverCurrentVersion);
break;