public static Iterable<ServiceBusMessage> createServiceBusMessages(
            final Iterable<?> data, final Map<String, Object> applicationProperties, final String correlationId) {
        return StreamSupport.stream(data.spliterator(), false)
                .map(obj -> createServiceBusMessage(obj, applicationProperties, correlationId))
                .collect(Collectors.toList());
    }
@Test
    void testCreateServiceBusMessages() {
        final List<String> inputMessages = new LinkedList<>();
        inputMessages.add("test data");
        inputMessages.add(String.valueOf(12345));

        final Iterable<ServiceBusMessage> busMessages = ServiceBusUtils.createServiceBusMessages(inputMessages, null, null);

        assertTrue(StreamSupport.stream(busMessages.spliterator(), false)
                .anyMatch(record -> record.getBody().toString().equals("test data")));
        assertTrue(StreamSupport.stream(busMessages.spliterator(), false)
                .anyMatch(record -> record.getBody().toString().equals("12345")));

        //Test bytes
        final List<byte[]> inputMessages2 = new LinkedList<>();
        byte[] byteBody1 = "test data".getBytes(StandardCharsets.UTF_8);
        byte[] byteBody2 = "test data2".getBytes(StandardCharsets.UTF_8);
        inputMessages2.add(byteBody1);
        inputMessages2.add(byteBody2);

        final Iterable<ServiceBusMessage> busMessages2 = ServiceBusUtils.createServiceBusMessages(inputMessages2, null, null);

        assertTrue(StreamSupport.stream(busMessages2.spliterator(), false)
                .anyMatch(message -> Arrays.equals(message.getBody().toBytes(), byteBody1)));
        assertTrue(StreamSupport.stream(busMessages2.spliterator(), false)
                .anyMatch(message -> Arrays.equals(message.getBody().toBytes(), byteBody2)));
    }