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 2019/09/27 00:27:52 UTC
[cxf] 03/03: CXF-8120: JAX-RS 2.1 SSE client: forbidden response
without WebApplicationException. Fixing test cases
This is an automated email from the ASF dual-hosted git repository.
reta pushed a commit to branch 3.2.x-fixes
in repository https://gitbox.apache.org/repos/asf/cxf.git
commit 9532ab1108e996ffb113a6d79f6e6e8d1a08b377
Author: reta <dr...@gmail.com>
AuthorDate: Thu Sep 26 20:27:30 2019 -0400
CXF-8120: JAX-RS 2.1 SSE client: forbidden response without WebApplicationException. Fixing test cases
---
.../org/apache/cxf/jaxrs/sse/client/SseEventSourceImplTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/rt/rs/sse/src/test/java/org/apache/cxf/jaxrs/sse/client/SseEventSourceImplTest.java b/rt/rs/sse/src/test/java/org/apache/cxf/jaxrs/sse/client/SseEventSourceImplTest.java
index 635f432..a06c650 100644
--- a/rt/rs/sse/src/test/java/org/apache/cxf/jaxrs/sse/client/SseEventSourceImplTest.java
+++ b/rt/rs/sse/src/test/java/org/apache/cxf/jaxrs/sse/client/SseEventSourceImplTest.java
@@ -395,13 +395,13 @@ public class SseEventSourceImplTest extends Assert {
try (SseEventSource eventSource = withReconnect()) {
eventSource.open();
assertThat(eventSource.isOpen(), equalTo(false));
- verify(response, times(1)).getStatus();
+ verify(response, times(3)).getStatus();
// Allow the event processor to pull for events (150ms)
Thread.sleep(150L);
}
- verify(response, times(2)).getStatus();
+ verify(response, times(6)).getStatus();
}
@Test
@@ -411,13 +411,13 @@ public class SseEventSourceImplTest extends Assert {
try (SseEventSource eventSource = withNoReconnect()) {
eventSource.open();
assertThat(eventSource.isOpen(), equalTo(false));
- verify(response, times(1)).getStatus();
+ verify(response, times(3)).getStatus();
// Allow the event processor to pull for events (150ms)
Thread.sleep(150L);
}
- verify(response, times(1)).getStatus();
+ verify(response, times(3)).getStatus();
}
@Test