import static org.junit.jupiter.api.Assertions.assertAll;
import static org.junit.jupiter.api.Assertions.assertEquals;
-
import com.google.common.base.Charsets;
import com.google.common.io.Resources;
import com.google.gson.JsonIOException;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.google.gson.JsonSyntaxException;
-
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.Properties;
-
import org.junit.jupiter.api.Test;
import org.onap.dmaap.mr.test.clients.ProtocolTypeConstants;
import org.springframework.http.MediaType;
() -> assertEquals("admin", actualPublisherConfig.get("password")),
() -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualPublisherConfig.get("TransportType")),
() -> assertEquals(15000, actualPublisherConfig.get("timeout")),
- () -> assertEquals(1000, actualPublisherConfig.get("limit")));
+ () -> assertEquals(100, actualPublisherConfig.get("limit")));
Properties actualConsumerConfig = parserUnderTest.getDmaapConsumerConfig();
assertAll("consumerConfig",
() -> assertEquals("policy-agent", actualConsumerConfig.get("id")),
() -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualConsumerConfig.get("TransportType")),
() -> assertEquals(15000, actualConsumerConfig.get("timeout")),
- () -> assertEquals(1000, actualConsumerConfig.get("limit")));
+ () -> assertEquals(100, actualConsumerConfig.get("limit")));
}
private JsonObject getJsonRootObject() throws JsonIOException, JsonSyntaxException, IOException {