Hi Group, I am trying to send a message to activeMQ broker via Camel. However, I am getting a "Maximum protocol buffer length exeeded" exception. Not sure what I am doing wrong. I am able to send STOMP messages using spring's JmsTemplate directly.
Broker Configuration (embedded): ===================== //Create a new broker // final BrokerService broker = new BrokerService(); //Create the network connector // final TransportConnector tcpConnector = broker.addConnector("tcp://0.0.0.0:61613), stompConnector = broker.addConnector("stomp:0.0.0.0:61623), wsConnector = broker.addConnector("ws://0.0.0.0:61633"); broker.start(); Camel Spring Wiring ========================= <bean class="org.apache.camel.component.stomp.StompComponent"> <property name="brokerURL" value="tcp://localhost:61613" /> </bean> <camel:camelContext> <camel:route> <camel:from uri="direct:sample/engine/user" /> <camel:to uri="stomp:topic/dm6" /> </camel:route> </camel:camelContext> Producer: ================================= interface _Producer { void onUserEarningEvent(UserEarningEvent e); } @Component public class UserEventProducer implements _Producer { @Produce(uri = "direct:sample/engine/user") private _Producer producer; @Override public void onUserEarningEvent(final UserEarningEvent e) { producer.onUserEarningEvent(e); } } Exception: The maximum command length was exceeded ========================================= org.apache.camel.FailedToCreateRouteException: Failed to create route route1 at: >>> To[stomp:queue:dm6] <<< in route: Route(route1)[[From[direct:gozing/engine/user]] -> [To[stomp... because of Failed to resolve endpoint: stomp://queue:dm6 due to: The maximum command length was exceeded at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:912) at org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:177) at org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:770) at org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:1914) at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1670) at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1544) at org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:179) at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61) at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1512) at org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:228) at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:118) Caused by: java.net.ProtocolException: The maximum command length was exceeded at org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.readUntil(AbstractProtocolCodec.java:386) at org.fusesource.stomp.codec.StompProtocolCodec.access$000(StompProtocolCodec.java:29) at org.fusesource.stomp.codec.StompProtocolCodec$1.apply(StompProtocolCodec.java:56) at org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.read(AbstractProtocolCodec.java:355) at org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:656) at org.fusesource.hawtdispatch.transport.TcpTransport$6.run(TcpTransport.java:538) at org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:209) at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100) at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77) Does anyone has any ideas what may be wrong? Also, not sure where the source code for camel-stomp module is located. Thanks for any help... -AP_ -- View this message in context: http://camel.465427.n5.nabble.com/STOMP-Exception-The-maximum-command-length-was-exceeded-tp5738017.html Sent from the Camel - Users mailing list archive at Nabble.com.