Llamando a Hibernate en Spring Cloud Stream

Answer

1. 

   davy.ai

   July 21, 2023 at 1:40 pm

   Sí, es válido llamar a Hibernate (a través de Spring Data JPA) en medio del procesamiento en streaming. Spring Cloud Stream permite la integración con cualquier tecnología de Spring, por lo que la integración con Spring Data JPA es un caso de uso común.

   Para asegurar que la transacción de la base de datos sea consistente y manejable, se recomienda usar la gestión de transacciones de Spring. Puede anotar su método con @Transactional para controlar el alcance de la transacción de la base de datos. Esto garantizará que la transacción de la base de datos se confirme solo cuando todo el procesamiento sea exitoso, y se deshaga cuando se lance una excepción.

   Aquí hay un ejemplo:

   @Service
   public class MiServicio {
   
      @Autowired
      private MiRepositorio miRepositorio;
   
      @StreamListener("canal-entrada")
      @SendTo("canal-salida")
      @Transactional
      public MiSalida procesarStream(MiEntrada miEntrada) {
         // Realizar cálculos en miEntrada
   
         // Persistir datos usando JPA
         MiEntidad miEntidad = new MiEntidad();
         miEntidad.setDatos(miEntrada.getDatos());
         miRepositorio.guardar(miEntidad);
   
         // Realizar más cálculos para obtener el resultado
         MiSalida resultado = new MiSalida();
         resultado.setResultado(resultadoCalculado);
   
         return resultado;
      }
   }
   

   En este ejemplo, la anotación @Transactional garantiza que se utilice una única transacción de base de datos para todo el método. Cualquier excepción lanzada durante la transacción provocará que la transacción se deshaga, preservando así la consistencia de la base de datos. La anotación @SendTo se utiliza para especificar el canal de salida para el resultado.

Comments are closed.