qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Godfrey <rob.j.godf...@gmail.com>
Subject Re: Java broker / AMQP 1.0 / dynamic creation of queues
Date Wed, 16 Dec 2015 15:29:21 GMT
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?
>

Doh - I'm an idiot... That should be fixed now on trunk


> 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.
>

That was probably due to a bug caused by another check-in I made last
night, which I fixed earlier today :-)

Hopefully everything should work now - apologies for that!

-- Rob


>
>
> 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
> >
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message