Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
Received-SPF: pass (athena.apache.org: local policy)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
  s=s1024; d=yahoo.com;
  h=Message-ID:X-YMail-OSG:Received:X-Mailer:Date:From:Subject:To:MIME-Version:Content-Type;
  b=hTVXQbFXPJBY6VcZwFGzgfWnjzqDNliQP+H/obp6qhukacxVpqmJW4Aiv2MhujEZYxhWYACXEDyLkto8eW+6ac6JCMpJj0Lc7Dphk877+QpkdWoD3lgU20NL3xZ0+tsLB1F9BV0LvYVtTe9zPvzRyaEIkOIj1hMOST/5SNAxXuA=;
Message-ID: <905112.77384.qm@web46110.mail.sp1.yahoo.com>
Date: Tue, 14 Jul 2009 08:52:40 -0700 (PDT)
From: Nithesh Shetty <knitheshshetty@yahoo.com>
Subject: Re: localqueue get
To: users@qpid.apache.org
MIME-Version: 1.0
Content-Type: multipart/alternative; boundary="0-900588554-1247586760=:77384"

--0-900588554-1247586760=:77384
Content-Type: text/plain; charset=iso-8859-1
Content-Transfer-Encoding: quoted-printable


Hi,
the listener sample has the following settings;
=A0SubscriptionManager subscriptions(session);
=A0SubscriptionSettings settings;=0A=A0settings.exclusive =3D false;=0A=A0s=
etting.flowControl =3D FlowControl::messageWindow(1);
=A0settings.acceptMode =3D ACCEPT_MODE_EXPLICIT;=0A=A0settings.acquireMode =
=3D ACQUIRE_MODE_PRE_ACQUIRED;
=A0LocalQueue local_queue;
=A0subscriptions.subscribe(local_queue, "RMS", settings, "rmsset");
Message message;local_queue.get(message, 10);
Now even after the depth of queue is more than 20 i have experiencedthat ge=
t gives an exception saying queue is empty is there any particular=A0reason=
 for that or again any change in the configuration.
Awaiting your reply.
Regards,
Nithesh
=0A


--- On Mon, 7/13/09, Nithesh Shetty <knitheshshetty@yahoo.com> wrote:
=0A
From: Nithesh Shetty <knitheshshetty@yahoo.com>
Subject: Re: localqueue get
To: users@qpid.apache.org
Date: Monday, July 13, 2009, 1:14 PM

=0Ahi,
=A0
=A0the listener sample has the following settings;
=A0SubscriptionManager subscriptions(session);
=A0SubscriptionSettings settings;
=A0settings.acceptMode =3D ACCEPT_MODE_EXP;
=A0settings.acquireMode =3D ACQUIRE_MODE_PRE_ACQUIRED;
=A0LocalQueue local_queue;
=A0subscriptions.subscribe(local_queue, "RMS", settings, "rmsset");
=A0 Message message =3D local_queue.get();

=A0
before getting the message i=A0put=A0a breakpoint over here and=A0i execute=
 another exe to get the message(timeout infinity) but it hangs=A0 till the =
above code gets the message and closes the connection.
=A0
Awaiting your reply.
=A0
Nithesh

=A0
=A0


--- On Mon, 7/13/09, Gordon Sim <gsim@redhat.com> wrote:


From: Gordon Sim=0A <gsim@redhat.com>
Subject: Re: localqueue get
To: users@qpid.apache.org
Date: Monday, July 13, 2009, 11:34 AM


Nithesh Shetty wrote:
> the listener sample has the following settings;
> SubscriptionManager subscriptions(session);
> SubscriptionSettings settings;
> settings.acceptMode =3D ACCEPT_MODE_NONE;
> settings.acquireMode =3D ACQUIRE_MODE_PRE_ACQUIRED;
> LocalQueue local_queue;
> subscriptions.subscribe(local_queue, "RMS", settings, "rmsset");
>=A0 Message message =3D local_queue.get();
>=A0 %%%%%%%%%%%%%%%%%%%%%%%%%%%%%
>=A0 now the problem is if i put ten message in the queue and get one messa=
ge and then close
> the connection the=0A rest of the nine message gets dequeued...

ACCEPT_MODE_NONE means that the broker will dequeue the message as soon as =
it is delivered. As you are using the default flow control settings for you=
r client, the broker will send as many messages to the client as it can, re=
gardless of whether the client application has received the earlier message=
s.

If you want the transfer from broker to subscribers to be reliable, use ACC=
EPT_MODE_EXPLICIT.


---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:=A0 =A0 =A0 http://qpid.apache.org
Use/Interact: mailto:users-subscribe@qpid.apache.org


=A0 =A0 =A0 =0A=0A=0A      
--0-900588554-1247586760=:77384--