Re: Increasing number of messages normal?

2013-09-12 Thread Christian Fromme
Hi Gordon, thanks again for your quick reply. On Thu, Sep 12, 2013 at 11:25 AM, Gordon Sim wrote: > I think the drops are caused by management events. The broker will generate > events and route them to the management exchanges. However if there is > no-one subscribed to receive those events, t

Re: Increasing number of messages normal?

2013-09-12 Thread Christian Fromme
Hi Gordon, thanks for your quick reply. On Wed, Sep 11, 2013 at 5:33 PM, Gordon Sim wrote: >>qmf.default.topic topic1 44.3k 15344.1k 0 >>qpid.management topic0 44.1k 044.1k 0 >> > No, its not the heartbeats, it looks like it is f

Increasing number of messages normal?

2013-09-11 Thread Christian Fromme
Hello list, I just noticed that the Qpid daemon gives me increasing numbers of messages being sent when using `qpid-stat -g`: Statistic Messages Bytes === queue-depth 0 0 total-enqueues 80

Re: Dead Link on Proton website

2013-09-09 Thread Christian Fromme
On Mon, Sep 9, 2013 at 11:36 AM, Christian Fromme wrote: > just a heads up for everybody: A link on > > http://qpid.apache.org/releases/qpid-proton-0.4/index.html > > saying "More about Qpid Proton." points to a local file: > > file:///home/jross/transom/output/pr

Dead Link on Proton website

2013-09-09 Thread Christian Fromme
Hi, just a heads up for everybody: A link on http://qpid.apache.org/releases/qpid-proton-0.4/index.html saying "More about Qpid Proton." points to a local file: file:///home/jross/transom/output/proton/index.html Best, Christian

Re: Qpid hanging in qpid::messaging::createSession()?

2013-06-21 Thread Christian Fromme
Hi Gordon, thanks for your quick reply. On Fri, Jun 21, 2013 at 2:41 PM, Gordon Sim wrote: >> When the qpidd vanishes during a client calling this: >> >> Connection connection(url, connection_options); > You need a connection.open() here. Oops. That's right. I wonder why it worked wh

Qpid hanging in qpid::messaging::createSession()?

2013-06-21 Thread Christian Fromme
Hi, playing around with Qpid this got my attention: When the qpidd vanishes during a client calling this: Connection connection(url, connection_options); Session session = connection.createSession(); Sender sender = session.createSender(foo); I get this in the client: #

Re: Is the class Receiver in QPID thread safe

2013-06-17 Thread Christian Fromme
Hi Rajesh, On Mon, Jun 17, 2013 at 1:42 AM, Rajesh Khan wrote: >void SomeClass::SomeMethod() > { > connection = boost::make_shared ("127.0.0.1"); > connection->open(); > session = boost::make_shared > (connection->createSession());

Re: MessageStore.h missing?

2013-05-24 Thread Christian Fromme
Hi Gordon, thanks for your answer. On Thu, May 23, 2013 at 2:55 PM, Gordon Sim wrote: > The situation with that store plugin has been a little messy. In reality > there isn't a clean interface between the broker and the store and the store > is in effect just another part of the broker codebase

Re: A second restart of slave leaves it in catchup state

2013-05-22 Thread Christian Fromme
On Wed, May 22, 2013 at 7:59 PM, Alan Conway wrote: >> Seems like I had my expectations wrong. We actually have a cluster >> resource manager that I can use. Thanks! > > Out of curiosity - what cluster resource manager are you using? I'd be > interested in hearing about your experience integratin

Re: Durable subscriptions in C++ API?

2013-05-22 Thread Christian Fromme
Hi Gordon, On Wed, May 22, 2013 at 4:54 PM, Christian Fromme wrote: > On Wed, May 22, 2013 at 4:16 PM, Gordon Sim wrote: > >> First, I would not advise you to start developing against the qpid::client >> API as it is old, AMQP 0-10 specific and more complicated to use. Inst

Re: Durable subscriptions in C++ API?

2013-05-22 Thread Christian Fromme
On Wed, May 22, 2013 at 4:16 PM, Gordon Sim wrote: > First, I would not advise you to start developing against the qpid::client > API as it is old, AMQP 0-10 specific and more complicated to use. Instead > look at the qpid::messaging API. > > In qpid::messaging you subscribe by creating a receive

Durable subscriptions in C++ API?

2013-05-22 Thread Christian Fromme
Hello Qpid users, I am wondering if there is a way to make subscriptions ("push queues") durable via the C++ API. With "durable", I mean: 1. Process foo subscribes for messages using SubscriptionManager implementing MessageListener to broker x 2. Broker x restarts at some point. 3. Process foo do

Re: MessageStore.h missing?

2013-05-22 Thread Christian Fromme
On Wed, May 22, 2013 at 1:36 PM, Christian Fromme wrote: > Greetings Qpid-users, > > I'm trying to build the Message Store of qpidcomponents.org[0] from > source. Even though I have a working Qpid 0.20 installation on the > system, the configure run complains about a mi

MessageStore.h missing?

2013-05-22 Thread Christian Fromme
Greetings Qpid-users, I'm trying to build the Message Store of qpidcomponents.org[0] from source. Even though I have a working Qpid 0.20 installation on the system, the configure run complains about a missing MessageStore.h header file. I've build a Qpid 0.20 from source, installed to local `/opt

Re: Add route via C++ API?

2013-05-21 Thread Christian Fromme
On Tue, May 21, 2013 at 1:43 PM, Gordon Sim wrote: >> Is there an exhaustive list of exceptions/error codes and what they >> mean? I've looked in the QMF Map Message Protocol[0], but didn't find >> it there. >> >> Also, a list of requests (types?) would be very handy. (Requesting a >> list of exi

Re: [c++] Error while building qpid 0.20 from source distribution

2013-05-21 Thread Christian Fromme
Hi, On Tue, May 21, 2013 at 12:54 PM, pela wrote: > I'm trying to build qpid c++ from 0.20 source distribution but I get the > following error: > > In file included from > /home/users/mpelagatti/qpid/qpidc-0.20/src/qpid/UrlArray.cpp:23: > /home/users/mpelagatti/qpid/qpidc-0.20/src/../include/qpi

Re: Add route via C++ API?

2013-05-21 Thread Christian Fromme
On Fri, May 17, 2013 at 4:29 PM, Gordon Sim wrote: >> When adding links or bridges, is it possible to check beforehand >> whether or not they already exist? >> Currently I get: "{error_code:7, error_text:object already exists: >> mylink-1}" > > > You can get send a request for a list of all links

Re: Add route via C++ API?

2013-05-17 Thread Christian Fromme
On Fri, May 17, 2013 at 2:37 PM, Gordon Sim wrote: > The full ist of properties for a bridge are "src", "dest", "key", "tag", > "excludes", "srcIsQueue", "srcIsLocal", "dynamic", "sync" and > "credit" When adding links or bridges, is it possible to check beforehand whether or not they already ex

Re: Add route via C++ API?

2013-05-17 Thread Christian Fromme
On Fri, May 17, 2013 at 2:37 PM, Gordon Sim wrote: > Its in the properties map within the args, the name of the property is > 'key'. > > The full ist of properties for a bridge are "src", "dest", "key", "tag", > "excludes", "srcIsQueue", "srcIsLocal", "dynamic", "sync" and > "credit" Thanks once

Re: Add route via C++ API?

2013-05-17 Thread Christian Fromme
On Fri, May 17, 2013 at 2:21 PM, Christian Fromme wrote: > Using the (newer) qpid::messaging API, I can't seem to find where to > add the routing-key for a bridge. I guess its somewhere through the > Variant::Map args? Are possible key/value pairs the broker understands > doc

Re: Add route via C++ API?

2013-05-17 Thread Christian Fromme
Hi, On Fri, May 17, 2013 at 10:52 AM, Gordon Sim wrote: > Attached is a simple example showing what this would look like using the C++ > qpid::messaging API. It creates a link between two brokers and then > established a flow of messages between the amq.fanout exchanges. > > Feel free to ask any

Re: Add route via C++ API?

2013-05-17 Thread Christian Fromme
Hi Gordon, thanks for your quick reply! On Fri, May 17, 2013 at 10:52 AM, Gordon Sim wrote: > The recommended approach for federation is to use the 'create' method[1] to > create objects of type 'link' (i.e. connections between two brokers) and > associated 'bridges' (i.e. subscriptions over th

Add route via C++ API?

2013-05-17 Thread Christian Fromme
Greetings, in Qpid, broker federation is usually done via the `qpid-route` command line utility. I wonder if there is a way to add and control routes via the C++ API? If possible, an example would help! TIA, Christian - To unsub

Re: A second restart of slave leaves it in catchup state

2013-05-06 Thread Christian Fromme
Hi Alan, On Tue, Apr 30, 2013 at 10:29 PM, Alan Conway wrote: >> Maybe we have a similar problem with Active/Passive clustering >> (version 0.20). When I restart the primary, the slave stays in state >> "ready" and former primary stays in state "joining": >> >> $ ./qpid-ha -b 10.40.48.1 status #

Re: A second restart of slave leaves it in catchup state

2013-04-30 Thread Christian Fromme
Hi list, On Sun, Apr 28, 2013 at 6:42 PM, Salman A Baset wrote: > The master starts ok with /etc/init.d/qpid-primary. The master becomes > active. > > I start the slave using service qpidd restart. Slave starts in ready state. > > I then restart slave. It remains in catchup state. This is very w