package won.protocol.jms;

import org.apache.camel.component.jms.JmsConfiguration;

import javax.jms.ConnectionFactory;

/**
 * User: LEIH-NB
 * Date: 28.04.14
 */
public class WonJmsConfiguration extends JmsConfiguration
{
  public WonJmsConfiguration(ConnectionFactory connectionFactory){
    super(connectionFactory);
    configureDefaultJmsConfiguration();
  }
  public void configureDefaultJmsConfiguration(){
    setTimeToLive(0);
    setDisableTimeToLive(true);
    setRequestTimeout(0);
  }

  public void configureJmsConfigurationForQueues(){
    setConcurrentConsumers(5);
  }

  public void configureJmsConfigurationForTopics(){

  }

}

@@ -20,16 +20,53 @@
 l.jms;%0A%0A
+import javax.jms.ConnectionFactory;%0A%0A
 import o
@@ -117,36 +117,56 @@
 on;%0A
-%0A
 import 
-javax.jms.Connection
+org.slf4j.Logger;%0Aimport org.slf4j.Logger
 Fact
@@ -274,16 +274,88 @@
 ation%0A%7B%0A
+  private final Logger logger = LoggerFactory.getLogger(getClass());%0A  %0A
   public
@@ -483,16 +483,21 @@
 tion();%0A
+    %0A
   %7D%0A  pu
@@ -622,16 +622,215 @@
 out(0);%0A
+    setAsyncConsumer(true);%0A    setDeliveryPersistent(false);%0A    setDisableReplyTo(true);%0A    setTimeToLive(5000);%0A    setTransacted(false);%0A    logger.info(%22default jms configuration setup done%22);%0A
   %7D%0A%0A  p

Change activemq settings