Return-Path: 
 <users-return-14483-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
Delivered-To: apmail-camel-users-archive@www.apache.org
Received: (qmail 5393 invoked from network); 12 Jul 2010 05:52:15 -0000
Received: from unknown (HELO mail.apache.org) (140.211.11.3)
  by 140.211.11.9 with SMTP; 12 Jul 2010 05:52:15 -0000
Received: (qmail 29719 invoked by uid 500); 12 Jul 2010 05:52:15 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 29615 invoked by uid 500); 12 Jul 2010 05:52:13 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Received: (qmail 29607 invoked by uid 99); 12 Jul 2010 05:52:12 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Jul 2010 05:52:12 +0000
X-ASF-Spam-Status: No, hits=1.3 required=10.0
	tests=FREEMAIL_FROM,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of claus.ibsen@gmail.com
 designates 74.125.82.51 as permitted sender)
Received: from [74.125.82.51] (HELO mail-ww0-f51.google.com) (74.125.82.51)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Jul 2010 05:52:06 +0000
Received: by wwc33 with SMTP id 33so471769wwc.20
        for <users@camel.apache.org>; Sun, 11 Jul 2010 22:51:46 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=gamma;
        h=domainkey-signature:received:mime-version:received:in-reply-to
         :references:from:date:message-id:subject:to:content-type
         :content-transfer-encoding;
        bh=eMuYhuABk49TgJpA8miRC2iLilesgPz26KPmRM/To4o=;
        b=IjccqDbziA9o6Heqls7C29IMv19vllWcwTUEggfyW43HiZMhfzKc8m5GWinlPEdXb3
         C+b0RDi36bMZC2IvXjplWW7W3hkwlGoKfcBtKqPA/IG3biV3S/ayeRGcTH6DaMBKJw6t
         W7Pams2+CmooPbtJgHOAFjWmCQj9eHc31bVYk=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=SzNYlVRdPixsr0vsC0zkgLhEJRR0PQGS8zwFq1nSmzRKufftlb6N3tfkYA/AqrXq2V
         7NKxYaXP9wlh90kflDkkQuKBKhcuuBkBrHpY6ZH1wnkWilT2mNkHguTax32kICk1BAkP
         flkUtRJ3xrkpV5MjdkpSAy6+3OkGKmfmY8vbY=
Received: by 10.227.136.81 with SMTP id q17mr12077934wbt.207.1278913906147;
	Sun, 11 Jul 2010 22:51:46 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.216.230.16 with HTTP; Sun, 11 Jul 2010 22:51:26 -0700 (PDT)
In-Reply-To: <1278858361056-1046084.post@n5.nabble.com>
References: <1278858361056-1046084.post@n5.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Mon, 12 Jul 2010 07:51:26 +0200
Message-ID: <AANLkTilo1g6-jL7HLL-M-TKffoxLe2VDnQ0RMpgiibIZ@mail.gmail.com>
Subject: Re: Oracle AQ Topic dequeue options and Apache Camel
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable
X-Virus-Checked: Checked by ClamAV on apache.org

On Sun, Jul 11, 2010 at 4:26 PM, impi <melissa.palmer@gmail.com> wrote:
>
> I would like to know if its possible to set the Oracle AQ dequeue options=
 for
> a topic (multiconsumer queue).
>
> I'm trying to set the following in the Camel Spring XML config:
> AQDequeueOptions deqopt =3D new AQDequeueOptions();
> deqopt.setRetrieveMessageId(true);
> deqopt.setConsumerName(consumerName);
>
> I have the following setup already:
> =A0<bean id=3D"topicConnectionFactory" class=3D"oracle.jms.AQjmsFactory"
> factory-method=3D"getTopicConnectionFactory">
> =A0 =A0 =A0 =A0<constructor-arg index=3D"0" value=3D"${topic.db.url}" />
> =A0 =A0 =A0 =A0<constructor-arg index=3D"1" type=3D"java.util.Properties"=
 value=3D"" />
> =A0 =A0</bean>
>
> <bean id=3D"authenticatedTopicConnectionFactory"
> class=3D"org.springframework.jms.connection.UserCredentialsConnectionFact=
oryAdapter">
> =A0 =A0 =A0 =A0<property name=3D"targetConnectionFactory"
> ref=3D"topicConnectionFactory" />
> =A0 =A0 =A0 =A0<property name=3D"username" value=3D"${topic.dbusername}" =
/>
> =A0 =A0 =A0 =A0<property name=3D"password" value=3D"${topic.db.password}"=
 />
> =A0 =A0</bean>
>
> <bean id=3D"topicConnection"
> class=3D"org.apache.camel.component.jms.JmsComponent">
> =A0 =A0 =A0 =A0<property name=3D"connectionFactory"
> ref=3D"authenticatedTopicConnectionFactory" />
> =A0 =A0</bean>
>
>
> This works and makes the connection to a topic and you can receive messag=
es
> from the topic HOWEVER its not possible to get those messages that where
> sent before you started subscribing. (those messages that were meant for
> your consumption).
>

Usually a topic can be set to either deliver only new messages which
arrives after the consumer connected.
Or also old messages. You most likely need to define the consumers as
persistent, which then allows the AQ to store
the messages to the consumer, so they can be delivered when the
consumer comes online.

I think you need to ask on the OracleAQ support about this.


> --
> View this message in context: http://camel.465427.n5.nabble.com/Oracle-AQ=
-Topic-dequeue-options-and-Apache-Camel-tp1046084p1046084.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



--=20
Claus Ibsen
Apache Camel Committer

Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus