0
Java에서 소비자 코드와 함께 Oracle AQ를 사용하고 있습니다.대기열이 일단 제거되면 소모되지 않습니까?
큐가 여전히 데이터베이스에 남아있는 이유는 무엇입니까? 큐를 사용하면 큐가 제거되도록하기 위해 어떤 호출을해야합니까?
QueueConnection myqueue = getConnection();
Session session = myqueue.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
myqueue.start();
queue = ((AQjmsSession) session).getQueue("demo", "myqueue");
MessageConsumer consumer = session.createConsumer(queue);
TextMessage msg = (TextMessage) consumer.receive();
System.out.println("message" + msg.getText());
consumer.close();
session.close();
myqueue.close();
고마워요!