class JavaToSiddhiSerializer implements Serializer<StratioStreamingMessage, Event> {

    @Override
    public Event serialize(StratioStreamingMessage object) {
        Object[] values = new Object[object.getColumns().size()];
        for (ColumnNameTypeValue column : object.getColumns()) {
            values[streamMetadataService.getAttributePosition(object.getStreamName(), column.getColumn())] = column
                    .getValue();
        }
        return new InEvent(object.getStreamName(), System.currentTimeMillis(), values);
    }

    public  JavaToSiddhiSerializer(StreamMetadataService streamMetadataService);

}