You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/12/06 17:07:43 UTC
[camel] 04/10: (chores) camel-cxf-spring-soap: replace inner class with lambda
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4aa7945901b449113617056909c7fa9c2a95eff4
Author: Gilvan Filho <gi...@gmail.com>
AuthorDate: Mon Dec 5 20:23:33 2022 -0300
(chores) camel-cxf-spring-soap: replace inner class with lambda
---
.../cxf/spring/jaxws/CxfSpringEndpoint.java | 54 ++++++++++------------
1 file changed, 25 insertions(+), 29 deletions(-)
diff --git a/components/camel-cxf/camel-cxf-spring-soap/src/main/java/org/apache/camel/component/cxf/spring/jaxws/CxfSpringEndpoint.java b/components/camel-cxf/camel-cxf-spring-soap/src/main/java/org/apache/camel/component/cxf/spring/jaxws/CxfSpringEndpoint.java
index 0f2e2a6566b..8eb369b2642 100644
--- a/components/camel-cxf/camel-cxf-spring-soap/src/main/java/org/apache/camel/component/cxf/spring/jaxws/CxfSpringEndpoint.java
+++ b/components/camel-cxf/camel-cxf-spring-soap/src/main/java/org/apache/camel/component/cxf/spring/jaxws/CxfSpringEndpoint.java
@@ -322,39 +322,35 @@ public class CxfSpringEndpoint extends CxfEndpoint implements ApplicationContext
.getBean(AbstractApplicationContext.APPLICATION_EVENT_MULTICASTER_BEAN_NAME,
ApplicationEventMulticaster.class);
aem.removeApplicationListener(cxfSpringBusListener);
- ApplicationListener listener = new ApplicationListener() {
- public void onApplicationEvent(final ApplicationEvent event) {
- new Thread() {
- public void run() {
- if (event instanceof ContextClosedEvent && bus.getState() == BusState.RUNNING) {
-
- try {
- boolean done = false;
- ShutdownStrategy shutdownStrategy = ((DefaultCamelContext) getCamelContext())
- .getShutdownStrategy();
- while (!done && !shutdownStrategy.hasTimeoutOccurred()) {
- int inflight = getCamelContext().getInflightRepository().size();
- if (inflight != 0) {
- Thread.sleep(1000);
- } else {
- done = true;
- }
- }
-
- } catch (Exception e) {
- LOG.debug("Error when enabling SpringBus shutdown gracefully", e);
+ abstractApplicationContext.addApplicationListener((final ApplicationEvent event) -> {
+ new Thread() {
+ public void run() {
+ if (event instanceof ContextClosedEvent && bus.getState() == BusState.RUNNING) {
+
+ try {
+ boolean done = false;
+ ShutdownStrategy shutdownStrategy = ((DefaultCamelContext) getCamelContext())
+ .getShutdownStrategy();
+ while (!done && !shutdownStrategy.hasTimeoutOccurred()) {
+ int inflight = getCamelContext().getInflightRepository().size();
+ if (inflight != 0) {
+ Thread.sleep(1000);
+ } else {
+ done = true;
+ }
}
- springBus.onApplicationEvent(event);
- } else {
- springBus.onApplicationEvent(event);
+
+ } catch (Exception e) {
+ LOG.debug("Error when enabling SpringBus shutdown gracefully", e);
}
+ springBus.onApplicationEvent(event);
+ } else {
+ springBus.onApplicationEvent(event);
}
- }.start();
-
- }
- };
- abstractApplicationContext.addApplicationListener(listener);
+ }
+ }.start();
+ });
}
}