Consume Operation Message

MessageConsumer.java

@Component
@RequiredArgsConstructor
public class OperationMessageConsumer {

  private static final LoggerService LOGGER = LoggerServiceFactory.getLoggerService(OperationMessageConsumer.class);

  private final MyExternalService service;
  private static final ObjectMapper MAPPER = new ObjectMapper();

  @RabbitListener(id = LISTENER_ID, queues = Queues.OPERATIONS, containerFactory = "rabbitListener")
  public void handlePspCallMessage(Message message) throws IOException {
    OperationMessage operationMessage = MAPPER.readerFor(OperationMessage.class).read(message.getBody());
    service.doWhatYouNeed(operationMessage);
  }
}