En Mule, estoy descargando archivos desde el servidor FTP. Quiero pasar todos los archivos de este directorio a mi clase Java, que debería estar realizando acciones después de Download_ZIP_File en mi flujo. Necesito realizar acciones como leer archivos de texto y descomprimir los archivos comprimidos usando Java.

Debería haber una clase de Java en mi flujo, para lo cual se debería generar una llamada de función cuando se complete la descarga. El objeto de esta clase debe conocer toda la información sobre los archivos descargados.

¿Alguien por favor puede ayudar en esto? Aquí está mi flujo actual;

Mi XML para este flujo es así;

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

 <mule xmlns:ftp="http://www.mulesoft.org/schema/mule/ee/ftp"
        xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" 
        ... >
    <file:endpoint name="Download_File_KBB" responseTimeout="10000" doc:name="File" path="E:\csv\output"/>
    <file:connector name="Global_File_Connector" autoDelete="false" streaming="false" validateConnections="true" doc:name="File"/>
    <flow name="ftp_kbb_download_fileFlow1" doc:name="ftp_kbb_download_fileFlow1">
       <ftp:inbound-endpoint host="${ftp.host}" port="${ftp.port}" path="${ftp.pathInbound}" user="${ftp.user}" password="${ftp.password}" responseTimeout="10000" doc:name="KBB_FTP">
       </ftp:inbound-endpoint>
       <logger message="KBBUsedVehiclesNoSpecTabFormat-#[server.dateTime.year]-W#[server.dateTime.weekOfYear]" level="INFO" doc:name="Logger"/>
       <file:outbound-endpoint path="${file.inboundEndpoint}" outputPattern="#[header:originalFilename]" responseTimeout="10000" doc:name="Donwload_ZIP_FILE" connector-ref="Global_File_Connector"/>
    </flow>
  </mule>