Hi,

I have a doubt regarding virtual topics and how the messages are routed 
(replicated) to the consumers (queues).

I'm using two virtual topics one with the default name (VirtualTopic.>) and 
another
one named VirtualTopic.MIGRATION.

I have three consumers (queues):

  * Consumer.2b36ad7a-e641-496d-b319-85000c36d13c.VirtualTopic.>
  * Consumer.e5e60abd-1a66-43f5-8588-842e429b4c5c.VirtualTopic.>
  * Consumer.48ebcaa5-f11b-4de4-a850-2ff45174f83b.VirtualTopic.MIGRATION

My expectation would be that messages send to topic VirtualTopic.> would be 
send to queues:

  * Consumer.2b36ad7a-e641-496d-b319-85000c36d13c.VirtualTopic.>
  * Consumer.e5e60abd-1a66-43f5-8588-842e429b4c5c.VirtualTopic.>

and that messages send to topic VirtualTopic.MIGRATION would be send to queue:

  * Consumer.48ebcaa5-f11b-4de4-a850-2ff45174f83b.VirtualTopic.MIGRATION

So far I was not able to make things work that way.

I have try different virtual destinations configurations: 

    <destinationInterceptors>
        <virtualDestinationInterceptor>
            <virtualDestinations>
                <virtualTopic name="VirtualTopic.MIGRATION" 
prefix="Consumer.*.VirtualTopic."/>
                <virtualTopic name="VirtualTopic.>" 
prefix="Consumer.*.VirtualTopic."/>
            </virtualDestinations>
        </virtualDestinationInterceptor>
    </destinationInterceptors>

but no look. Messages send to topic VirtualTopic.MIGRATION are replicated to 
queues:

  * Consumer.2b36ad7a-e641-496d-b319-85000c36d13c.VirtualTopic.>
  * Consumer.e5e60abd-1a66-43f5-8588-842e429b4c5c.VirtualTopic.>

but not to queue:

  * Consumer.48ebcaa5-f11b-4de4-a850-2ff45174f83b.VirtualTopic.MIGRATION

The only way I manage to make this work more or less was using some tag in the 
consumers name and use the 
prefix to filter by that tag. 

This makes me ask, is it not possible to route messages to queues only based on 
the topic name ?

Unfortunately I cannot change consumers names (that are generated randomly) so 
using only the prefix is not option.  

I'm using ActiveMQ release version 5.9.0. 

Any comments on this will be appreciated.

Thank you,

Nuno Oliveira

-- 
==
GeoServer Professional Services from the experts! 
Visit http://goo.gl/it488V for more information.
==
Nuno Miguel Carvalho Oliveira
@nmcoliveira
Software Engineer

GeoSolutions S.A.S.
Via di Montramito 3/A
55054  Massarosa (LU)
Italy

phone: +39 0584 962313
fax:   +39 0584 1660272
mob:   +39  333 8128928

http://www.geo-solutions.it
http://twitter.com/geosolutions_it

-------------------------------------------------------

AVVERTENZE AI SENSI DEL D.Lgs. 196/2003
Le informazioni contenute in questo messaggio di posta elettronica e/o nel/i 
file/s allegato/i sono
da considerarsi strettamente riservate. Il loro utilizzo è consentito 
esclusivamente al destinatario del messaggio, per le finalità indicate
nel messaggio stesso. Qualora riceviate questo messaggio senza esserne il 
destinatario, Vi preghiamo cortesemente di darcene notizia via e
-mail e di procedere alla distruzione del messaggio stesso, cancellandolo dal 
Vostro sistema. Conservare il messaggio stesso, divulgarlo
anche in parte, distribuirlo ad altri soggetti, copiarlo, od utilizzarlo per 
finalità diverse, costituisce comportamento contrario ai
principi dettati dal D.Lgs. 196/2003.
 
The information in this message and/or attachments, is intended solely for the 
attention and use of
the named addressee(s) and may be confidential or proprietary in nature or 
covered by the provisions of privacy act (Legislative Decree
June, 30 2003, no.196 - Italy's New Data Protection Code).Any use not in accord 
with its purpose, any disclosure, reproduction, copying,
distribution, or either dissemination, either whole or partial, is strictly 
forbidden except previous formal approval of the named
addressee(s). If you are not the intended recipient, please contact immediately 
the sender by telephone, fax or e-mail and delete the
information in this message that has been received in error. The sender does 
not give any warranty or accept liability as the content,
accuracy or completeness of sent messages and accepts no responsibility  for 
changes made after they were sent or for other risks which
arise as a result of e-mail transmission, viruses, etc.

Reply via email to