Re: qpid-send and qpid-receive utilities

2012-07-17 Thread Gordon Sim
On 07/11/2012 03:23 PM, Andy Goldstein wrote: We use these apps all the time. I'd prefer to see them all moved out of the tests directories and moved into someplace like tools. My only objection there is the complications for automated tests and sensible installs. The c++ tests require the c

Re: acknowledge(), reject(), release().. in qpid::messaging::Session

2012-07-17 Thread Toralf Lund
On 17/07/12 15:01, Gordon Sim wrote: On 07/17/2012 11:50 AM, Toralf Lund wrote: Some more questions loose related to my post on response queues: 1. What's the purpose of qpid::messaging::session::release()? Yeah, it releases the message, but what precisely does that mean? And how does i

Re: Batch/Bulk receive messages using java client?

2012-07-17 Thread Praveen M
Hi Robbie, Thanks for writing back soon. Please see inline. On Mon, Jul 16, 2012 at 3:32 PM, Robbie Gemmell wrote: > Ok, so to check I understand correctly, and seek clarification on some > points... > > You have potentially 30 application instances that have 5 connections, 20 > sessions per con

Re: Receiver.unsettled()

2012-07-17 Thread Gordon Sim
On 07/16/2012 10:45 PM, Sitapati das / Joshua J Wulf wrote: # python unsettled.py Traceback (most recent call last): File "unsettled.py", line 20, in msgs = ssn.unsettled() AttributeError: Session instance has no attribute 'unsettled' Which is what I would have expected, given that the

Re: qpid-send and qpid-receive utilities

2012-07-17 Thread Gordon Sim
On 07/11/2012 03:21 PM, Ken Giusti wrote: Sorry for the late feedback... Likewise! +1 to renaming qpid-cpp-benchmark to qpid-benchmark. I think moving qpid-benchmark into qpid/tools makes sense - it is a 'tool', even if it is not exactly a management tool. :) Is the intent also to instal

Re: Pub/Sub Example

2012-07-17 Thread Rajith Attapattu
On Tue, Jul 17, 2012 at 5:52 AM, ghada wrote: > Hello, > > I am a debutante in programming the Apache QPID. > I want to achieve a Java program "Publisher/subscriber" that sets up a > publisher and two subscribers sharing the same topic. > I searched in forums for examples but I found nothing. > Ca

Re: acknowledge(), reject(), release().. in qpid::messaging::Session

2012-07-17 Thread Gordon Sim
On 07/17/2012 11:50 AM, Toralf Lund wrote: Some more questions loose related to my post on response queues: 1. What's the purpose of qpid::messaging::session::release()? Yeah, it releases the message, but what precisely does that mean? And how does it affect the state of the receiver?

Re: Overhead of creating (private reply) queue?

2012-07-17 Thread Rajith Attapattu
On Tue, Jul 17, 2012 at 5:56 AM, Toralf Lund wrote: > On 16/07/12 16:12, Virgilio Fornazin wrote: >> >> We used here to create a private reply queue for each request/reply (and >> also, we discovered leaks with Ted Ross in 0.10 version that time). >> After that, we changed our code to pre-create a

Re: Sending to deleted auto delete queue

2012-07-17 Thread Gordon Sim
On 07/16/2012 10:39 PM, Sitapati das / Joshua J Wulf wrote: I see (I think). I don't have a production use case atm, I'm just experimenting. I was using auto-delete queues so that my tests cleaned up after themselves. I was under the (mistaken) impression that a sender gave me a handle on a que

Re: Queue and exchange with the same name

2012-07-17 Thread Gordon Sim
On 07/17/2012 03:51 AM, Sitapati das / Joshua J Wulf wrote: My apologies if this is me totally failing to grok how this works... A little more experimenting (this was done using the Fedora 16 packages): qpid-config add queue doppleganger qpid-config add exchange topic doppleganger (in either o

Re: Queue and exchange with the same name

2012-07-17 Thread Gordon Sim
On 07/17/2012 01:02 AM, Sitapati das / Joshua J Wulf wrote: I'm working through the Address tutorial here: http://qpid.apache.org/books/0.16/Programming-In-Apache-Qpid/html/section-addresses.html I was not expecting this behaviour: $ spout 'amq.topic; {assert: always, node: { type: topic}}' tes

Re: Pub/Sub Example

2012-07-17 Thread Toralf Lund
On 17/07/12 11:52, ghada wrote: Hello, I am a debutante in programming the Apache QPID. I want to achieve a Java program "Publisher/subscriber" that sets up a publisher and two subscribers sharing the same topic. I searched in forums for examples but I found nothing. Can someone help me? I'm not

Pub/Sub Example

2012-07-17 Thread ghada
Hello, I am a debutante in programming the Apache QPID. I want to achieve a Java program "Publisher/subscriber" that sets up a publisher and two subscribers sharing the same topic. I searched in forums for examples but I found nothing. Can someone help me? Best regards, Ghada -- View this me

acknowledge(), reject(), release().. in qpid::messaging::Session

2012-07-17 Thread Toralf Lund
Some more questions loose related to my post on response queues: 1. What's the purpose of qpid::messaging::session::release()? Yeah, it releases the message, but what precisely does that mean? And how does it affect the state of the receiver? 2. What would be the point of rejecting a messag

Re: c++ broker federation over ssl

2012-07-17 Thread wei6rong
hi all, I have set the qpid ssl link successfully by refer to qpid-0.16/cpp/src/tests/sasl_fex_ex, the process is as following, TEST 1: /root/Downloads/qpid-0.16/cpp/src/.libs/lt-qpidd --port=5801 --ssl-port 6667 --ssl-sasl-no-dict --sasl-config=/root/Downloads/qpid-0.16/cpp/src/tests/sasl_config

Re: Overhead of creating (private reply) queue?

2012-07-17 Thread Toralf Lund
On 16/07/12 16:12, Virgilio Fornazin wrote: We used here to create a private reply queue for each request/reply (and also, we discovered leaks with Ted Ross in 0.10 version that time). After that, we changed our code to pre-create a private reply queue for each connection that perform request / r

qpid::messaging main loop integration?

2012-07-17 Thread Toralf Lund
Hi Does anyone here receive "published" messages in an application using a something like a GLib main loop? Or Gtk or Qt? If you do, how exactly do you integrate the message availability check with the main loop? I was hoping there would be filedescriptor that had data available whenever mess