@Nonnull
    @Override
    public Collection<DataConnectionResource> listResources() {
        HazelcastInstance instance = getClient();
        try {
            return instance.getDistributedObjects()
                    .stream()
                    .filter(IMap.class::isInstance)
                    .map(o -> new DataConnectionResource(OBJECT_TYPE_IMAP_JOURNAL, o.getName()))
                    .collect(Collectors.toList());
        } finally {
            instance.shutdown();
        }
    }
@Test
    public void list_resources_should_return_map() {
        IMap<Integer, String> map = instance.getMap("my_map");
        map.put(42, "42");

        DataConnectionConfig dataConnectionConfig = sharedDataConnectionConfig(clusterName);

        hazelcastDataConnection = new HazelcastDataConnection(dataConnectionConfig);
        Collection<DataConnectionResource> resources = hazelcastDataConnection.listResources();

        assertThat(resources).contains(new DataConnectionResource("IMapJournal", "my_map"));
    }