You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Malathi G <ma...@gmail.com> on 2013/12/05 11:38:27 UTC
ReplyTo Queue is not getting cleared
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.