Return-Path: <users-return-64224-archive-asf-public=cust-asf.ponee.io@camel.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 309CF200C00
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Wed, 18 Jan 2017 09:36:37 +0100 (CET)
Received: by cust-asf.ponee.io (Postfix)
	id 2F1CA160B53; Wed, 18 Jan 2017 08:36:37 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 79414160B3A
	for <archive-asf-public@cust-asf.ponee.io>; Wed, 18 Jan 2017 09:36:36 +0100 (CET)
Received: (qmail 12404 invoked by uid 500); 18 Jan 2017 08:36:35 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Delivered-To: moderator for users@camel.apache.org
Received: (qmail 11347 invoked by uid 99); 18 Jan 2017 08:34:56 -0000
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 3.487
X-Spam-Level: ***
X-Spam-Status: No, score=3.487 tagged_above=-999 required=6.31
	tests=[DKIM_ADSP_CUSTOM_MED=0.001, NML_ADSP_CUSTOM_MED=1.2,
	RCVD_IN_DNSWL_NONE=-0.0001, SPF_SOFTFAIL=0.972, URIBL_BLOCKED=0.001,
	URI_HEX=1.313] autolearn=disabled
Date: Wed, 18 Jan 2017 01:34:44 -0700 (MST)
From: Scisci <ferioli.mirko@gmail.com>
To: users@camel.apache.org
Message-ID: <1484728484500-5792714.post@n5.nabble.com>
In-Reply-To: <1484585339161-5792581.post@n5.nabble.com>
References: <1484585339161-5792581.post@n5.nabble.com>
Subject: Re: Infinispan Idempotent - EAP Cluster mod
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
archived-at: Wed, 18 Jan 2017 08:36:37 -0000

Hi, 
after some try, I think I've found the error.
It seems that the idempotentkey on file endpoint doesn't work as expected.
With this route the key is never found

<from
uri="{{net_protocol}}://{{ftp_imi_user}}@{{ftp_imi_host}}:{{ftp_imi_port}}/{{ftp_imi_path}}?password={{ftp_imi_password}}&amp;fileName=${bean:Genera_File_Imi.Crea_Nome_File}&amp;scheduler=quartz2&amp;scheduler.cron=0+28+17+?+*+MON-FRI&amp;noop=true&amp;idempotent=true&amp;idempotentRepository=#infinispanRepo&amp;idempotentKey=${file:onlyname.noext}&amp;readLock=idempotent&amp;delay=2000"/>
<doTry>
	<log message="Processing File: ${file:name}"/>
	<setHeader headerName="filename">
		<simple>${file:name}</simple>
	</setHeader>
	
	<setHeader headerName="CamelInfinispanKey"
id="route-header-infinispan-key">
		<simple>${file:onlyname.noext}</simple>
	</setHeader>
	<setHeader headerName="CamelInfinispanOperation"
id="route-header-infinispan-operation">
		<constant>CamelInfinispanOperationGet</constant>
	</setHeader>
	<setHeader headerName="CamelInfinispanCacheName">
		<simple>Idempotent_Emir</simple>
	</setHeader>
	<to id="route-infinispan-cache-lookup"
uri="infinispan:remote?cacheContainer=#cacheManager&amp;cacheName=Idempotent_Emir"/>
   <choice id="route-cache-choice">
	   <when id="route-cache-hit">
		   <simple>${header.CamelInfinispanOperationResult} != null</simple>
		   <log id="route-log-hit" message="CACHE LOOKUP NAME
${header.CamelInfinispanCacheName} : entry for key
${header.CamelInfinispanKey} is: ${header.CamelInfinispanOperationResult}"/>
	   </when>
	   <otherwise id="route-cache-miss">
		   <log id="route-log-miss" message="CACHE LOOKUP NAME
${header.CamelInfinispanCacheName} : no entry for key
${header.CamelInfinispanKey}"/>
	   </otherwise>
   </choice>
...

Put the idempotent out of file endpoint it work ...

<from
uri="{{net_protocol}}://{{ftp_imi_user}}@{{ftp_imi_host}}:{{ftp_imi_port}}/{{ftp_imi_path}}?password={{ftp_imi_password}}&amp;fileName=${bean:Genera_File_Imi.Crea_Nome_File}&amp;scheduler=quartz2&amp;scheduler.cron=0+0+18+?+*+MON-FRI&amp;noop=true"/>
            <idempotentConsumer id="route-idempotent-repository"
messageIdRepositoryRef="infinispanRepo">
            	<simple>${file:onlyname.noext}</simple>
	            <doTry>
	                <log message="Processing File: ${file:name}"/>
	                 ....

Bye
Mirko



--
View this message in context: http://camel.465427.n5.nabble.com/Infinispan-Idempotent-EAP-Cluster-mod-tp5792581p5792714.html
Sent from the Camel - Users mailing list archive at Nabble.com.