qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robbie Gemmell <robbie.gemm...@gmail.com>
Subject Re: Java broker / AMQP 1.0 / dynamic creation of queues
Date Wed, 16 Dec 2015 15:29:20 GMT
Did you have Rob's latest commit (r1720340) from a few hours ago? It
seems some other changes had impacted on the brokers AMQP 1.0 support
on trunk. I havent tried it against the current trunk, but I did run
that example against the recent 6.0.0 release earlier while testing
something else and it was happy then.


On 16 December 2015 at 14:24, Julien Charon <Julien.Charon@avitech.aero> wrote:
>   Hi Rob,
> Thank you very much for the implementation. I just tested it with a very similar configuration
as described in QPID-6954 (merely modified the pattern) and it seems to work pretty well.
> However, I noticed 2 things:
> 1. After a broker restart, an automatically created queue has disappeared, no matter
whether the nodeAutoCreationPolicies configuration is defined as durable or not. When I create
a durable queue manually with the web management interface I can directly see it in the json
configuration. This is not the case for automatically created ones. Maybe there's a store
operation missing or something like that?
> 2. I'm not sure if this is related to the change you've made, I doubt it to be honest
but I'd like to mention it anyway. I used to test / play with the java broker with the help
of the qpid-jms-examples (https://github.com/apache/qpid-jms/tree/master/qpid-jms-examples)
HelloWorld class which is very similar to the Hello class in the qpid-client-examples that
can be found on SVN. However, while the example used to work fine with the java broker 0.32,
I now get a ClassCastException because the consumer receives a javax.jms.BytesMessage (with
no content) instead of a javax.jms.TextMessage.
> Best regards,
> Julien
> Avitech GmbH
> Engineering AxL
> Tel.: +49 (0)7541/282-177
> Fax: +49 (0)7541/282-199
> e-mail: julien.charon@avitech.aero
> ________________________________________________
> Avitech GmbH
> Principal Office: Bahnhofplatz 1 | 88045 Friedrichshafen | Germany
> Court Registration: Amtsgericht Ulm | HRB 728293
> Geschäftsführer/Managing Director: Antonio Maria Gonzalez Gorostiza
> http://avitech.aero
> This message may contain confidential information and is intended only for the individual
named. If you are not the named addressee you should not disseminate, distribute or copy this
e-mail. Please notify the sender immediately by e-mail if you have received this e-mail by
mistake and delete this e-mail from your system.
> -----Ursprüngliche Nachricht-----
> Von: Rob Godfrey [mailto:rob.j.godfrey@gmail.com]
> Gesendet: Dienstag, 15. Dezember 2015 21:53
> An: users@qpid.apache.org
> Betreff: Re: Java broker / AMQP 1.0 / dynamic creation of queues
> Hi Julien,
> I've made a first pass at an implementation of a similar policy based approach for the
Java Broker.  The details are in QPID-6954 ( https://issues.apache.org/jira/browse/QPID-6954),
and the code is committed against the trunk in the subversion repo ( https://svn.apache.org/repos/asf/qpid/java/trunk/).
> It allows for creating queues or exchanges on the publishing of a message (or the establishment
of an incoming link to an address), and the creating of queues (but not currently exchanges)
on the establishment of an outgoing link (a consumer) for an address.  There is no way to
auto-create bindings currently.
> If you get a chance to try it out, let me know if it is works for you.
> Cheers,
> Rob
> On 15 December 2015 at 09:25, Gordon Sim <gsim@redhat.com> wrote:
>> On 12/14/2015 06:27 PM, Rob Godfrey wrote:
>>> The other approach (which I believe is available in the C++ broker)
>>> is to define some namespace / pattern for which queues of some kind
>>> are automagically created when referenced.  We could implement
>>> something similar in the Java Broker, though there's a lot of
>>> configuration that goes along with a queue, and I'm not sure of the
>>> best way of specifying what
>>> *sort*  of queue should be created.
>> The way the c++ broker does this is that it allows 'policies' to be
>> associated with some naming pattern. The policy can include various
>> aspects of the queue configuration (e.g. maximum depth, durability,
>> last-value semantics etc) that are then applied to any queue created
>> as a result of matching that naming pattern.
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org For
>> additional commands, e-mail: users-help@qpid.apache.org

To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org

View raw message