Hi,
I want to create a camel route which consumes messages from an ActiveMQ
topic. There's a firewall between the camel code and the ActiveMQ broker,
the broker can only expose ports 80 and 443. Is it possible to create a
camel route which receives messages from the broker using stomp over
websockets?
The broker has a websocket connector:
BrokerService brokerSvc = new BrokerService();
brokerSvc.setBrokerName("brkr1");
brokerSvc.addConnector("ws://localhost:80?trace=true");
brokerSvc.setPersistent(false);
brokerSvc.start();
For the camel route i have the following code:
StompComponent stompComponent = new StompComponent();
stompComponent.setBrokerURL("ws://localhost:80");
camelContext.addComponent("stomp",stompComponent);
from("stomp:topic:test").
log(LoggingLevel.INFO, "received websocket msg
${id}, ${body}").
setBody(simple("${body.ascii.toString()}")).
to("file:///c:/tmp/to-stomp");
When i run this i get the following error:
...
Caused by: java.lang.Exception: Unsupported URI scheme 'ws'
at org.fusesource.stomp.client.Stomp.connectCallback(Stomp.java:119)
at
org.apache.camel.component.stomp.StompEndpoint.doStart(StompEndpoint.java:73)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
...
Using ActiveMQ 5.8.0 and Camel 2.12.1.
Is this possible at all?
Thanks,
Andrej
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-consuming-from-apache-mq-using-stomp-over-websockets-tp5741476.html
Sent from the Camel - Users mailing list archive at Nabble.com.