Produce Message

MessageProducer.java

@Component
@RequiredArgsConstructor
public class CreateOperationRabbitMessage {
  
  private static final LoggerService LOGGER = LoggerServiceFactory.getLoggerService(CreateOperationRabbitMessage.class);

  private final RabbitTemplate rabbitTemplate;
  private static final ObjectMapper MAPPER = new ObjectMapper();

  @Override
  public boolean sendMessage(OperationMessage operationMessage) {
    try {
      String orderJson = MAPPER.writeValueAsString(operationMessage);
      Message message = MessageBuilder
          .withBody(orderJson.getBytes())
          .setContentType(MessageProperties.CONTENT_TYPE_JSON)
          .build();
      rabbitTemplate
          .convertAndSend(Exchanges.OPERATIONS_EXCHANGE,
              Exchanges.OPERATION_ROUTING_KEY,
              message);
      return true;
    } catch (AmqpException e) {
      LOGGER.warn(() -> "Error sending message to RabbitMQ");
      LOGGER.debug(() -> "Error sending message to RabbitMQ", e);
    } catch (JsonProcessingException e) {
      LOGGER.warn(() -> "Error converting message to JSON");
      LOGGER.debug(() -> "Error sending message to RabbitMQ", e);
    }
    return false;
  }

}