Hi I think the protocol in camel-stomp should be defined as tcp. http://camel.apache.org/stomp
On Sun, Oct 13, 2013 at 4:52 PM, ako <[email protected]> wrote: > 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. -- Claus Ibsen ----------------- Red Hat, Inc. Email: [email protected] Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
