import org.apache.http.ProtocolVersion;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.message.BasicHttpResponse;
+import org.onap.logging.ref.slf4j.ONAPLogConstants;
+import org.slf4j.MDC;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;
interceptor = new ApacheClientMetricInterceptor() {};
request = new HttpGet(path);
response = new BasicHttpResponse(new ProtocolVersion("a",1,2), 200, "ok");
+ MDC.clear();
}
@Test
@Test
public void testGetResponseCode() {
- assertEquals(interceptor.getResponseCode(response), "ok");
+ assertEquals(interceptor.getResponseCode(response), "200");
}
@Test
public void testGetTargetEntity() {
assertNull(interceptor.getTargetEntity(request));
}
+
+ @Test
+ protected void testAdditionalPre() {
+ request.addHeader(ONAPLogConstants.Headers.INVOCATION_ID, "123");
+ interceptor.additionalPre(request, request);
+ assertEquals(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID), "123");
+ }
+
+ @Test
+ protected void whenThereIsNoInvocationIdHeader_thenMdcValueIsNull() {
+ interceptor.additionalPre(request, request);
+ assertNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
+ }
}