Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of christian.mueller@gmail.com
 designates 209.85.214.177 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAGO7Ob0iG0KoHZRhs9LvZetJVJKaVBmaJ2nndk6_nckdOHwyrA@mail.gmail.com>
References: <1355100983735-5723805.post@n5.nabble.com>
	<CAKoNANuByh7hqtWTbQ5MSO7xzj=YvWFcfoa=KcgXKBOmKzALRw@mail.gmail.com>
	<1355103804220-5723808.post@n5.nabble.com>
	<CALvzYd8vksn71ijCesGx9pmaok6uG+Uzgjh3U9aO6wBcM4iWfg@mail.gmail.com>
	<CAGB5yNkVY=_UFTGCkSaoFCwe-uYHRfo1KRApMvjqRc_7hcE0vQ@mail.gmail.com>
	<CALvzYd99Jtc=xaqk7wqr+TM6QCuYfkkmUE1T06tFYEuvUw+Z0w@mail.gmail.com>
	<CAGO7Ob0iG0KoHZRhs9LvZetJVJKaVBmaJ2nndk6_nckdOHwyrA@mail.gmail.com>
Date: Wed, 19 Dec 2012 22:36:44 +0100
Message-ID: 
 <CALvzYd_TzeXQwo1bLA4a=5+bdt5EemPpw2LuG-DOAoNnDBr_OA@mail.gmail.com>
Subject: Re: JMS persistence options have no effect
From: =?ISO-8859-1?Q?Christian_M=FCller?= <christian.mueller@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=e89a8f9240782ef61104d13b69ff

--e89a8f9240782ef61104d13b69ff
Content-Type: text/plain; charset=ISO-8859-1

Thanks David!

I updated the example and set "explicitQosEnabled" on both endpoint
configurations. Now it works as expected! Thanks!

@Brad: I hope this will also solve your issue.

import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.camel.component.ActiveMQComponent;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.JndiRegistry;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

public class CamelActiveMQConsumerPersistentIssueTest extends
CamelTestSupport {

    private BrokerService broker;

    @Before
    public void setUp() throws Exception {
        broker = new BrokerService();
        broker.setPersistent(true);
        broker.setUseJmx(false);
        broker.addConnector("tcp://localhost:61616");
        broker.start();

        super.setUp();
    }

    @After
    public void tearDown() throws Exception {
        super.tearDown();

        broker.stop();
    }

    @Test
    public void test() throws Exception {
        // 1 = NON_PERSISTENT
        // 2 = PERSISTENT

        context.addRoutes(new RouteBuilder() {
            public void configure() throws Exception {

from("activemq:queue:test?replyToDeliveryPersistent=false&explicitQosEnabled=true")
                    .process(new Processor() {
                        public void process(Exchange exchange) throws
Exception {
                            assertEquals(Integer.valueOf(1),
exchange.getIn().getHeader("JMSDeliveryMode", Integer.class));
                            exchange.getOut().setBody("Camel");
                        }
                    });
            }
        });

        Exchange ex =
template.request("activemq:queue:test?deliveryPersistent=false&explicitQosEnabled=true",
new Processor() {
            public void process(Exchange exchange) throws Exception {
                exchange.getIn().setBody("What's the best integration
framework?");
            }
        });

        assertEquals("Camel", ex.getOut().getBody(String.class));
        assertEquals(Integer.valueOf(1),
ex.getOut().getHeader("JMSDeliveryMode", Integer.class));
    }

    @Override
    protected JndiRegistry createRegistry() throws Exception {
        JndiRegistry registry = super.createRegistry();
        registry.bind("activemq",
ActiveMQComponent.activeMQComponent("failover:(tcp://localhost:61616)"));
        return registry;
    }
}

Best,
Christian

On Mon, Dec 17, 2012 at 6:55 PM, David Karlsen <davidkarlsen@gmail.com>wrote:

> explicitQos


--

--e89a8f9240782ef61104d13b69ff--