This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new 531fde8 Fixed test 531fde8 is described below commit 531fde850ba539397fb90dd37649ac5f5a60fef1 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sat Mar 28 17:42:03 2020 +0100 Fixed test --- .../main/java/org/apache/camel/component/stomp/StompComponent.java | 5 +++-- .../org/apache/camel/component/stomp/StompCustomHeadersTest.java | 5 ++++- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java index 5e51760..5587359 100644 --- a/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java +++ b/components/camel-stomp/src/main/java/org/apache/camel/component/stomp/StompComponent.java @@ -39,9 +39,10 @@ public class StompComponent extends HeaderFilterStrategyComponent implements SSL // Implementation methods // ------------------------------------------------------------------------- + @Override - protected void doStart() throws Exception { - super.doStart(); + protected void doInit() throws Exception { + super.doInit(); if (getHeaderFilterStrategy() == null) { setHeaderFilterStrategy(new DefaultHeaderFilterStrategy()); } diff --git a/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompCustomHeadersTest.java b/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompCustomHeadersTest.java index d9c25d7..05e093f 100644 --- a/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompCustomHeadersTest.java +++ b/components/camel-stomp/src/test/java/org/apache/camel/component/stomp/StompCustomHeadersTest.java @@ -38,7 +38,10 @@ public class StompCustomHeadersTest extends StompBaseTest { props.setProperty("ack", "auto"); map.put("customHeaders", props); - + + // ensure component is initialized + context.getComponent("stomp").init(); + StompEndpoint endpoint = (StompEndpoint) context.getEndpoint("stomp:test", map); assertNotNull(endpoint.getConfiguration().getCustomHeaders().getProperty("ack")); }