- Properties actualPublisherConfig = result.dmaapPublisherConfig();
- assertAll("publisherConfig",
- () -> assertEquals("localhost:6845/events", actualPublisherConfig.get("ServiceName"), "Wrong ServiceName"),
- () -> assertEquals("A1-POLICY-AGENT-WRITE", actualPublisherConfig.get("topic"), "Wrong topic"),
- () -> assertEquals("localhost:6845", actualPublisherConfig.get("host"), "Wrong host"),
- () -> assertEquals(MediaType.APPLICATION_JSON.toString(), actualPublisherConfig.get("contenttype"),
- "Wrong contenttype"),
- () -> assertEquals("admin", actualPublisherConfig.get("userName"), "Wrong userName"),
- () -> assertEquals("admin", actualPublisherConfig.get("password"), "Wrong password"),
- () -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualPublisherConfig.get("TransportType"),
- "Wrong TransportType"),
- () -> assertEquals("15000", actualPublisherConfig.get("timeout"), "Wrong timeout"),
- () -> assertEquals("100", actualPublisherConfig.get("limit"), "Wrong limit"));
-
- Properties actualConsumerConfig = result.dmaapConsumerConfig();
- assertAll("consumerConfig",
- () -> assertEquals("localhost:6845/events", actualConsumerConfig.get("ServiceName"), "Wrong ServiceName"),
- () -> assertEquals("A1-POLICY-AGENT-READ", actualConsumerConfig.get("topic"), "Wrong topic"),
- () -> assertEquals("localhost:6845", actualConsumerConfig.get("host"), "Wrong host"),
- () -> assertEquals(MediaType.APPLICATION_JSON.toString(), actualConsumerConfig.get("contenttype"),
- "Wrong contenttype"),
- () -> assertEquals("admin", actualConsumerConfig.get("userName"), "Wrong userName"),
- () -> assertEquals("admin", actualConsumerConfig.get("password"), "Wrong password"),
- () -> assertEquals("users", actualConsumerConfig.get("group"), "Wrong group"),
- () -> assertEquals("policy-agent", actualConsumerConfig.get("id"), "Wrong id"),
- () -> assertEquals(ProtocolTypeConstants.HTTPNOAUTH.toString(), actualConsumerConfig.get("TransportType"),
- "Wrong TransportType"),
- () -> assertEquals("15000", actualConsumerConfig.get("timeout"), "Wrong timeout"),
- () -> assertEquals("100", actualConsumerConfig.get("limit"), "Wrong limit"));