InfoexchangeTest.kt

gistfile1.txt

package cc.datafabric.infoexchange.streams.gate;

import com.salesforce.kafka.test.junit5.SharedKafkaTestResource;
import de.bwaldvogel.mongo.MongoServer;
import de.bwaldvogel.mongo.backend.memory.MemoryBackend;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.RegisterExtension;

import java.net.InetSocketAddress;
import java.util.List;

class InfoexchangeTestJ {

    @RegisterExtension
    public final static SharedKafkaTestResource kafkaTestResource = new SharedKafkaTestResource();

    @Test
    void generalTest() {
        MongoServer mongoServer = new MongoServer(new MemoryBackend());
        InetSocketAddress serverAddress = mongoServer.bind();
        String mongoConnection = "mongodb://" +
                serverAddress.getHostName() +
                ":" +
                serverAddress.getPort();

        InfoexchangeSettings settings = new InfoexchangeSettings(
                "mongo",
                mongoConnection,
                "testOrg",
                kafkaTestResource.getKafkaConnectString()
        );

        Infoexchange adapter = new Infoexchange(settings);

        String iri = "testiri";
        String msg = "data";
        adapter.publishMessage(iri, msg);
        List<MessageRef> list = adapter.getMessagesIds();

        Assertions.assertEquals(1L, list.size());
    }
}