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 <[email protected]>
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"));
}