@Test
void testOnBlockingQueue() {

    ArrayBlockingQueue<Plc4xSchema.Record> queue = new ArrayBlockingQueue<>(100);
    Plc4xStreamTable table = new Plc4xStreamTable(queue, new JobConfigurationImpl(
        "job1",
        null,
        100,
        Collections.emptyList(),
        Collections.singletonMap("key", "address")));
    Map<String, Object> objects = Collections.singletonMap("key", "value");
    queue.add(new Plc4xSchema.Record(Instant.now(), "", objects));
    Enumerator<Object[]> enumerator = table.scan(null).enumerator();
    assertThat(enumerator.moveNext()).isTrue();
    assertThat(enumerator.current()).contains("value");
}