gistfile1.txt

        List<IOException> deserializationErrors = new ArrayList<IOException>();
        IntStream.range(0, items.length)
            .parallel()
            .forEach(i -> {
                String messageBody = messages.get(i).getBody();
                try {
                    items[i] = mapper.readValue(messageBody, type);
                } catch (IOException e) {
                    deserializationErrors.add(e);
                }
            });

        if (deserializationErrors.size() > 0) {
            throw new AggregateIOException(deserializationErrors);
        }