activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sbuberl <sbub...@gmail.com>
Subject Re: Posting to a virtual topic's physical queue
Date Thu, 24 May 2007 14:56:53 GMT



sbuberl wrote:
> 
> 
> Thanks.  I knew about the subscription policies existed but didn't know I
> could override MessageQuery to do as I wish.  How do I configure the
> broker's queryBasedSubscriptionRecoveryPolicy to use my custom
> implementation of MessageQuery rather than message selectors? 
> 

Okay so I found the answer to this question by going through the mailing
list and finding a sample on svn.  But I still can't get my connecting
message driven beans to be retroactive (there's two test MDBs listening to
the topic).

I wrote the following policy:

<policyEntry topic="ATIS">
  <dispatchPolicy>
    <strictOrderDispatchPolicy />
  </dispatchPolicy>
  <subscriptionRecoveryPolicy>
    <queryBasedSubscriptionRecoveryPolicy query="#ritisQuery"/>
  </subscriptionRecoveryPolicy>
</policyEntry>

and defined my ritisQuery bean in the config as well.

I also modified the ServerUrl property in my Jboss server's activeMQ
resource adapter's ra.xml to be:
tcp://localhost:61616?jms.useRetroactiveConsumer=true

and then for each of my beans I defined the destination property like so:
<activation-config-property>
 
<activation-config-property-name>destination</activation-config-property-name>
       		 
<activation-config-property-value>ATIS?consumer.retroactive=true</activation-config-property-value>
  </activation-config-property>

Both beans successful connect to the topic and receive messages when I post
to the topic but my query is never run and jconsole says both topic
connections' "retroactive" property is false.  Am I missing something?
-- 
View this message in context: http://www.nabble.com/Posting-to-a-virtual-topic%27s-physical-queue-tf3805152s2354.html#a10785662
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message