установка переменной сеанса, доступной для всех сеансов сплиттера

Question

У меня есть ситуация, когда я читаю несколько файлов в одном потоке с помощью агрегатора сбора. Затем я использую сплиттер для разделения файлов для обработки по одному. Теперь я хочу поместить некоторые элементы файла в карту, и я хочу, чтобы эта карта была доступна для всех сеансов сплиттера, чтобы я мог заполнить ее для каждого файла.

, устанавливающий его с учетом объема обработки файла, после того как разделитель на нем делает его доступным для текущего сеанса обработки файлов. Тем не менее, я думал об объявлении переменной сеанса как null перед сплиттером. Будет ли это доступно для всех сеансов после разделения?

Я думаю, что это так, как я видел для первого процесса файла. Я также хочу знать, как установить переменную сеанса как null. Кажется, я не нашел его. Также будет оценено любое другое решение ситуации.

Вот мой поток:

<?xml version="1.0" encoding="UTF-8"?> 

<mule xmlns:json="http://www.mulesoft.org/schema/mule/json" 
    xmlns:mulexml="http://www.mulesoft.org/schema/mule/xml" 
    xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" 
    xmlns:spring="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd 
http://www.mulesoft.org/schema/mule/xml http://www.mulesoft.org/schema/mule/xml/current/mule-xml.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd 
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd"> 
    <flow name="dictionary_keywordsFlow"> 
     <file:inbound-endpoint path="D:\mJunction\CATALOG INTEGRATION TO BE MODIFIED\sOURCE FILES\Read_dir" connector-ref="Filefinal" pollingFrequency="10000" responseTimeout="10000" doc:name="File" moveToDirectory="D:\mJunction\CATALOG INTEGRATION TO BE MODIFIED\sOURCE FILES\Read_dir\backup"> 
      <file:filename-regex-filter pattern="BSL.*" caseSensitive="true"/> 
     </file:inbound-endpoint> 
     <!-- <set-session-variable value="#[message.inboundProperties['originalFilename']]" variableName="filename" doc:name="Session Variable" /> --> 
     <set-property propertyName="MULE_CORRELATION_ID" value="#[message.inboundProperties['originalFilename']]" doc:name="Property"/> 
     <collection-aggregator failOnTimeout="true" doc:name="Collection Aggregator"/> 
     <!-- <custom-transformer class="AddContainerMapSessionvalue" doc:name="Java"/> --> 
     <splitter expression="#[payload]" doc:name="Splitter"/> 
      <logger message="&gt;&gt;&gt; flow to extract keywords and create dictionary" level="INFO" doc:name="Logger"/> 
      <logger message="Payload received for maeterial list is #[payload]" level="INFO" doc:name="Original Payload"/> 
      <splitter expression="#[xpath3('//CATALOGUE',payload,'NODESET')]" doc:name="Splitter"/> 
      <mulexml:dom-to-xml-transformer doc:name="DOM to XML"/> 
      <json:xml-to-json-transformer doc:name="XML to JSON"/> 
      <json:json-to-object-transformer returnClass="java.util.Map" doc:name="JSON to Object"/> 
      <logger message="payload is #[payload]" level="INFO" doc:name="Logger"/> 
      <custom-transformer class="com.mjunction.transformers.DictionarykeywordsGenerator" doc:name="Java"/> 
      <logger message="payload is #[payload]" level="INFO" doc:name="Logger"/> 
      <logger message="session variable is #[sessionVars.container_map]" level="INFO" doc:name="Logger"/> 
      <json:object-to-json-transformer doc:name="Object to JSON"/> 
      <file:outbound-endpoint path="src/main/resources/dictionaryfiles/output" outputPattern="output.txt" connector-ref="Filefinal" responseTimeout="10000" doc:name="File"/> 




    </flow> 
</mule> 

Спасибо, Arun

Answer 1

Вы можете определить нулевой сеанс переменный, как показано ниже

<set-session-variable variableName="fileName" value="#['']" doc:name="Session Variable"/>. 

Да, если определить сеанс переменного до разветвителя и хранения карты (надеясь, что вы получите эту карту от начальной полезной нагрузки) будут доступны через сеанс.

После сплиттера, если вы используете сеанс, каждый раз, если структура полезной нагрузки, в которой вы извлекаете и сохраняете в сеансе, такая же, вне курса, она переопределяет, в таком случае вы можете использовать концепцию типа кэша. Обратите внимание: https://docs.mulesoft.com/mule-user-guide/v/3.7/cache-scope, or Когда вы храните его для раскола firstTime и используете случай для следующих сеансов, выполните небольшую проверку состояния #[sessionVars['fileName'] != null? 'true':'']. На основании этого вы можете построить ожидающую логику.