Tema 12 - Disparadores de Flujo

Un flujo tiene un JMS Publish consume seguido de una operación JMS Publish. Los dos tienen la configuración por defecto.

¿Qué operación es asíncrona (no espera respuesta antes de continuar al siguiente proceso) y cuál es síncrona (bloquea el flujo esperando una respuesta o un timeout antes de continuar con el siguiente proceso)?

• Publish consume: Síncrona

  Publish: Asíncrona

• Publish consume: Síncrona

  Publish: Síncrona

• Publish consume: Asíncrona

  Publish: Asíncrona

• Publish consume: Asíncrona

  Publish: Síncrona

Observa la imagen. ¿Cuál sería el tipo de objeto retornado por la operación List File?

• Array de Strings con los nombres de los ficheros

• Un Objeto de Strings con los nombres de los ficheros

• Array de objetos de eventos Mule

• Objeto de eventos Mule

Observa la imagen. La carpeta /daily existe, está vacía actualmente, y los ficheros pueden ser leídos y escritos en esta carpeta por Anypoint Studio.

Esta aplicación se ejecuta en Anypoint Studio y escribe un fichero llamado productUpdate.txt en la carpeta /daily que contiene el texto "START".

¿Qué habrá en la carpeta /daily una vez se complete el flujo readDailyFile por primera vez?

• Un fichero llamado productUpdates.txt.bak que contiene el texto "START"

• Un fichero llamado productUpdates.txt.bak que contiene el texto "FINISHED"

• Un fichero llamado productUpdates.txt que contiene el texto "START" y un fichero llamado productUpdates.txt.bak que contiene el texto "START"

• Un fichero llamado productUpdates.txt que contiene el texto "START" y un fichero llamado productUpdates.txt.bak que contiene el texto "FINISHED"

Observa la imagen. Cuando el flujo se ejecuta, la función now() en el Transform Message devuelve "2021-08-26T13:32:10.64-07:00".

¿Qué se escribirá en el fichero records.csv cuando se ejecute el flujo?

• {

  "transaction_id": "SS-4848-44KK-4YQ",

  "account_id": "KA-382-SKD44",

  "name": "Max Mule",

  "position": "sell"

  }

• {

  "transaction_id": "SS-4848-44KK-4YQ",

  "account_id": "KA-382-SKD44",

  "name": "Max Mule",

  "position": "sell",

  "write_date": "2021-08-26T13:32:10.64-07:00"

  }

• transaction_id, account_id, name, position

  "SS-4848-44KK-4YQ","KA-382-SKD44", "Max Mule", "sell"

• transaction_id, account_id, name, position, write_date

  "SS-4848-44KK-4YQ","KA-382-SKD44", "Max Mule", "sell", "2021-08-26T13:32:10.64-07:00"

Una tabla de base de datos contiene una columna con valores que se incrementan a medida que se añaden nuevos registros a la tabla.

Se crea una aplicación de Mule para leer esta tabla.

¿Cuál sería el proceso clave para activar la watermark manual para peticiones hechas utilizando un Scheduler como disparador de Flujo y un componente Database Select?

• Activar la watermark automática en la operación de Database Select.

• Guardar el max recordID de la lista de record IDs guardados en un ObjectStore y hacer referencia a este recordID en posteriores consultas a la base de datos.

• Seleccionar la columna watermark en el Scheduler con el recordID.

• Guardar el max recordID de la lista de record IDs guardados en una variable y hacer referencia a este recordID en posteriores consultas a la base de datos.