You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by re...@apache.org on 2021/06/17 00:37:00 UTC
[cxf] branch master updated: CXF-8534: Fix
org.apache.cxf.jaxrs.client.logging.RESTLoggingTest.testBinary (#815)
This is an automated email from the ASF dual-hosted git repository.
reta pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/cxf.git
The following commit(s) were added to refs/heads/master by this push:
new e8ff7db CXF-8534: Fix org.apache.cxf.jaxrs.client.logging.RESTLoggingTest.testBinary (#815)
e8ff7db is described below
commit e8ff7db98b357cb5c935ae19fe3da59380d1233b
Author: Andriy Redko <dr...@gmail.com>
AuthorDate: Wed Jun 16 20:36:48 2021 -0400
CXF-8534: Fix org.apache.cxf.jaxrs.client.logging.RESTLoggingTest.testBinary (#815)
---
.../cxf/jaxrs/client/logging/RESTLoggingTest.java | 37 ++++++++++++++++------
1 file changed, 27 insertions(+), 10 deletions(-)
diff --git a/rt/rs/client/src/test/java/org/apache/cxf/jaxrs/client/logging/RESTLoggingTest.java b/rt/rs/client/src/test/java/org/apache/cxf/jaxrs/client/logging/RESTLoggingTest.java
index fbfdcfe..6c81b20 100644
--- a/rt/rs/client/src/test/java/org/apache/cxf/jaxrs/client/logging/RESTLoggingTest.java
+++ b/rt/rs/client/src/test/java/org/apache/cxf/jaxrs/client/logging/RESTLoggingTest.java
@@ -62,31 +62,48 @@ public class RESTLoggingTest {
LoggingFeature loggingFeature = new LoggingFeature();
TestEventSender sender = new TestEventSender();
loggingFeature.setSender(sender);
+ loggingFeature.setLogBinary(true);
+
Server server = createService(SERVICE_URI_BINARY, new TestServiceRestBinary(), loggingFeature);
server.start();
WebClient client = createClient(SERVICE_URI_BINARY, loggingFeature);
client.get(InputStream.class).close();
- loggingFeature.setLogBinary(true);
+ client.close();
+
+ List<LogEvent> events = sender.getEvents();
+ await().until(() -> events.size(), is(4));
+ server.stop();
+ server.destroy();
+
+ Assert.assertEquals(4, events.size());
+
+ assertContentLogged(events.get(0));
+ assertContentLogged(events.get(1));
+ assertContentLogged(events.get(2));
+ assertContentLogged(events.get(3));
+ }
+
+ @Test
+ public void testNonBinary() throws IOException, InterruptedException {
+ LoggingFeature loggingFeature = new LoggingFeature();
+ TestEventSender sender = new TestEventSender();
+ loggingFeature.setSender(sender);
+ Server server = createService(SERVICE_URI_BINARY, new TestServiceRestBinary(), loggingFeature);
+ server.start();
+ WebClient client = createClient(SERVICE_URI_BINARY, loggingFeature);
client.get(InputStream.class).close();
client.close();
List<LogEvent> events = sender.getEvents();
- await().until(() -> events.size(), is(8));
+ await().until(() -> events.size(), is(4));
server.stop();
server.destroy();
- Assert.assertEquals(8, events.size());
+ Assert.assertEquals(4, events.size());
- // First call with binary logging false
assertContentLogged(events.get(0));
assertContentLogged(events.get(1));
assertContentNotLogged(events.get(2));
assertContentNotLogged(events.get(3));
-
- // Second call with binary logging true
- assertContentLogged(events.get(4));
- assertContentLogged(events.get(5));
- assertContentLogged(events.get(6));
- assertContentLogged(events.get(7));
}
@Test