Как перестать получать сообщения, удаленные без подтверждения в Oracle AQ? - PullRequest
Новая
       30

Как перестать получать сообщения, удаленные без подтверждения в Oracle AQ?

0 голосов
/ 24 февраля 2020

Я настроил одного клиента Oracle AQ. Я наблюдаю сообщения из этой очереди в веб-приложении Java с режимом CLIENT_ACKNOWLEDGE. Но как только я получаю сообщения в методе onMessage, кажется, что сообщения удаляются из очереди Oracle. Я предполагаю, что сообщение не должно быть удалено, если я не acknowledge их в клиенте. Как мне это остановить?

Oracle Схема очереди выглядит следующим образом: 

BEGIN DBMS_AQADM.CREATE_QUEUE_TABLE(
  Queue_table => '"TESTUSER"."myqueuetable"', 
  Queue_payload_type => 'TESTUSER.messageobject', 
  multiple_consumers => false
);
END;
/

BEGIN DBMS_AQADM.CREATE_QUEUE(
  Queue_name => 'TESTUSER.myqueue', 
  Queue_table => 'TESTUSER.myqueuetable', 
  Queue_type => 0, Max_retries => 5, Retry_delay => 0
);
END;
/

BEGIN dbms_aqadm.start_queue (
  queue_name => 'testuser.myqueue'
);
END;

Я наблюдаю за сообщениями в моем Java приложении, как это 

 //somewhere in my app
session = queueConnection.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
queueReceiver = ((AQjmsSession) databaseConnectionManager.getSession())
 .createReceiver(databaseConnectionManager.getQueue(), Messageobject.getORADataFactory());
queueReceiver.setMessageListener(this);


//in my listener class
@Override
public void onMessage(Message message) {
 AdtMessage msg = (AdtMessage) message;

 try {
  Messageobject message = (Messageobject) msg.getAdtPayload();

  if (isUserConnected(message.userId)) {
   logger.debug("Message acknowledged");
   msg.acknowledge();
   //handle the message. the message should be deleted now.
  } else {
   //i don't want the message to be deleted
  }

 } catch (JMSException | IllegalArgumentException | SQLException e) {
  logger.error("An error occurred while sending an outgoing blob", e);
 }
}
...