On 02/03/2011 04:14 AM, sergey_zhemzhit...@troika.ru wrote:
Start qpid (currently I have one node of qpid configured to work in a
cluster)
When I execute qpid-config -q I have a lot of queues with names like that
_@amq.failover_54cb1666-c325-472b-9b83-1bececd2f0a8
What is the meaning of thos
On 02/02/2011 07:35 AM, Bruno Matos wrote:
Hi,
Short answer:
qpid::messaging is a high level API, easier to use than qpid::client.
It's also the newer API, the one we are focusing on for new development,
and the one that is featured in our documentation.
Use qpid::messaging.
Jonathan
On 02/01/2011 09:19 AM, sergey_zhemzhit...@troika.ru wrote:
Well, queue seems to be empty, because I can't read a message from it.
Does anybody know how make qpid-tool and qpid-stat return an appropriate
information?
1. qpid-stat -q gives statistics for a queue
2. In qpid-tool, first do a 'li
On 01/17/2011 10:37 AM, Alan Conway wrote:
On 01/13/2011 04:54 PM, Jonathan Robie wrote:
Content-based filtering is currently available only for XML messages,
using the XML Exchange.
There's no reason the same functionality couldn't be extended to maps,
but nobody has implemented tha
Content-based filtering is currently available only for XML messages,
using the XML Exchange.
There's no reason the same functionality couldn't be extended to maps,
but nobody has implemented that.
Jonathan
-
Apache Qpid - A
What does your PYTHONPATH look like?
Here's mine ...
$ echo $PYTHONPATH
/home/jrobie/projects/qpid/python:/home/jrobie/projects/qpid/extras/qmf/src/py
And it works for me.
Jonathan
-
Apache Qpid - AMQP Messaging Implementatio
Hi Liz,
Can you show me the address, using the old vs. new syntaxes? Also, can
you show the output of $ qpid-config queues, after creating the new
queues with each syntax?
Jonathan
-
Apache Qpid - AMQP Messaging Implementati
On 11/01/2010 09:04 PM, zhaoyi0...@gmail.com wrote:
In this thread
http://apache-qpid-users.2158936.n2.nabble.com/What-is-the-different-between-qpid-client-Session-h-and-qpid-messaging-Session-h-tt5569296.html#a5569296
you told me that the new API is in active development. what I think is that
On 10/31/2010 09:40 PM, zhaoyi0...@gmail.com wrote:
Let me confirm one thing. Old C++ API doesn't have Topic class to implement
pub-sub pattern. New C++ API have implement this patter. Do I understand
correctly?
Hi Zhao - Both APIs support both patterns. It's simpler in the new API.
Is there
On 10/18/2010 12:00 PM, Thomas Kirkham wrote:
Could it be the Apache Mina Libs?
I moved from 0.6 and installed from the trunk and still error below, any ideas?
I don't know what environment you are working in - could you install the
C++ implementation of the broker for comparison?
I don't u
I think this is the Java broker - any of the Java broker folks want to
weigh in here?
Jonathan
-
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:users-subscr...@qpid.apache.
On 10/13/2010 08:23 AM, Thomas Kirkham wrote:
Hi,
I have been looking through the documentation for an example java client
using SSL to connect to the broker. I can't seem to find any examples, can
anybody point me in the right direction or offer up some code to get me started?
This page
On 09/14/2010 01:45 PM, Rajiv Jacob Cheriyan wrote:
Hi,
Can anyone give me pointers for QPID integration with Spring framework.
This looks like it might be it:
http://www.springframework.net/
We are pleased to announce that the first milestone release of the Spring AMQP
1.0 project is now
On 07/29/2010 09:39 AM, Gordon Sim wrote:
On 07/29/2010 01:41 PM, Andy Goldstein wrote:
The c++ docs under 0.6 are actually more recent than that. I suspect
that the 0.6 directory should actually be 0.7 and accurate 0.6 docs need
to be regenerated (there is a set of 0.5 docs that appear not to b
On 07/29/2010 08:41 AM, Andy Goldstein wrote:
Hi all,
I've found a couple of 404s on the web site and wanted to report them. On
http://qpid.apache.org/documentation.html, all the links under API Reference
Documentation for 0.7 are broken. This includes both the HTML versions and the
.tar.gz
On 07/28/2010 01:28 PM, Brian Crowell wrote:
It sounds like I'm just going to have to create a more complicated
setup than I hoped for, trying to divide all the messages up into as
many queues as I can. I originally wanted all messages to go into a
few exchanges and let the subscriber bind to wh
On 05/03/2010 05:21 PM, Steve Olson wrote:
Thanks everyone for the replies. It looks like the map interface could
do the job nicely. Is there some advantage to going another route?
Note that it will not be known at compile time what the data row is
going to look like; it will be obtained from
On 05/03/2010 05:21 PM, Steve Olson wrote:
Thanks everyone for the replies. It looks like the map interface could
do the job nicely. Is there some advantage to going another route?
Note that it will not be known at compile time what the data row is
going to look like; it will be obtained from
On 05/03/2010 05:06 PM, Steve Olson wrote:
Thanks for the quick reply. I'll check out the link.
Am programming in C/C++.
OK, in C++ you use a Variant::Map - a sender adds map entries, then
encodes it into a message. A receiver decodes the message content into a
map, where it can be read by t
On 05/03/2010 04:47 PM, Steve Olson wrote:
Hello,
I'm must getting acquainted with qpid. Have read the AMQP spec (0-10)
and the messaging tutorial from red hat. I'm wondering how to
send/receive a message containing one or more data rows from a
database (multiple datatypes) -- the qpid client
I added a section on the XML Exchange to "Programming in Apache Qpid".
The source is checked in to our svn repo, and it will appear on the new
web site as soon as it is up, in the meantime you can see it here:
http://people.apache.org/~jonathan/Programming-In-Apache-Qpid.html
http://people.apac
Here's a C++ program that uses the XML exchange. The only x-bindings
argument that is really needed is the xquery, since the subject and the
exchange can be specified as part of standard address syntax. I used a
stringstream to make it easier to write a query and add it to a template
string tha
On 04/30/2010 05:38 PM, Jonathan Robie wrote:
sender = session.sender(address)
receiver = session.receiver(address)
Oops, that should have read:
sender = session.sender("xml")
receiver = session.receiver(address)
In other words, I should be sending to the XML Exchange, and rea
This Python program works for me, using the same data as the XML
Exchange example in the Python examples directory.
Make sure you create an instance of the XML exchange with qpid-config first:
$ ./qpid-config add exchange xml xml
Jonathan
import sys
from qpid.messaging import *
broker = "
On 04/22/2010 09:31 AM, Cajus Pollmeier wrote:
just waited for 0.6 to pop up and tried to do something with the new API. Is
there some documentation for it and it's usage intention?
Reading the code examples (examples/api) and the (rare) documentation for the
API itself, I'm wondering where q
On 12/10/2009 10:39 AM, Michael DeHaan wrote:
I'm curious if anyone has any existing/working PHP bindings for qpid?
I am not aware of one.
I have found http://code.google.com/p/php-amqplib/ which works
sufficiently well with RabbitMQ, though apparently it does not play
work (so I'm told)
Angel Freire wrote:
2009/11/4 Jonathan Robie
Get the persistence stuff from QpidComponents.org:
http://qpidcomponents.org/download.html
Thanks, I know I was missing something obvious.
It would be obvious if the qpid downloads page pointed to the components
on
Get the persistence stuff from QpidComponents.org:
http://qpidcomponents.org/download.html
Jonathan
Angel Freire wrote:
Hi,
I can't setup my qpid broker to have persistent storage running Gentoo
Linux.
I've downloaded the source qpid-cpp-0.5.tar.gz (I'm using the C++ version of
the broker) a
I just modified the page so that people who can not edit our Wiki pages
can still sign up. Ooops!
http://cwiki.apache.org/confluence/display/qpid/Qpid+Meetup+at+ApacheCon+2009
Jonathan
-
Apache Qpid - AMQP Messaging Implementa
Someone who was planning a Qpid Meetup at ApacheCon 2009 had to bow out
at the last moment, and I've been asked to take over the session.
We will have a meetup in Oakland, CA on Tuesday night, 3 November 2009,
at 8PM. This event is open to anyone who wants to come, even if you are
not register
message to prevent
loop
detection.
Carl.
Jonathan Robie wrote:
Bidirectional links are fine, and
automatically detect
loops. Tree, star, or line topologies are fine
too, and
bidirectional links between any pair
Bidirectional links are fine, and automatically detect loops. Tree,
star, or line topologies are fine too, and bidirectional links between
any pair of brokers are fine. A ring topology is also possible, if only
unidirectional links are used.
Here's the rule:
For any pair of nodes A,B in a fed
One way is to create a "dead letter queue" that receives messages that
could not be delivered, and bind it to a "dead letter exchange".
session.exchangeDeclare(arg::exchange="deadletter.exchange",
arg::type="fanout");
session.queueDeclare(arg::queue="deadletter_queue");
session.exchangeBind(ar
Bill Whiting wrote:
Thanks, I'll add my own attribute for now. It would be beneficial to
add this to the API.
+1
Jonathan
-
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto
Isn't the Java client's output determined by the log4j file (log4j.xml)?
If it's still the way it used to be, you can change the level in the
logger to trace, debug, info, warn, error or fatal:
I haven't looked at this for quite a while, so it may well have changed ...
Jonathan
--
Rich Stephens wrote:
Thanks for the quick reply.
It seems I have made some rather silly errors in my client code:
1) I was assigning the newSession to a local session variable instead of my
class member (unintentionally)
2) I didn't realize that the "url" argument to open->(URL) was an actual
q
Leglise Yann wrote:
Hello Robert,
I am not particulary trying to create queues dynamically. I am in fact trying to
determine if by using the JMS QPID implementation leads to an AMQP compliant behaviour. I
mean, by using JMS, as soon as a use a consumer on an non-existing queue, this queue is
Leglise Yann wrote:
Hello once again :)
Here are some additional questions arisen from your answers.
1) As there are java example that does not make use of JMS objects, I suppose
that QPID also furnish another AMQP implementation that is independent from JMS?
Yes, there is also a "low leve
Ricard,
The Java AMQP API is not widely used, most Java programmers are using
the Java JMS interface. It is also not well documented, grepping for
"Properties" in the examples can help give you an overview if you really
want to use this API (see below).
I haven't tried this, but I imagine Me
Marcus Schröder wrote:
But the included
Makefile is too complex for me to see how it works and I don't want to
keep modifying the included examples to compile code (which works, but
is obviously out of question for production). Eventually, I would like
to make my own...
Sounds like starting
Jesse W. Hathaway wrote:
The ruby client I was trying to use, tmm1-amqp, is tested against
RabbitMQ and since RabbitMQ only supports 0-8 at this time no support
for other specs have been added to the client.
Our Ruby client is tested against the Qpid C++ broker (and I think it
has also been
Hi Jesse,
Our Ruby clients are written in pure Ruby, the only C code is in the
library for SASL integration. I have not ever used JRuby - did you try
using our client with JRuby and run into problems? (Does anyone out
there have experience with JRuby and our client?)
Make sure your client an
Jesse W. Hathaway wrote:
I am brand new to AMQP as well as QPID
When attempting to use the Ruby bindings with
the example code I get the same error message from M4
as well as from the trunk.
/home/jwh/tmp/qpid-svn/trunk/qpid/ruby/lib/qpid/connection.rb:139:in
`start': Qpid::Timeout (Qpid::Tim
Alan Conway wrote:
Shan Wang wrote:
Hi All,
According to the document, normally a listener of a publish/subscribe
kind of exchange can only receive messages after it begins running. Is
there any way to let the listeners receive all the messages ever sent by
producer?
Basically what I n
falconair,
Since I don't do this kind of thing myself, I may not understand all of
the issues in your application domain. Let me see if I understand what
the issues are.
1. There are many topics. You want to use hierarchies to manage them.
Wildcards do that well in the topic exchange.
2. Y
falconair wrote:
I would like to publish market data through qpid. Since I have massive amount of data flowing through the
pipes, I can't publish all that data to a single topic, since the client may only be interested in one or two
symbols. The usual solution to use a hierarchical topic nami
We've had a C++ API summary as part of the reference documentation for a
while. I wanted a similar summary for the Python API. Here are the two
summaries, followed by the references to the complete API documentation:
C++ Messaging API for Apache Qpid:
http://www.ibiblio.org/jwrobie/blog/?p=18
h
Gordon Sim wrote:
The (non-standard) XML exchange allows XQuery selection based on
headers, but currently I believe it requires the body to be in XML
even if your query doesn't actually access the body.
I just checked in a version of the XML Exchange that does not attempt to
parse the message
Gordon Sim wrote:
Does anyone have a strong view on the desirability of making this more
consistent?
Consistency really makes it easier to remember these things.
I myself have a slight preference for --no-auth over
--auth no; I'm less bothered about the --mgmt-enable option but that
could be
GS.Chandra N wrote:
On Tue, Feb 17, 2009 at 8:20 PM, Jonathan Robie
wrote:
I honestly do not know which approach would perform better - we'll see! How
many conditions are you likely to be testing in a single query?
upto 100 conditions in 30% of the cases, upto 500 in 50% of the case
Someone else can comment on our overhead per queue, I have not measured
that, I think we have good support for lots of queues.
You can read a message without consuming it from the queue, and you can
use Ttl ("time to live") to make a message expire when it is no longer
relevant.
The XML Exch
GS.Chandra N wrote:
That would be really cool Jonathan.
The major reason i fear to take the multiple subscriptions route is due to
fears of performance degradation. If i can make do with a single
subscription, which performs better than equivalent multiple subscriptions,
i could connect more cli
Gordon Sim wrote:
I think the simplest fix/change to address your need would be a
modification to the xml exchange to allow xqueries on headers only,
where the body is not itself xml.
I will do that - it means I have to detect statically whether the
message body is used in the query, but I th
e rabbitmq python client binding from barryp, there are simple server
and client programs, 30 lines or so each, that demonstrate simple api usage,
are very friendly.
http://barryp.org/software/py-amqplib/
On Thu, Feb 5, 2009 at 8:17 PM, Carl Trieloff wrote:
coping user list
Jonathan Robi
Ted Ross wrote:
Can you remove references to the management and managementdata
modules? These are obsolete.
Eventually, but
There are actually a zillion obsolete things in the generated API docs,
which makes them a bit of a trap. It needs major cleaning, either by
cleaning up the API i
Carl Trieloff wrote:
don't post it in your home, dir let put it under docs section. I can
help you
OK - thanks, see you in IRC!
Jonathan
-
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/In
I just posted Python API docs here:
http://people.apache.org/~jonathan/qpid/api/python/html/
I'll be linking to that form the wiki. I've decided I'm a fan of epydoc ;->
Jonathan
-
Apache Qpid - AMQP Messaging Implementation
Pr
I commented out a bunch of stuff, and the second part works now:
SubscriptionManager subscriptions(session);
// Create a listener and subscribe it to the queue named
"message_queue"
Listener listener(subscriptions);
// Receive messages until the subscription is cancelled
//
Alan Conway wrote:
you can also declare the queue with auto_delete=true if you want it
automatically deleted
when you close your session
And that's more robust - it does not depend on your program to get it
right, and it works even if your program crashes.
Jonathan
Joshua Kramer wrote:
Remember to delete the queue when you're done with it, or queues will
accumulate on the server.
In python - is it enough to call the close() method of the queue
object, or is there also some sort of destroy() method?
qpid.session.Session.queueDelete() is your friend. I w
Alan Conway wrote:
Justin Ross wrote:
Hi, Josh.
Do you have some kind of user session id you could use to create
session-scoped queues? With a queue per active user, the world would
remain coherent without the need to create and destroy things too much.
Josh - if you create sessions without
I find this surprising. When Adam does the cancel, I would expect all
messages that haven't been acknowledged to be available on the
server-side queue. When he subscribes the listener, I would expect him
to receive the rest.
In my programs I always set up the subscriptions first, then call
st
Carl Trieloff wrote:
Would it be useful to create a page where we link useful and
informative blog posting about Qpid?
As well as articles and such. Yes, it would be useful.
Jonathan
63 matches
Mail list logo
