[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
we need to make use of a certain feature of the XMLBlaster. suppose we
have a few subscribers registered for a particular topic (it is actually
a few instances of the same application, which run in load balancing
mode). we need to create a scenario in which a publisher posts a message
on the topic, but we only need one single subscriber to receive it.
the way that we see it is, the publisher can dictate somewhere (possibly
in the <qos> tag), at the time the posted message is created, whether
that message is supposed to be received by all the subscribers, or by
just one of the registered subscribers. practically, we want to use
XMLBlaster to access distributed database queries: if the message is
some sort of a SELECT command, then one single response from any of the
databases should be enough (considering the databases are sync'ed); if
the message is an INSERT or an UPDATE, we need all the subscribers to
perform the command on their local databases.
i know you have some work done on that ConsumableQueue concept, but i
didnt quite understand how that works. i also know that theres a method
that goes around, with doing some sort of administrative get()'s, but we
would definitely prefer the subscriber push (or callback, as you call
it). can you provide a step-by-step approach on how to install the
ConsumableQueue plugin and how to publish, register and receive a
message in the scenario above. even if it's not fully tested, we may
volunteer to do that for you.
email: radu at jambotech.com