Hi all,
I am running Qpid C++ on Opensuse 10.2 and CentOS 5.2, then run the command
below
I have tried the command on both sides, same result
qpidc-0.4/python> ./qpid-route -v link add user/p...@192.168.20.133:5672
user/p...@localhost:5672
Exception in thread Thread-1:
Traceback (most recent
I ended up trying what you propose. I had an issue that I didn't know
when I could delete the queue. I ended up sending messages back to
the producer to do the deletion which worked and then it all got very
slow when I added clustering. My requirements have eased a little in
this area and I'm no
Adam Chase wrote:
I am not totally seeing how I can use this to solve my problem.
I am currently sending all my messages to a direct exchange with the
same routing key. (Maybe a mistake). Suppose I had each "group" of
messages have a different routing key. I can't get all the messages
going t
Thanks a lot!
These codes explain everything.
On Thu, Feb 12, 2009 at 12:17 AM, Adam Chase wrote:
> On Wed, Feb 11, 2009 at 10:46 AM, chenta lee wrote:
> > On Wed, Feb 11, 2009 at 10:56 PM, Adam Chase
> wrote:
> >
> >> I have been using this.
> >>
> >> There is a version of connect that can t
On Wed, Feb 11, 2009 at 10:46 AM, chenta lee wrote:
> On Wed, Feb 11, 2009 at 10:56 PM, Adam Chase wrote:
>
>> I have been using this.
>>
>> There is a version of connect that can take a set of qpid servers
>> (urls). You actually end up connecting to one of them.
>>
>
> Do you remember which ve
On Wed, Feb 11, 2009 at 10:56 PM, Adam Chase wrote:
> I have been using this.
>
> There is a version of connect that can take a set of qpid servers
> (urls). You actually end up connecting to one of them.
>
Do you remember which version it is? I know we can specify the broker list
via amqp-url.
I have been using this.
There is a version of connect that can take a set of qpid servers
(urls). You actually end up connecting to one of them.
You need to install openais to do clustering (libraries and configure
it and start aisexec on each server). When qpid is built with cpg
(part of opena
Adam Chase wrote:
The way I am implementing failback using qpid is to release a message
when I detect that the other consumer is available again via a
message.
When I release the message, the other consumer isn't getting it.
If I add some credit to myself I get it again and then the next time
t
Adam Chase wrote:
If I have implemented received and I call messageFlush(sync=true) in
my main thread, received will either complete before messageFlush
completes with a message from that subscription, or I will not get any
more messages from that subscription until I add credit again, right?
O
Adam Chase wrote:
First thank you for all the help you've been giving me, its been
extremely useful.
My question now is about the FailoverManager.
From what I can read, it essentially associates each command with a
session and then if that fails, reconnects you to the failover server
and lets y
I construct a broker cluster and I want to use c++ client to connect it.
I have three questions:
1. How do clients join the cluster? If the client connect to one of the
broker in the cluster, does it also means that it connect to the cluster?
Can I use cluster name to join to cluster?
2. How do I
Adam Chase wrote:
I am talking about the CPP broker. I see there's a flush on the
Session, but not the Subscription.
There are two uses of the term 'flush' in AMQP (and consequently in the
c++ API).
There is the Session::messageFlush() session 'command' which Carl is
referring to that flus
12 matches
Mail list logo
