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 {
import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoMoreInteractions;
-
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
-
import java.io.IOException;
-
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.onap.dmaap.mr.client.MRBatchingPublisher;
+import org.onap.dmaap.mr.client.response.MRPublisherResponse;
import org.oransc.policyagent.clients.AsyncRestClient;
import org.oransc.policyagent.configuration.ApplicationConfig;
import org.oransc.policyagent.dmaap.DmaapRequestMessage.Operation;
-
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;
public void successfulCase() throws IOException {
doReturn(Mono.just("OK")).when(agentClient).delete("url");
doReturn(1).when(dmaapClient).send(anyString());
+ doReturn(new MRPublisherResponse()).when(dmaapClient).sendBatchWithResponse();
StepVerifier //
.create(testedObject.createTask(dmaapInputMessage(Operation.DELETE))) //
verifyNoMoreInteractions(agentClient);
verify(dmaapClient, times(1)).send(anyString());
+ verify(dmaapClient, times(1)).sendBatchWithResponse();
verifyNoMoreInteractions(dmaapClient);
}
public void errorCase() throws IOException {
doReturn(Mono.error(new Exception("Refused"))).when(agentClient).put("url", "payload");
doReturn(1).when(dmaapClient).send(anyString());
-
+ doReturn(new MRPublisherResponse()).when(dmaapClient).sendBatchWithResponse();
StepVerifier //
.create(testedObject.createTask(dmaapInputMessage(Operation.PUT))) //
.expectSubscription() //
// Error response
verify(dmaapClient, times(1)).send(anyString());
+ verify(dmaapClient, times(1)).sendBatchWithResponse();
verifyNoMoreInteractions(dmaapClient);
}