{"type":"doc","content":[{"type":"extension","attrs":{"layout":"default","extensionType":"com.atlassian.confluence.macro.core","extensionKey":"toc","parameters":{"macroParams":{"minLevel":{"value":"1"},"maxLevel":{"value":"1"},"outline":{"value":"true"},"style":{"value":"square"},"type":{"value":"list"},"printable":{"value":"false"}},"macroMetadata":{"macroId":{"value":"a0df1a28-832d-4a1a-8d76-272026971454"},"schemaVersion":{"value":"1"},"title":"Table of Contents"}},"localId":"fc64e521-1584-47c0-8f82-f17003fbefc6"}},{"type":"heading","attrs":{"level":1},"content":[{"text":"Purpose","type":"text"}]},{"type":"layoutSection","content":[{"type":"layoutColumn","attrs":{"width":66.66},"content":[{"type":"paragraph","content":[{"text":"Ehcache is an open source, standards-based cache that boosts performance, offloads your database, and simplifies scalability. It is the most widely-used Java-based cache because it is robust, proven, full-featured, and integrates with other popular libraries and frameworks. Ehcache scales from in-process caching, all the way to mixed in-process/out-of-process deployments with terabyte-sized caches.","type":"text"}]}]},{"type":"layoutColumn","attrs":{"width":33.33},"content":[{"type":"mediaSingle","attrs":{"layout":"align-start","width":128,"widthType":"pixel"},"content":[{"type":"media","attrs":{"width":3268,"type":"external","url":"https://www.ehcache.org/images/Ehcache_Logo.png","height":402}}]}]}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"Use Case","type":"text"}]},{"type":"paragraph","content":[{"text":"Once the ITEM_UPDATE_PR is obtained, take data from it, enrich it with some data taken from another PFX table and upload enriched record to some PX table.","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"text":"As there can be generated thousands of events per seconds (if data to PR table is uploaded via Excel Client or similarly), there was a need to call backend API to obtain a table for enrichment every time. That is a very expensive operation and so caching can come handy. ","type":"text"}]},{"type":"paragraph","content":[{"text":"The entire implementation is mostly in one commit: ","type":"text"},{"text":"https://bitbucket.org/pricefx/tfg-integration/commits/f3fe205d33b75861a9fae0debcfdabb4d1c98842","type":"text","marks":[{"type":"link","attrs":{"href":"https://bitbucket.org/pricefx/tfg-integration/commits/f3fe205d33b75861a9fae0debcfdabb4d1c98842"}}]},{"type":"hardBreak"},{"text":"Additional commit adds a condition to the cache: ","type":"text"},{"text":"https://bitbucket.org/pricefx/tfg-integration/commits/09b373f8b0dbd69e8fb91278bd0653969a8edd4e","type":"text","marks":[{"type":"link","attrs":{"href":"https://bitbucket.org/pricefx/tfg-integration/commits/09b373f8b0dbd69e8fb91278bd0653969a8edd4e"}}]},{"type":"hardBreak"},{"text":"Additional condition was added due to NoHttpResponseException which is sometimes occurs and then an empty list is returned.","type":"text"}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"Example Implementation","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Add Dependencies to pom.xml","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n org.springframework.boot\n spring-boot-starter-cache\n\n\n javax.cache\n cache-api\n\n\n org.ehcache\n ehcache\n ","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Add property to properties file","type":"text"}]},{"type":"codeBlock","content":[{"text":"spring.cache.jcache.config=classpath:ehcache.xml","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Create ehcache.xml configuration file","type":"text"}]},{"type":"paragraph","content":[{"text":"Based on this create ","type":"text"},{"text":"ehcache.xml","type":"text","marks":[{"type":"em"}]},{"text":" file in the classpath (probably directly in the resource folder by default) with this content:","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n\n \n\n \n 30\n \n\n \n \n net.pricefx.integration.startup.config.CacheEventLogger\n ASYNCHRONOUS\n UNORDERED\n CREATED\n EXPIRED\n \n \n\n \n 2\n 10\n \n \n\n","type":"text"}]},{"type":"paragraph","content":[{"text":"Above you can note a few things. You can configure ttl as well as persistence to disk, listeners etc. For more configurations check out the ehcache documentation.","type":"text"}]},{"type":"paragraph","content":[{"text":"Here we use just ttl for 30 minutes. If no event is received within 30 minutes, the table will be evicted from the cache and a new API call will be triggered to populate fresh data. Because we have listener, we will get notified and log such process.","type":"text"}]},{"type":"paragraph","content":[{"text":"Do not hesitate to change entries and other properties which will fit to your needs. Since we needed to store the entire table (approx. 1500 rows), just 1 entry and 10MB was enough. ","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Create listener for logging cache events","type":"text"}]},{"type":"paragraph","content":[{"text":"So we have configuration where a listener is mentioned. Let's create it.","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"CacheEventLogger.java","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"package net.pricefx.integration.startup.config;\n\nimport org.ehcache.event.CacheEvent;\nimport org.ehcache.event.CacheEventListener;\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\n\npublic class CacheEventLogger implements CacheEventListener {\n\n private static final Logger log = LoggerFactory.getLogger(CacheEventLogger.class);\n\n @Override\n public void onEvent(CacheEvent cacheEvent) {\n log.info(\"Cache event {} for item with key {}.\", cacheEvent.getType(), cacheEvent.getKey());\n }\n\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"You can get a better log info with for example:","type":"text"}]},{"type":"codeBlock","content":[{"text":"log.info(\"Cache event {} for item with key {}. Old value = {}, New value = {}\", cacheEvent.getType(), cacheEvent.getKey(), cacheEvent.getOldValue(), cacheEvent.getNewValue());","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Enable caching in your application","type":"text"}]},{"type":"paragraph","content":[{"text":"You have two options. You can put a line in the ","type":"text"},{"text":"camel-context.xml","type":"text","marks":[{"type":"em"}]},{"text":" or add an annotation to the startup Application class. Adding annotation to the Application is proved to be working on Java 11 and IM 1.1.17. You might try to create a CacheConfig class.","type":"text"}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"Add annotation-driven into camel-context.xml","type":"text"}]},{"type":"paragraph","content":[{"text":"Add the following line into the ","type":"text"},{"text":"camel-context.xml","type":"text","marks":[{"type":"em"}]},{"text":" and its namespace.","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"camel-context.xml","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"xml"},"content":[{"text":"\n\n","type":"text"}]},{"type":"paragraph"},{"type":"heading","attrs":{"level":4},"content":[{"text":"Create CacheConfig","type":"text"}]},{"type":"paragraph","content":[{"text":"Then create the cache config Java class:","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"CacheConfig.java","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"package net.pricefx.integration.startup.config;\n\nimport org.springframework.cache.annotation.EnableCaching;\nimport org.springframework.context.annotation.Configuration;\n\n@Configuration\n@EnableCaching\npublic class CacheConfig {\n \n}","type":"text"}]},{"type":"paragraph","content":[{"text":"To explain: Spring’s auto-configuration finds Ehcache’s implementation of JSR-107. However, no caches are created by default. That is why this is needed.","type":"text"}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"Add EnableCaching annotations to your Application class","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"Application","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","attrs":{"language":"java"},"content":[{"text":"package net.pricefx.integration.startup;\n\nimport org.springframework.boot.SpringApplication;\nimport org.springframework.boot.autoconfigure.EnableAutoConfiguration;\nimport org.springframework.boot.autoconfigure.SpringBootApplication;\nimport org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration;\nimport org.springframework.cache.annotation.EnableCaching;\nimport org.springframework.context.annotation.ImportResource;\n\n@ImportResource({\"${application.context}\"})\n@SpringBootApplication\n@EnableAutoConfiguration(exclude={JmsAutoConfiguration.class})\n@EnableCaching\npublic class Application {\n\tpublic static void main(String[] args) {\n\t\tSpringApplication.run(Application.class, args);\n\t}\n}","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Modify service class to enable caching","type":"text"}]},{"type":"paragraph","content":[{"text":"We are almost at the end. Now you should create your own service which will do the caching of data you want. Here is an example of data which were needed.","type":"text"}]},{"type":"paragraph","content":[{"text":"TerminalsService.java","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"package net.pricefx.integration.startup.service;\n\nimport java.util.Arrays;\nimport java.util.List;\nimport java.util.Map;\n\nimport org.slf4j.Logger;\nimport org.slf4j.LoggerFactory;\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.cache.annotation.Cacheable;\nimport org.springframework.stereotype.Service;\n\nimport net.pricefx.integration.api.client.PriceFxClient;\nimport net.pricefx.integration.api.client.builder.FetchFilterBuilder;\nimport net.pricefx.integration.api.client.model.FetchRequest;\nimport net.pricefx.integration.api.client.model.FetchResponse;\n\n@Service\npublic class TerminalsService {\n\n private final static Logger log = LoggerFactory.getLogger(TerminalsService.class);\n\n @Autowired\n private PriceFxClient priceFxClient;\n\n @SuppressWarnings(\"unchecked\")\n @Cacheable(value = \"terminalsCache\", key = \"#terminals\", sync = true, condition=\"!#terminals.isEmpty()\")\n public List> terminals(String terminals) {\n\n FetchRequest filter = new FetchFilterBuilder().create();\n\n try {\n FetchResponse response = priceFxClient.getLookuptableApi().fetchValue(Long.valueOf(\"3\"), filter);\n log.info(\"No terminals found in the cache. There is a need to call API!\");\n return (List>) response.getResponse().getData();\n } catch (Exception e) {\n e.printStackTrace();\n }\n\n return Arrays.asList();\n }\n\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"In this case the most important is @Cacheable annotation and its parameters:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"value ","type":"text","marks":[{"type":"strong"}]},{"text":"– Name of the cache.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"key –","type":"text","marks":[{"type":"strong"}]},{"text":" It can be your value which is the same as the method parameter. For example, this can be customerId or sku etc. It depends on which data you will cache. We are caching the entire table and the only key will be String \"terminals\", hence we will send such string to the method.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"sync","type":"text","marks":[{"type":"strong"}]},{"text":" – Defines if cache should be synchronized. We want it to be synchronized across of all apache threads.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"condition –","type":"text","marks":[{"type":"strong"}]},{"text":" Expression to decide when to return data from the cache and when not. For example: #terminals > 10. In this case if we would send some terminal ID as a parameter terminals which is below 10, the data will not go from the cache but the method code will run every time. In the opposite case, if we send the number 100 it will try to use a cached value if there is any.","type":"text"}]}]}]},{"type":"paragraph"},{"type":"paragraph","content":[{"text":"Now let's update our enricher processor class like this:","type":"text"}]},{"type":"paragraph","content":[{"text":"EnrichPRBean.java","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"package net.pricefx.integration.startup.processor;\n\n// imports ...\n\npublic class enrichPRBean {\n \n Logger logger = LoggerFactory.getLogger(enrichPRBean.class);\n\n @Autowired\n private TerminalsService terminalsServices;\n\n @Handler\n public void process(Exchange exchange){\n \t// logic...\n }\n\n private void fillTerminalNames(Map record) {\n List> terminals = terminalsServices.terminals(\"terminals\");\n\n String recordTerminalNumberOrigin = record.get(terminalNumberOrigin).toString();\n String recordTerminalNumberDestination = record.get(terminalNumberDestination).toString();\n\n for(Map terminal : terminals){\n if(terminal.get(\"name\").toString().equals(recordTerminalNumberOrigin)){\n record.put(\"terminalNameOrigin\", terminal.get(\"attribute3\"));\n }\n if(terminal.get(\"name\").toString().equals(recordTerminalNumberDestination)){\n record.put(\"terminalNameDestination\", terminal.get(\"attribute3\"));\n }\n }\n }\n}","type":"text"}]},{"type":"paragraph","content":[{"text":"Finally ensure you have @SpringBootApplication annotation in Application.java and you are ready to go.","type":"text"}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"Log output","type":"text"}]},{"type":"paragraph","content":[{"text":"Let's see the behavior in real time. We changed ttl to 30s for testing purposes.","type":"text"}]},{"type":"heading","attrs":{"level":5},"content":[{"text":"main.log","type":"text","marks":[{"type":"strong"}]}]},{"type":"codeBlock","content":[{"text":"Obtained 4 events.\n\n12:48:59.788 | INFO | Camel (camel-1) thread #20 - WireTap | archiveReceived_ITEM_UPDATED_PR_event | ID-Kadlec-MacBook-Pro-local-1564138094972-0-15 | n.p.integration.audit.AuditExchange | \n12:48:59.945 | INFO | Camel (camel-1) thread #21 - WireTap | HandleItemUpdatePR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-17 | HandleItemUpdatePR | PR was not accepted by customer hence not approved for export!\n12:49:00.682 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | DecideIfUpdateSpecialPricesPXTable | Received updated PR is not internal id! Updating SpecialPrices table! Obtained id: 122002\n12:49:00.683 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | DecideIfUpdateSpecialPricesPXTable | Going to enrich obtained PR to provide terminalNameOrigin and terminalNameDestination values!\n\n\nFirst event is about to be enriched hence API is called to obtain enrich table and it's cached for another 30s\n-------------------------\n12:49:01.086 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | n.p.i.s.service.TerminalsService | No terminals found in the cache. There is a need to call API!\n12:49:01.341 | INFO | Ehcache [_default_]-0 | | | n.p.i.s.config.CacheEventLogger | Cache event CREATED for item with key terminals.\n-------------------------\n\n12:49:01.346 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | DecideIfUpdateSpecialPricesPXTable | PR enriched!\n12:49:01.347 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | updateSpecialPricesPXTable | Uploading data to Special Prices PX table!\n12:49:02.399 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | n.p.i.api.client.PriceFxClient | Start loading data with type PX and size 1\n12:49:02.402 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | n.p.i.a.PriceFxExceptionTranslator | Loaddata of 1 ProductExtension with business key [name, sku, attribute2, attribute4, attribute6, attribute8, attribute9, attribute10]\n12:49:02.534 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | n.p.i.api.client.PriceFxClient | Done loading data with type PX and size 1\n12:49:02.535 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-13 | updateSpecialPricesPXTable | SpecialPrices data loaded to PX table!\n12:49:02.546 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | perEventTypeEventRouteOutputEventRouteITEM_UPDATE_PR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-11 | n.p.integration.audit.AuditExchange | \n12:49:02.571 | INFO | Camel (camel-1) thread #23 - WireTap | HandleItemUpdatePR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-25 | HandleItemUpdatePR | PR was not accepted by customer hence not approved for export!\n12:49:02.575 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | DecideIfUpdateSpecialPricesPXTable | Received updated PR is not internal id! Updating SpecialPrices table! Obtained id: 122002\n12:49:02.576 | INFO | Camel (camel-1) thread #22 - WireTap | archiveReceived_ITEM_UPDATED_PR_event | ID-Kadlec-MacBook-Pro-local-1564138094972-0-23 | n.p.integration.audit.AuditExchange | \n12:49:02.576 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | DecideIfUpdateSpecialPricesPXTable | Going to enrich obtained PR to provide terminalNameOrigin and terminalNameDestination values!\n12:49:03.105 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | DecideIfUpdateSpecialPricesPXTable | PR enriched!\n12:49:03.107 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | updateSpecialPricesPXTable | Uploading data to Special Prices PX table!\n12:49:03.112 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | n.p.i.api.client.PriceFxClient | Start loading data with type PX and size 1\n12:49:03.114 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | n.p.i.a.PriceFxExceptionTranslator | Loaddata of 1 ProductExtension with business key [name, sku, attribute2, attribute4, attribute6, attribute8, attribute9, attribute10]\n12:49:03.223 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | n.p.i.api.client.PriceFxClient | Done loading data with type PX and size 1\n12:49:03.229 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-21 | updateSpecialPricesPXTable | SpecialPrices data loaded to PX table!\n12:49:03.236 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | perEventTypeEventRouteOutputEventRouteITEM_UPDATE_PR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-19 | n.p.integration.audit.AuditExchange | \n12:49:03.285 | INFO | Camel (camel-1) thread #24 - WireTap | archiveReceived_ITEM_UPDATED_PR_event | ID-Kadlec-MacBook-Pro-local-1564138094972-0-31 | n.p.integration.audit.AuditExchange | \n12:49:03.292 | INFO | Camel (camel-1) thread #25 - WireTap | HandleItemUpdatePR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-33 | HandleItemUpdatePR | PR was not accepted by customer hence not approved for export!\n12:49:03.297 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | DecideIfUpdateSpecialPricesPXTable | Received updated PR is not internal id! Updating SpecialPrices table! Obtained id: 122002\n12:49:03.307 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | DecideIfUpdateSpecialPricesPXTable | Going to enrich obtained PR to provide terminalNameOrigin and terminalNameDestination values!\n12:49:03.493 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | DecideIfUpdateSpecialPricesPXTable | PR enriched!\n12:49:03.494 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | updateSpecialPricesPXTable | Uploading data to Special Prices PX table!\n12:49:03.501 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | n.p.i.api.client.PriceFxClient | Start loading data with type PX and size 1\n12:49:03.502 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | n.p.i.a.PriceFxExceptionTranslator | Loaddata of 1 ProductExtension with business key [name, sku, attribute2, attribute4, attribute6, attribute8, attribute9, attribute10]\n12:49:03.609 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | n.p.i.api.client.PriceFxClient | Done loading data with type PX and size 1\n12:49:03.619 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-29 | updateSpecialPricesPXTable | SpecialPrices data loaded to PX table!\n12:49:03.624 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | perEventTypeEventRouteOutputEventRouteITEM_UPDATE_PR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-27 | n.p.integration.audit.AuditExchange | \n12:49:03.697 | INFO | Camel (camel-1) thread #26 - WireTap | archiveReceived_ITEM_UPDATED_PR_event | ID-Kadlec-MacBook-Pro-local-1564138094972-0-39 | n.p.integration.audit.AuditExchange | \n12:49:03.750 | INFO | Camel (camel-1) thread #27 - WireTap | HandleItemUpdatePR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-41 | HandleItemUpdatePR | PR was not accepted by customer hence not approved for export!\n12:49:03.760 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | DecideIfUpdateSpecialPricesPXTable | Received updated PR is not internal id! Updating SpecialPrices table! Obtained id: 122002\n12:49:03.791 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | DecideIfUpdateSpecialPricesPXTable | Going to enrich obtained PR to provide terminalNameOrigin and terminalNameDestination values!\n12:49:04.025 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | DecideIfUpdateSpecialPricesPXTable | PR enriched!\n12:49:04.029 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | updateSpecialPricesPXTable | Uploading data to Special Prices PX table!\n12:49:04.036 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | n.p.i.api.client.PriceFxClient | Start loading data with type PX and size 1\n12:49:04.037 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | n.p.i.a.PriceFxExceptionTranslator | Loaddata of 1 ProductExtension with business key [name, sku, attribute2, attribute4, attribute6, attribute8, attribute9, attribute10]\n12:49:04.163 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | n.p.i.api.client.PriceFxClient | Done loading data with type PX and size 1\n12:49:04.164 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-37 | updateSpecialPricesPXTable | SpecialPrices data loaded to PX table!\n12:49:04.179 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | perEventTypeEventRouteOutputEventRouteITEM_UPDATE_PR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-35 | n.p.integration.audit.AuditExchange | \n\n\nSo all 4 events were enriched and sent to PFX but just one API call was needed to get that table. Enrich table is still in the cache...\n\n\nAnother obtained event after 30s or more\n\n12:49:42.361 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | DecideIfUpdateSpecialPricesPXTable | Received updated PR is not internal id! Updating SpecialPrices table! Obtained id: 122002\n12:49:42.364 | INFO | Camel (camel-1) thread #28 - WireTap | archiveReceived_ITEM_UPDATED_PR_event | ID-Kadlec-MacBook-Pro-local-1564138094972-0-117 | n.p.integration.audit.AuditExchange | \n12:49:42.364 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | DecideIfUpdateSpecialPricesPXTable | Going to enrich obtained PR to provide terminalNameOrigin and terminalNameDestination values!\n12:49:42.362 | INFO | Camel (camel-1) thread #29 - WireTap | HandleItemUpdatePR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-119 | HandleItemUpdatePR | PR was not accepted by customer hence not approved for export!\n\n\nBelow is a note that cached table expired and therefore there was a need to refresh data by new API call\n-------------------------\n12:49:42.723 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | n.p.i.s.service.TerminalsService | No terminals found in the cache. There is a need to call API!\n12:49:42.765 | INFO | Ehcache [_default_]-1 | | | n.p.i.s.config.CacheEventLogger | Cache event EXPIRED for item with key terminals.\n12:49:42.765 | INFO | Ehcache [_default_]-1 | | | n.p.i.s.config.CacheEventLogger | Cache event CREATED for item with key terminals.\n-------------------------\n\n12:49:42.766 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | DecideIfUpdateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | DecideIfUpdateSpecialPricesPXTable | PR enriched!\n12:49:42.766 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | updateSpecialPricesPXTable | Uploading data to Special Prices PX table!\n12:49:42.767 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | n.p.i.api.client.PriceFxClient | Start loading data with type PX and size 1\n12:49:42.768 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | n.p.i.a.PriceFxExceptionTranslator | Loaddata of 1 ProductExtension with business key [name, sku, attribute2, attribute4, attribute6, attribute8, attribute9, attribute10]\n12:49:42.874 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | n.p.i.api.client.PriceFxClient | Done loading data with type PX and size 1\n12:49:42.874 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | updateSpecialPricesPXTable | ID-Kadlec-MacBook-Pro-local-1564138094972-0-115 | updateSpecialPricesPXTable | SpecialPrices data loaded to PX table!\n12:49:42.875 | INFO | Camel (camel-1) thread #18 - file:///Users/kadlec/customer/tfg/events/ITEM_UPDATE_PR | perEventTypeEventRouteOutputEventRouteITEM_UPDATE_PR | ID-Kadlec-MacBook-Pro-local-1564138094972-0-113 | n.p.integration.audit.AuditExchange | ","type":"text"}]},{"type":"heading","attrs":{"level":1},"content":[{"text":"Final Thoughts","type":"text"}]},{"type":"paragraph","content":[{"text":"Maybe are you asking why we do it like this if we could ask only for records we are interested in using a filter on terminalNameOrigin or terminalNameDestination and return a name accordingly. But if there are some 1500k records in the enrichment table and we will be out of luck, 1500 API calls would be called and cached. It should be faster to fetch the entire table into the memory and then just iterate over it every time to find the proper record. ","type":"text"}]}],"version":1}

Browser not supported