Tenho uma Fila JMS que envia documentos para uma API externa, o que parece que esta ocorrendo e que a fila esta duplicando estas chamadas quando a fila recebe muitas requisições de uma só vez, e a chamada demora um pouco a processar, ja li um pouco sobre o assunto na internet, porém ainda não consegui resolver, quem puder ajudar agradeço.
segue o trecho que executa a fila:
@MessageDriven(activationConfig = { @ActivationConfigProperty(propertyName = “destination”, propertyValue = “java:/jms/docTransport”) , @ActivationConfigProperty(propertyName = “destinationType”, propertyValue = “javax.jms.Queue”) } )@TransactionManagement(TransactionManagementType.BEAN)
public class DocTansportMdb implements MessageListener {private Logger log =
Logger.getLogger(DocTansportMdb.class);public void onMessage(Message message) { DocRequestDto dto = null; try { dto = message.getBody(DocTansportMdb.class); message.acknowledge();log.info("Processando..."); long startTime = System.nanoTime(); execute(dto); long endTime = System.nanoTime(); long duration = (endTime - startTime); log.info("Processado em " + (duration / 1000000) + " milisegundos"); } catch (JMSException e) { log.error(e.getMessage(), e); } finally { log.info("<< DocTansportMdbBloco de citação
.onMessage()"); } } }