Hi, I have a problem with infinispanIdempotent.
This is my config :

<route id="Ricezione_Messaggi_Scarico_Datalicense">
    <from uri="amqp:Scarico_Datalicense"/>
    <idempotentConsumer messageIdRepositoryRef="infinispanRepo"
skipDuplicate="false">
      <xpath>/ag_02:Messaggio/ag_02:Data_Giro</xpath>
      <filter>
        <exchangeProperty>CamelDuplicateMessage</exchangeProperty>
        <log message="Mesaggio Scarico_Datalicense Duplicato"/>
        <stop/>
      </filter>
      <to uri="direct:Process_Scarico_Datalicense"/>
    </idempotentConsumer>
  </route>

<bean id="cacheManager"
class="org.infinispan.client.hotrod.RemoteCacheManager" init-method="start"
destroy-method="stop"/>
        
        
        
        <bean id="infinispanRepo"
class="org.apache.camel.component.infinispan.processor.idempotent.InfinispanIdempotentRepository"
factory-method="infinispanIdempotentRepository">
        <constructor-arg index="0" ref="cacheManager"/>
        <constructor-arg index="1"  value="Idempotent"/>
        </bean>
I have two EAP server in domain mode with ha profile.

If I use DefaultCacheManager it works only on one server, the cache is not
replicated on the second server.
If I use RemoteCacheManager it doesn't work no messages are blocked. 

Do you have any suggestions?

Thanks
Mirko




--
View this message in context: 
http://camel.465427.n5.nabble.com/infinispan-Idempotent-and-RemoteCacheManager-tp5780600.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to