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.

Reply via email to