This is an automated email from the ASF dual-hosted git repository. gzurowski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit a2ae43c3c155350e3ed103fd48d51427ef1f7be7 Author: Gregor Zurowski <[email protected]> AuthorDate: Tue Apr 9 08:10:58 2019 +0200 [Minor] Replace anonymous class with lambda expressions --- .../camel/management/DefaultManagementAgent.java | 16 +++++++-------- .../management/mbean/ManagedCamelContext.java | 21 +++++++++----------- .../management/BacklogTracerStreamCachingTest.java | 9 +++------ .../management/CamelChoiceWithManagementTest.java | 14 ++++--------- .../management/ExceptionWithManagementTest.java | 13 +++--------- .../camel/management/ManagedCustomPolicyTest.java | 9 +++------ .../management/ManagedErrorHandlerOptionsTest.java | 12 +++++------ .../ManagedErrorHandlerRedeliveryTest.java | 12 +++++------ .../ManagedFailoverLoadBalancerTest.java | 7 ++----- .../management/ManagedFileIdempotentClearTest.java | 12 +++++------ .../ManagedFileIdempotentConsumerTest.java | 12 +++++------ .../management/ManagedInflightRepositoryTest.java | 23 ++++++++++------------ .../management/ManagedInflightStatisticsTest.java | 11 ++++------- .../management/ManagedInlinedProcessorTest.java | 7 +------ .../ManagedMemoryIdempotentClearTest.java | 12 +++++------ .../ManagedMemoryIdempotentConsumerTest.java | 12 +++++------ .../management/ManagedRedeliverRouteOnlyTest.java | 8 +++----- .../camel/management/ManagedRedeliverTest.java | 8 +++----- .../management/ManagedRouteAddFromRouteTest.java | 19 ++++++++---------- .../ManagedRouteDirectWhileIssueLeakTest.java | 17 +++++++--------- .../camel/management/ManagedThrottlerTest.java | 7 ++----- .../management/MultiInstanceProcessorTest.java | 8 +++----- .../apache/camel/processor/NoErrorHandlerTest.java | 8 +++----- .../ReduceStacksNeededDuringRoutingTest.java | 17 +++++++--------- .../processor/async/AsyncEndpointWithJMXTest.java | 14 +++---------- 25 files changed, 115 insertions(+), 193 deletions(-) diff --git a/core/camel-management-impl/src/main/java/org/apache/camel/management/DefaultManagementAgent.java b/core/camel-management-impl/src/main/java/org/apache/camel/management/DefaultManagementAgent.java index 6ca3a58..e35ca5a 100644 --- a/core/camel-management-impl/src/main/java/org/apache/camel/management/DefaultManagementAgent.java +++ b/core/camel-management-impl/src/main/java/org/apache/camel/management/DefaultManagementAgent.java @@ -568,15 +568,13 @@ public class DefaultManagementAgent extends ServiceSupport implements Management // use async thread for starting the JMX Connector // (no need to use a thread pool or enlist in JMX as this thread is terminated when the JMX connector has been started) String threadName = camelContext.getExecutorServiceManager().resolveThreadName("JMXConnector: " + url); - Thread thread = getCamelContext().getExecutorServiceManager().newThread(threadName, new Runnable() { - public void run() { - try { - LOG.debug("Staring JMX Connector thread to listen at: {}", url); - cs.start(); - LOG.info("JMX Connector thread started and listening at: {}", url); - } catch (IOException ioe) { - LOG.warn("Could not start JMXConnector thread at: " + url + ". JMX Connector not in use.", ioe); - } + Thread thread = getCamelContext().getExecutorServiceManager().newThread(threadName, () -> { + try { + LOG.debug("Staring JMX Connector thread to listen at: {}", url); + cs.start(); + LOG.info("JMX Connector thread started and listening at: {}", url); + } catch (IOException ioe) { + LOG.warn("Could not start JMXConnector thread at: " + url + ". JMX Connector not in use.", ioe); } }); thread.start(); diff --git a/core/camel-management-impl/src/main/java/org/apache/camel/management/mbean/ManagedCamelContext.java b/core/camel-management-impl/src/main/java/org/apache/camel/management/mbean/ManagedCamelContext.java index 2c9f4d1..f3144b3 100644 --- a/core/camel-management-impl/src/main/java/org/apache/camel/management/mbean/ManagedCamelContext.java +++ b/core/camel-management-impl/src/main/java/org/apache/camel/management/mbean/ManagedCamelContext.java @@ -376,19 +376,16 @@ public class ManagedCamelContext extends ManagedPerformanceCounter implements Ti if (resolvePlaceholders) { final AtomicBoolean changed = new AtomicBoolean(); InputStream is = new ByteArrayInputStream(xml.getBytes("UTF-8")); - Document dom = XmlLineNumberParser.parseXml(is, new XmlLineNumberParser.XmlTextTransformer() { - @Override - public String transform(String text) { - try { - String after = getContext().resolvePropertyPlaceholders(text); - if (!changed.get()) { - changed.set(!text.equals(after)); - } - return after; - } catch (Exception e) { - // ignore - return text; + Document dom = XmlLineNumberParser.parseXml(is, text -> { + try { + String after = getContext().resolvePropertyPlaceholders(text); + if (!changed.get()) { + changed.set(!text.equals(after)); } + return after; + } catch (Exception e) { + // ignore + return text; } }); // okay there were some property placeholder replaced so re-create the model diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java index b94ca07..38a93c7 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/BacklogTracerStreamCachingTest.java @@ -88,12 +88,9 @@ public class BacklogTracerStreamCachingTest extends ManagementTestSupport { context.setUseBreadcrumb(false); from("direct:start").streamCaching() - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - ByteArrayInputStream is = new ByteArrayInputStream("Bye World".getBytes()); - exchange.getIn().setBody(is); - } + .process(exchange -> { + ByteArrayInputStream is = new ByteArrayInputStream("Bye World".getBytes()); + exchange.getIn().setBody(is); }) .log("Got ${body}") .to("mock:bar").id("bar"); diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/CamelChoiceWithManagementTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/CamelChoiceWithManagementTest.java index 6d31603..c847d72 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/CamelChoiceWithManagementTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/CamelChoiceWithManagementTest.java @@ -57,11 +57,9 @@ public class CamelChoiceWithManagementTest extends ContextTestSupport { c.expectedHeaderReceived("Validation", "Yes"); expectsMessageCount(0, b, d, e); - template.send("direct:start", new Processor() { - public void process(Exchange exchange) throws Exception { - exchange.getIn().setBody(body); - exchange.getIn().setHeader("CBR1", "Yes"); - } + template.send("direct:start", exchange -> { + exchange.getIn().setBody(body); + exchange.getIn().setHeader("CBR1", "Yes"); }); assertMockEndpointsSatisfied(); @@ -74,11 +72,7 @@ public class CamelChoiceWithManagementTest extends ContextTestSupport { expectsMessageCount(0, a, b, c, d); - template.send("direct:start", new Processor() { - public void process(Exchange exchange) throws Exception { - exchange.getIn().setBody(body); - } - }); + template.send("direct:start", exchange -> exchange.getIn().setBody(body)); assertMockEndpointsSatisfied(); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java index 827cd71..3440335 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ExceptionWithManagementTest.java @@ -42,12 +42,7 @@ public class ExceptionWithManagementTest extends ContextTestSupport { MockEndpoint out = this.resolveMandatoryEndpoint("mock:out", MockEndpoint.class); out.expectedMessageCount(0); - template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { - exchange.getIn().setBody("hello"); - } - - }); + template.send("direct:start", ExchangePattern.InOnly, exchange -> exchange.getIn().setBody("hello")); error.assertIsSatisfied(); out.assertIsSatisfied(); @@ -61,10 +56,8 @@ public class ExceptionWithManagementTest extends ContextTestSupport { onException(IllegalArgumentException.class).redeliveryDelay(0).maximumRedeliveries(1).to("mock:error"); - from("direct:start").process(new Processor() { - public void process(Exchange exchange) throws Exception { - throw new IllegalArgumentException("intentional error"); - } + from("direct:start").process(exchange -> { + throw new IllegalArgumentException("intentional error"); }).to("mock:out"); } }; diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedCustomPolicyTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedCustomPolicyTest.java index 8337eb8..5f029b0 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedCustomPolicyTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedCustomPolicyTest.java @@ -88,12 +88,9 @@ public class ManagedCustomPolicyTest extends ManagementTestSupport { @Override public Processor wrap(RouteContext routeContext, final Processor processor) { - return new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - counter.incrementAndGet(); - processor.process(exchange); - } + return exchange -> { + counter.incrementAndGet(); + processor.process(exchange); }; } } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java index 55d44b1..1e12306 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerOptionsTest.java @@ -141,15 +141,13 @@ public class ManagedErrorHandlerOptionsTest extends ManagementTestSupport { public void configure() throws Exception { errorHandler(defaultErrorHandler().maximumRedeliveries(5)); - from("direct:start").process(new Processor() { - public void process(Exchange exchange) throws Exception { - counter++; - if (counter < 3) { - throw new IllegalArgumentException("Forced"); - } + from("direct:start").process(exchange -> { + counter++; + if (counter < 3) { + throw new IllegalArgumentException("Forced"); } }).to("mock:result"); } }; } -} \ No newline at end of file +} diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java index 237d457..7d7764f 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedErrorHandlerRedeliveryTest.java @@ -140,15 +140,13 @@ public class ManagedErrorHandlerRedeliveryTest extends ManagementTestSupport { public void configure() throws Exception { errorHandler(defaultErrorHandler().maximumRedeliveries(5)); - from("direct:start").process(new Processor() { - public void process(Exchange exchange) throws Exception { - counter++; - if (counter < 3) { - throw new IllegalArgumentException("Forced"); - } + from("direct:start").process(exchange -> { + counter++; + if (counter < 3) { + throw new IllegalArgumentException("Forced"); } }).to("mock:result"); } }; } -} \ No newline at end of file +} diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFailoverLoadBalancerTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFailoverLoadBalancerTest.java index 0518b97..7509514 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFailoverLoadBalancerTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFailoverLoadBalancerTest.java @@ -39,11 +39,8 @@ public class ManagedFailoverLoadBalancerTest extends ManagementTestSupport { return; } - getMockEndpoint("mock:foo").whenAnyExchangeReceived(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - throw new IOException("Forced"); - } + getMockEndpoint("mock:foo").whenAnyExchangeReceived(exchange -> { + throw new IOException("Forced"); }); MockEndpoint bar = getMockEndpoint("mock:bar"); diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentClearTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentClearTest.java index 69b124a..67dfc89 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentClearTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentClearTest.java @@ -101,13 +101,11 @@ public class ManagedFileIdempotentClearTest extends ManagementTestSupport { } protected void sendMessage(final Object messageId, final Object body) { - template.send(startEndpoint, new Processor() { - public void process(Exchange exchange) { - // now lets fire in a message - Message in = exchange.getIn(); - in.setBody(body); - in.setHeader("messageId", messageId); - } + template.send(startEndpoint, exchange -> { + // now lets fire in a message + Message in = exchange.getIn(); + in.setBody(body); + in.setHeader("messageId", messageId); }); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentConsumerTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentConsumerTest.java index 1b3a072..2137943 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentConsumerTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedFileIdempotentConsumerTest.java @@ -108,13 +108,11 @@ public class ManagedFileIdempotentConsumerTest extends ManagementTestSupport { } protected void sendMessage(final Object messageId, final Object body) { - template.send(startEndpoint, new Processor() { - public void process(Exchange exchange) { - // now lets fire in a message - Message in = exchange.getIn(); - in.setBody(body); - in.setHeader("messageId", messageId); - } + template.send(startEndpoint, exchange -> { + // now lets fire in a message + Message in = exchange.getIn(); + in.setBody(body); + in.setHeader("messageId", messageId); }); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightRepositoryTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightRepositoryTest.java index 1b85874..88a53ac 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightRepositoryTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightRepositoryTest.java @@ -48,23 +48,20 @@ public class ManagedInflightRepositoryTest extends ManagementTestSupport { public void configure() throws Exception { from("direct:start").routeId("foo") .to("mock:a") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - MBeanServer mbeanServer = getMBeanServer(); - ObjectName name = ObjectName.getInstance("org.apache.camel:context=camel-1,type=services,name=DefaultInflightRepository"); + .process(exchange -> { + MBeanServer mbeanServer = getMBeanServer(); + ObjectName name = ObjectName.getInstance("org.apache.camel:context=camel-1,type=services,name=DefaultInflightRepository"); - Integer size = (Integer) mbeanServer.getAttribute(name, "Size"); - assertEquals(1, size.intValue()); + Integer size = (Integer) mbeanServer.getAttribute(name, "Size"); + assertEquals(1, size.intValue()); - Integer routeSize = (Integer) mbeanServer.invoke(name, "size", new Object[]{"foo"}, new String[]{"java.lang.String"}); - assertEquals(1, routeSize.intValue()); + Integer routeSize = (Integer) mbeanServer.invoke(name, "size", new Object[]{"foo"}, new String[]{"java.lang.String"}); + assertEquals(1, routeSize.intValue()); - TabularData data = (TabularData) mbeanServer.invoke(name, "browse", null, null); - assertNotNull(data); + TabularData data = (TabularData) mbeanServer.invoke(name, "browse", null, null); + assertNotNull(data); - assertEquals(1, data.size()); - } + assertEquals(1, data.size()); }).id("myProcessor") .to("mock:result"); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightStatisticsTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightStatisticsTest.java index 55a1c6d..e7f7839 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightStatisticsTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInflightStatisticsTest.java @@ -121,16 +121,13 @@ public class ManagedInflightStatisticsTest extends ManagementTestSupport { @Override public void configure() throws Exception { from("direct:start") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - CountDownLatch latch = (CountDownLatch) exchange.getIn().getBody(); - latch.await(10, TimeUnit.SECONDS); - } + .process(exchange -> { + CountDownLatch latch = (CountDownLatch) exchange.getIn().getBody(); + latch.await(10, TimeUnit.SECONDS); }) .to("mock:result").id("mock"); } }; } -} \ No newline at end of file +} diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInlinedProcessorTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInlinedProcessorTest.java index de4f7d2..c346be9 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInlinedProcessorTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedInlinedProcessorTest.java @@ -56,12 +56,7 @@ public class ManagedInlinedProcessorTest extends ManagementTestSupport { @Override public void configure() throws Exception { from("direct:start").routeId("foo") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - exchange.getOut().setBody("Bye World"); - } - }).id("custom") + .process(exchange -> exchange.getOut().setBody("Bye World")).id("custom") .to("mock:result"); } }; diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentClearTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentClearTest.java index 923052a..c2fcb1b 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentClearTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentClearTest.java @@ -152,13 +152,11 @@ public class ManagedMemoryIdempotentClearTest extends ManagementTestSupport { } protected void sendMessage(final Object messageId, final Object body) { - template.send(startEndpoint, new Processor() { - public void process(Exchange exchange) { - // now lets fire in a message - Message in = exchange.getIn(); - in.setBody(body); - in.setHeader("messageId", messageId); - } + template.send(startEndpoint, exchange -> { + // now lets fire in a message + Message in = exchange.getIn(); + in.setBody(body); + in.setHeader("messageId", messageId); }); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentConsumerTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentConsumerTest.java index 7050265..89010e0 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentConsumerTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedMemoryIdempotentConsumerTest.java @@ -156,13 +156,11 @@ public class ManagedMemoryIdempotentConsumerTest extends ManagementTestSupport { } protected void sendMessage(final Object messageId, final Object body) { - template.send(startEndpoint, new Processor() { - public void process(Exchange exchange) { - // now lets fire in a message - Message in = exchange.getIn(); - in.setBody(body); - in.setHeader("messageId", messageId); - } + template.send(startEndpoint, exchange -> { + // now lets fire in a message + Message in = exchange.getIn(); + in.setBody(body); + in.setHeader("messageId", messageId); }); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverRouteOnlyTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverRouteOnlyTest.java index aeff451..2d5d28f 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverRouteOnlyTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverRouteOnlyTest.java @@ -72,12 +72,10 @@ public class ManagedRedeliverRouteOnlyTest extends ManagementTestSupport { from("direct:start") .to("mock:foo") - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - log.info("Invoking me"); + .process(exchange -> { + log.info("Invoking me"); - throw new IllegalArgumentException("Damn"); - } + throw new IllegalArgumentException("Damn"); }).id("myprocessor"); } }; diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverTest.java index 49c220b..00aab02 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRedeliverTest.java @@ -93,12 +93,10 @@ public class ManagedRedeliverTest extends ManagementTestSupport { from("direct:start") .to("mock:foo") - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - log.info("Invoking me"); + .process(exchange -> { + log.info("Invoking me"); - throw new IllegalArgumentException("Damn"); - } + throw new IllegalArgumentException("Damn"); }).id("myprocessor"); } }; diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteAddFromRouteTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteAddFromRouteTest.java index 3039786..372afab 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteAddFromRouteTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteAddFromRouteTest.java @@ -46,17 +46,14 @@ public class ManagedRouteAddFromRouteTest extends ManagementTestSupport { seda.getQueue().put(new DefaultExchange(context)); from("seda:start").routeId("foo") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - RouteBuilder child = new RouteBuilder() { - @Override - public void configure() throws Exception { - from("seda:bar").routeId("bar").to("mock:bar"); - } - }; - context.addRoutes(child); - } + .process(exchange -> { + RouteBuilder child = new RouteBuilder() { + @Override + public void configure() throws Exception { + from("seda:bar").routeId("bar").to("mock:bar"); + } + }; + context.addRoutes(child); }) .to("mock:result"); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteDirectWhileIssueLeakTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteDirectWhileIssueLeakTest.java index d6c6b04..a06814c 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteDirectWhileIssueLeakTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedRouteDirectWhileIssueLeakTest.java @@ -63,17 +63,14 @@ public class ManagedRouteDirectWhileIssueLeakTest extends ManagementTestSupport public void configure() throws Exception { from("direct:start") .choice().when(simple("${header.counter} > 0")) - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - String body = exchange.getIn().getBody(String.class); - body = "A" + body; - exchange.getIn().setBody(body); + .process(exchange -> { + String body = exchange.getIn().getBody(String.class); + body = "A" + body; + exchange.getIn().setBody(body); - int counter = exchange.getIn().getHeader("counter", int.class); - counter = counter - 1; - exchange.getIn().setHeader("counter", counter); - } + int counter = exchange.getIn().getHeader("counter", int.class); + counter = counter - 1; + exchange.getIn().setHeader("counter", counter); }).to("direct:start") .otherwise() .to("mock:result") diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java index d8b1c4d..1eb49bb 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/ManagedThrottlerTest.java @@ -315,11 +315,8 @@ public class ManagedThrottlerTest extends ManagementTestSupport { from("seda:throttleCountAsyncException") .throttle(1).asyncDelayed().timePeriodMillis(250).id("mythrottler4") .to("mock:endAsyncException") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - throw new RuntimeException("Fail me"); - } + .process(exchange -> { + throw new RuntimeException("Fail me"); }); from("seda:throttleCountRejectExecutionCallerRuns") .onException(RejectedExecutionException.class).to("mock:rejectedExceptionEndpoint1").end() diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/management/MultiInstanceProcessorTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/management/MultiInstanceProcessorTest.java index 4c57f4e..cb31599 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/management/MultiInstanceProcessorTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/management/MultiInstanceProcessorTest.java @@ -35,11 +35,9 @@ public class MultiInstanceProcessorTest extends JmxInstrumentationUsingDefaultsT protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { - from("direct:start").process(new Processor() { - public void process(Exchange exchange) throws Exception { - // simulate a little processing time - Thread.sleep(10); - } + from("direct:start").process(exchange -> { + // simulate a little processing time + Thread.sleep(10); }).to("mock:end").to("mock:end"); } }; diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/processor/NoErrorHandlerTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/processor/NoErrorHandlerTest.java index 6e9e76b..a764bc0 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/processor/NoErrorHandlerTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/processor/NoErrorHandlerTest.java @@ -78,11 +78,9 @@ public class NoErrorHandlerTest extends ContextTestSupport { public void configure() throws Exception { errorHandler(noErrorHandler()); - from("direct:start").process(new Processor() { - public void process(Exchange exchange) throws Exception { - if (++counter < 3) { - throw new IllegalArgumentException("Forced by unit test"); - } + from("direct:start").process(exchange -> { + if (++counter < 3) { + throw new IllegalArgumentException("Forced by unit test"); } }).to("mock:result"); } diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/processor/ReduceStacksNeededDuringRoutingTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/processor/ReduceStacksNeededDuringRoutingTest.java index c262325..8acd2d1 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/processor/ReduceStacksNeededDuringRoutingTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/processor/ReduceStacksNeededDuringRoutingTest.java @@ -51,16 +51,13 @@ public class ReduceStacksNeededDuringRoutingTest extends ContextTestSupport { .to("log:foo") .to("log:bar") .to("log:baz") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - try { - throw new IllegalArgumentException("Forced to dump stacktrace"); - } catch (Exception e) { - e.fillInStackTrace(); - log.info("There are " + e.getStackTrace().length + " lines in the stacktrace"); - log.error("Dump stacktrace to log", e); - } + .process(exchange -> { + try { + throw new IllegalArgumentException("Forced to dump stacktrace"); + } catch (Exception e) { + e.fillInStackTrace(); + log.info("There are " + e.getStackTrace().length + " lines in the stacktrace"); + log.error("Dump stacktrace to log", e); } }) .to("mock:result"); diff --git a/core/camel-management-impl/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java b/core/camel-management-impl/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java index 551d78f..552c4a5 100644 --- a/core/camel-management-impl/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java +++ b/core/camel-management-impl/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithJMXTest.java @@ -56,17 +56,9 @@ public class AsyncEndpointWithJMXTest extends ContextTestSupport { from("direct:start") .to("mock:before") .to("log:before") - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - beforeThreadName = Thread.currentThread().getName(); - } - }) + .process(exchange -> beforeThreadName = Thread.currentThread().getName()) .to("async:bye:camel") - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - afterThreadName = Thread.currentThread().getName(); - } - }) + .process(exchange -> afterThreadName = Thread.currentThread().getName()) .to("log:after") .to("mock:after") .to("mock:result"); @@ -74,4 +66,4 @@ public class AsyncEndpointWithJMXTest extends ContextTestSupport { }; } -} \ No newline at end of file +}
