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.
