Return-Path: X-Original-To: apmail-camel-users-archive@www.apache.org Delivered-To: apmail-camel-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 840AA10C34 for ; Thu, 5 Dec 2013 10:41:02 +0000 (UTC) Received: (qmail 46207 invoked by uid 500); 5 Dec 2013 10:40:56 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 46164 invoked by uid 500); 5 Dec 2013 10:40:49 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Delivered-To: moderator for users@camel.apache.org Received: (qmail 43997 invoked by uid 99); 5 Dec 2013 10:38:54 -0000 X-ASF-Spam-Status: No, hits=2.5 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,SPF_SOFTFAIL,URI_HEX X-Spam-Check-By: apache.org Received-SPF: softfail (nike.apache.org: transitioning domain of malathig52@gmail.com does not designate 216.139.236.26 as permitted sender) Date: Thu, 5 Dec 2013 02:38:27 -0800 (PST) From: Malathi G To: users@camel.apache.org Message-ID: <1386239907316-5744358.post@n5.nabble.com> Subject: ReplyTo Queue is not getting cleared MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Hi, I am transferring message from one queue to another queue and getting response from ReplyTo queue but after reading message from ReplyTo queue, messages are not getting cleared in ReplyTo queue of weblogic. I am using Weblogic queue. Please help me to correct this issue. *camel code:* CamelContext context = new DefaultCamelContext(); String wlurl = "t3://localhost:7001/console"; String jndiFactory = "weblogic.jndi.WLInitialContextFactory"; Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY,jndiFactory); properties.put(Context.PROVIDER_URL, wlurl); Context jndiContext = new InitialContext(properties); QueueConnectionFactory queueConnectionFactory= (QueueConnectionFactory)jndiContext.lookup("JMSCF"); context.addComponent( "jms", JmsComponent.jmsComponentClientAcknowledge( queueConnectionFactory ) ); context.addRoutes(new RouteBuilder() { public void configure() { from("jms:queue:./JMSResources!Sender_Queue?username=admin&password=polaris123&jmsMessageType=Text") .inOut("jms:queue:./JMSResources!Receiver_Queue?username=admin&password=polaris123&jmsMessageType=Text&replyTo=./JMSResources!ReplyTo_Queue&requestTimeout=100000"); } }); context.start(); while(true) { } *JMS Stud code:* CamelContext context = new DefaultCamelContext(); String wlurl = "t3://localhost:7001/console"; String jndiFactory = "weblogic.jndi.WLInitialContextFactory"; Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY,jndiFactory); properties.put(Context.PROVIDER_URL, wlurl); Context jndiContext = new InitialContext(properties); QueueConnectionFactory queueConnectionFactory= (QueueConnectionFactory)jndiContext.lookup("JMSCF"); context.addComponent( "jms", JmsComponent.jmsComponentClientAcknowledge( queueConnectionFactory ) ); context.addRoutes(new RouteBuilder() { public void configure() { from("jms:queue:./JMSResources!Receiver_Queue?username=admin&password=polaris123&jmsMessageType=Text") .process( new Processor() { @Override public void process( Exchange e )throws Exception{ e.getOut().setBody("Response from LMS"); } } ) .inOnly("jms:queue:./JMSResources!ReplyTo_Queue?username=admin&password=polaris123&jmsMessageType=Text"); } }); context.start(); while(true) { } -- View this message in context: http://camel.465427.n5.nabble.com/ReplyTo-Queue-is-not-getting-cleared-tp5744358.html Sent from the Camel - Users mailing list archive at Nabble.com.