Camel - ActiveMQ

[jdev.hari]

Hi,

I am trying a simple program to read from a queue and handle it. I have
started active mq locally and is running

===========

        try {
            CamelContext context = new DefaultCamelContext();
            context.addComponent("activemq",
                    
ActiveMQComponent.activeMQComponent("tcp://localhost:8161"));
            context.addRoutes(new RouteBuilder() {
                @Override
                public void configure() {
                    from("activemq:queue:TEST").to("file://c:/test");
                }
            });
            context.start();
            while (true) {
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    ===========


I am getting the following error. Any help.

javax.jms.JMSException: Frame size of 1157 MB larger than max allowed 100 MB
        at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
        at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1380)
        at
org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1466)
        at
org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:503)
        at
org.springframework.jms.listener.AbstractJmsListeningContainer.startSharedConnection(AbstractJmsListeningContainer.java:440)
        at
org.springframework.jms.listener.DefaultMessageListenerContainer.startSharedConnection(DefaultMessageListenerContainer.java:764)

I am unable to figure out the issue.



Thanks,




--
View this message in context: 
http://camel.465427.n5.nabble.com/Camel-ActiveMQ-tp5728603.html
Sent from the Camel - Users mailing list archive at Nabble.com.