Skip to content
Snippets Groups Projects
Select Git revision
  • 776cac5ba0333f3a5ae9a211ff7ea5b9f7ac5114
  • main default protected
  • KOP-3064-Test-Nachrichten-Fuer-Enaio-DMS
  • KOP-3139-ozgcloud-Abhaengigkeit-entfernen
  • OZG-8085-ci-components-poc
  • KOP-3126-Reproduce-Bug
  • 0.2.2
  • 0.2.1
  • 0.2.0
9 results

XtaClientITCase.java

Blame
  • XtaClientITCase.java 15.14 KiB
    package de.ozgcloud.xta.client;
    
    import static de.ozgcloud.xta.client.XtaClient.*;
    import static de.ozgcloud.xta.client.extension.XtaServerSetupExtensionTestUtil.*;
    import static java.util.Collections.*;
    import static org.assertj.core.api.Assertions.*;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.function.Consumer;
    import java.util.function.Predicate;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.RegisterExtension;
    
    import de.ozgcloud.xta.client.extension.StaticStringListAppender;
    import de.ozgcloud.xta.client.extension.XtaMessageExampleLoader;
    import de.ozgcloud.xta.client.extension.XtaTestServerSetupExtension;
    import de.ozgcloud.xta.client.model.XtaIdentifier;
    import de.ozgcloud.xta.client.model.XtaMessage;
    import de.ozgcloud.xta.client.model.XtaMessageMetaData;
    import de.ozgcloud.xta.client.model.XtaMessageStatus;
    import de.ozgcloud.xta.client.model.XtaTransportReport;
    import lombok.SneakyThrows;
    
    class XtaClientITCase {
    
    	@RegisterExtension
    	static final XtaTestServerSetupExtension XTA_TEST_SERVER_SETUP_EXTENSION = new XtaTestServerSetupExtension();
    	static final int TWO_MAX_LIST_ITEMS = 2;
    
    	private XtaClient setupClient;
    	private XtaClient testClient;
    
    	private List<XtaMessageMetaData> supportCheckedMetadataItems;
    	private List<XtaMessage> processedMessages;
    	private Consumer<XtaMessage> processMessageDummy;
    	private Predicate<XtaMessageMetaData> isSupportedDummy;
    
    	@BeforeEach
    	@SneakyThrows
    	void setup() {
    		processMessageDummy = (message) -> {
    		};
    		supportCheckedMetadataItems = new ArrayList<>();
    		isSupportedDummy = (metaData) -> true;
    		processedMessages = new ArrayList<>();
    		setupClient = XTA_TEST_SERVER_SETUP_EXTENSION.getSetupClient();
    
    		StaticStringListAppender.clearLogLines();
    		closeMessagesForAllReaders();
    	}
    
    	private void closeMessagesForAllReaders() {
    		closeAllMessages(setupClient, READER_CLIENT_IDENTIFIER1);
    		closeAllMessages(setupClient, READER_CLIENT_IDENTIFIER2);
    		closeAllMessages(setupClient, READER_CLIENT_IDENTIFIER3);
    	}
    
    
    	@DisplayName("fetch messages")
    	@Nested
    	class TestFetchMessages {
    
    		private List<XtaMessage> sendMessages;
    		private List<String> sendMessageIds;