You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by co...@apache.org on 2019/08/27 16:44:35 UTC

[cxf] branch master updated: Checkstyle fix

This is an automated email from the ASF dual-hosted git repository.

coheigea 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 705ddd2  Checkstyle fix
705ddd2 is described below

commit 705ddd2a5dc859221a57b0baddf134dbb3cc4c97
Author: Colm O hEigeartaigh <co...@apache.org>
AuthorDate: Tue Aug 27 17:44:21 2019 +0100

    Checkstyle fix
---
 .../apache/cxf/transport/http/asyncclient/AsyncHTTPConduitTest.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/rt/transports/http-hc/src/test/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduitTest.java b/rt/transports/http-hc/src/test/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduitTest.java
index 7ea4a77..ee3ebca 100644
--- a/rt/transports/http-hc/src/test/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduitTest.java
+++ b/rt/transports/http-hc/src/test/java/org/apache/cxf/transport/http/asyncclient/AsyncHTTPConduitTest.java
@@ -307,14 +307,15 @@ public class AsyncHTTPConduitTest extends AbstractBusClientServerTestBase {
         AtomicInteger threadCount = new AtomicInteger();
 
         for (long i = 0; i < repeat; i++) {
-            g.greetMeLaterAsync(-50, (res) -> {
+            g.greetMeLaterAsync(-50, res -> {
 
                 try {
                     int myCount = threadCount.getAndIncrement();
 
                     if (myCount < automaticWorkQueue1.getHighWaterMark()) {
                         // Sleep long enough so that the workqueue will fill up and then
-                        // handleResponseOnWorkqueue will fail for the calls from both responseReceived and consumeContent
+                        // handleResponseOnWorkqueue will fail for the calls from both
+                        // responseReceived and consumeContent
                         Thread.sleep(3 * asyncExecuteTimeout);
                         initialThreadsLatch.countDown();
                     } else {