Hi,
When
qpid-0.8 was release we had created a wrapper on the api
provided
Session.exchangeDeclare(arg::exchange,
arg::exclusive, arg::durable, arg::autoDelete,
arg::type);
Session.queueDeclare(arg::queue, arg::exclusive,
arg::durable, arg::autoDelete,
id 0.8 queries
> To: users@qpid.apache.org
> Date: Tuesday, July 19, 2011, 11:52 AM
> On 07/19/2011 12:34 PM, Nithesh
> Shetty wrote:
> > /usr/include/db.h
> > /usr/include/db4
> > /usr/include/db4/db.h
> > /usr/include/db4/db_185.h
> > /usr/include/db4/db_
uesday, July 19, 2011, 10:41 AM
> On 07/19/2011 11:29 AM, Nithesh
> Shetty wrote:
> > db4-devel-4.3.29-9.fc6
>
> That seems odd, I would expect db4-devel-4.3.29-10.el5_5.2
> for the platform specified.
>
> What does
db4-devel-4.3.29-9.fc6
--- On Tue, 7/19/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Tuesday, July 19, 2011, 10:12 AM
> On 07/19/2011 10:24 AM, Nithesh
> Shetty wrote:
> >
> > Red Hat Endterprise L
id 0.8 queries
> To: users@qpid.apache.org
> Date: Tuesday, July 19, 2011, 8:26 AM
> On 07/19/2011 08:32 AM, Nithesh
> Shetty wrote:
> > ./configure gives error saying
> > ...
> > checking for db_cxx.h... no
> > configure: error: db4-devel package missing. Please
>
awaiting your reply
--- On Mon, 7/18/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Monday, July 18, 2011, 2:44 PM
> On 07/18/2011 03:28 PM, Nithesh
> Shetty wrote:
> > there are two source code folders
>
> To: users@qpid.apache.org
> Date: Monday, July 18, 2011, 2:44 PM
> On 07/18/2011 03:28 PM, Nithesh
> Shetty wrote:
> > there are two source code folders
> >
> > 1. actual qpid0.10 from where i built the broker
> > 2. http://anonsvn.jboss.org/repos/rhmessaging
build msgstore.so to make my broker support persistant queue
i am total confused here
--- On Mon, 7/18/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Monday, July 18, 2011, 2:17 PM
> On 07/18/2011 03:00 PM, Nithesh
--- On Mon, 7/18/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Monday, July 18, 2011, 1:53 PM
> On 07/18/2011 02:51 PM, Nithesh
> Shetty wrote:
> >
> >> Do you have a persistence plugin installed
/trunk/cpp
or is there any other way
--- On Tue, 7/12/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Tuesday, July 12, 2011, 12:02 PM
> On 07/12/2011 07:26 AM, Nithesh
> Shetty wrote:
> > MQ has a option of ge
> and we can reach to the starting point. if there is
> possibility of doing so please let me know.
i meant to say is there any way to iterate through the message queue to and fro.
--- On Thu, 7/14/11, Nithesh Shetty wrote:
> From: Nithesh Shetty
> Subject: Re: qpid 0.8 queries
can also browse the queue to non-destructively read
> messages, instead of draining the queue. See e.g.
> http://docs.redhat.com/docs/en-US/Red_Hat_Enterprise_MRG/1.3/html-single/Programming_in_Apache_Qpid/index.html,
> section "2.4.3.3. browse".
>
>
> Kind rega
ay, July 13, 2011, 10:57 AM
> On 07/13/2011 05:36 AM, Nithesh
> Shetty wrote:
> > My requirement is
> > when i browse a msg in a queue it should return
> me unique msg id.
> >
> > and if i successfully process the msg received from
> the queue then
> > i re
again with the current msg id.
there is no function for that stuck again
--- On Wed, 7/13/11, Nithesh Shetty wrote:
> From: Nithesh Shetty
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Wednesday, July 13, 2011, 4:36 AM
> Hi,
>
> My requirement is
> w
n 07/12/2011 01:50 PM, Nithesh
> Shetty wrote:
> > But can i check the message id of message is the
> localqueue and then match with my message id and it they
> match then read...
> >
> > Some way through messageproperties or messageheader.
>
> You can check the
To: users@qpid.apache.org
> Date: Tuesday, July 12, 2011, 12:41 PM
> On 07/12/2011 01:22 PM, Nithesh
> Shetty wrote:
> > yes m using c++ qpid.messaging API?
>
> Then its easy enough to set the ID:
>
> import
>
> using qpid::types::Uuid;
> ...
> message.setMessageId(Uui
yes m using c++ qpid.messaging API?
--- On Tue, 7/12/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Tuesday, July 12, 2011, 12:16 PM
> On 07/12/2011 01:14 PM, Nithesh
> Shetty wrote:
> > I am using C++ Bro
--- On Tue, 7/12/11, Gordon Sim wrote:
> From: Gordon Sim
> Subject: Re: qpid 0.8 queries
> To: users@qpid.apache.org
> Date: Tuesday, July 12, 2011, 12:02 PM
> On 07/12/2011 07:26 AM, Nithesh
> Shetty wrote:
> > MQ has a option of generating unique message i
Hi,I have been usign Websphere MQ for messaging
in Linux.MQ has a option of generating unique message id for all the
messages inserted in the queue.and we can retrieve those messages from the
queue using the messageId.I have checked MessageProperties structure in
qpid. it has a field called mes
Hi,
I am using QPID 8 trying to get message by id .
Hope it has been implementated. and can u please give me the link of
the example to get message id.
Regards,
Nithesh
--- On Fri, 8/14/09, Marnie McCormack wrote:
> From: Marnie McCormack
> Subject: Re: get message by correlationId
> To: us
Hi
make in ruby gives me error
cqpid.cpp: In function 'VALUE SWIG_Ruby_NewPointerObj(void*, swig_type_info*,
int)':
cqpid.cpp:1306: error: 'struct RString' has no member named 'ptr'
Awaiting you reply,
Nithesh
-
Apache Qpid
t << error.what() << std::endl;
}
return 1;
}
If i comment /* Message message; ***/ in the above code it works fine
if i uncomment it then the program hangs at exchangeDeclare. it hangs even at
queueDeclare
if i comment exchangeDeclare
Awaiting your reply to proce
in Future.cpp
void Future::wait(SessionImpl& session)
{
if (!complete)
{
}
}
--- On Thu, 9/24/09, Nithesh Shetty wrote:
From: Nithesh Shetty
Subject: Re: exchangeDeclare funtion hangs
To: users@qpid.apache.org
Date: Thursday, September 24, 2009, 5:26 AM
qpidclient test
id.apache.org
Date: Wednesday, September 23, 2009, 7:38 PM
On 09/23/2009 01:48 PM, Nithesh Shetty wrote:
> Hi,
>
> Version is qpid0.5
Can you run pstack against both the client and qpidd processes at the
point of the hang?
>
> I have created a class called CMessageQueue
> it ha
h
--- On Wed, 9/23/09, Steve Huston wrote:
From: Steve Huston
Subject: RE: exchangeDeclare funtion hangs
To: users@qpid.apache.org
Date: Wednesday, September 23, 2009, 12:20 PM
Hi Nitesh,
What version of Qpid do you see this problem in? Could you post a
small test program that reproduces this?
Hi,
When I try to declare exchange using
Session.exchangeDeclare(arg::exchange = "NAME", arg::exclusive = false,
arg::autoDelete = false, arg::type = "direct");
it hangs in
VOID Condition::wait(Mutex& mutex)
{
QPID_POSIX_ASSERT_THROW_IF(pthread_cond_destroy(&condition));
}
Need help
your reply.
regards,
Nithesh
--- On Fri, 7/17/09, Nithesh Shetty wrote:
From: Nithesh Shetty
Subject: Async get
To: users@qpid.apache.org
Date: Friday, July 17, 2009, 10:08 AM
Hi
I have created three thread two threads read asynchronoulsy from the queue and
one thread writes to the
dException'
what() : not attached: Session guest.4578c63b-0089-48bf-8c26-76d0afd78f8b isn;t
attached (qpid/client/SessionImpl.cpp:736)
Aborted (core dumped)
Awaiting your reply.
regards,
Nithesh
--- On Fri, 7/17/09, Nithesh Shetty wrote:
From: Nithesh Shetty
Subject: Asyn
Hi
I have created three thread two threads read asynchronoulsy from the queue and
one thread writes to the queue..
below is the code.
class listener : public MesageListener
{
// constructor
// received function;
};
unsigned int __stdcall ReadThreadProc(void *)
{
const char* host = "
Date: Wednesday, July 15, 2009, 1:05 PM
Nithesh Shetty wrote:
> Hi,
> I have created a thread where i
> open connection to broker and create a localqueue with the below
> configuration
> SubscriptionManager subscriptions(session);
> SubscriptionSettings settings;
>
Hi,
I have created a thread where i
open connection to broker
and create a localqueue with the below configuration
SubscriptionManager subscriptions(session);
SubscriptionSettings settings;
settings.exclusive = false;
setting.flowControl = FlowControl::messageWindow(1);
settings.acce
Hi,
the listener sample has the following settings;
SubscriptionManager subscriptions(session);
SubscriptionSettings settings;
settings.exclusive = false;
setting.flowControl = FlowControl::messageWindow(1);
settings.acceptMode = ACCEPT_MODE_EXPLICIT;
settings.acquireMode = ACQUIRE_MO
ny particular reason for
that or again any change in the configuration.
Awaiting your reply.
Regards,
Nithesh
--- On Mon, 7/13/09, Nithesh Shetty wrote:
From: Nithesh Shetty
Subject: Re: localqueue get
To: users@qpid.apache.org
Date: Monday, July 13, 2009, 1:14 PM
hi,
the listener samp
our reply.
Nithesh
--- On Mon, 7/13/09, Gordon Sim wrote:
From: Gordon Sim
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);
>
Hi
I have created a producer=A0sample with the following option:
QueueOptions queueOptions;
queueOptions.setOrdering(FIFO);
session.exchangeDeclare(arg::exchange="QM", arg::exclusive = false,
arg::autoDelete = false, arg::type = "direct");
session.queueDeclare(arg::queue="RMS", arg::exclusive = f
@qpid.apache.org
Date: Wednesday, July 8, 2009, 12:24 PM
Nithesh Shetty wrote:
> Hi,
> I there any way to change the acquiremode of a localqueue after subscribing
>the queue to subscriptionManager . I mean SubscriptionSettings settings;
> settings.acquiremode = ACQUIRE_MODE
Hi,
I there any way to change the acquiremode of a localqueue after subscribing
the queue to subscriptionManager . I mean
SubscriptionSettings settings;
settings.acquiremode = ACQUIRE_MODE_PRE_ACQUIRE.
LocalQueue local_queue;
then u call subscribe(local_queue, queuename, settings);
now if i
hi,
I have implemented a reader class to asynchronously received msg from the
broker.
For that i have derived from MessageListener and implemented the receive
function.
to start recived i have called subscriptionManager run function but
the control of the program doesn't return from the run
