जेएमएस कतार

Question

से एक संदेश को कैसे हटाएं मॉनिटरिंग एडमिन टूल का उपयोग किये बिना जेएमएस कतार से संदेश हटाने के लिए कोई एपीआई है।

Answer 1

एक QueueBrowser ऑब्जेक्ट आपको जो चाहिए वह हो सकता है। मुझे लगता है कि इसमें एक डिलीट विधि (या समान)

Answer 2

संदेश हटाने के लिए कोई प्रत्यक्ष API नहीं है। आप कतार से संदेश निकालने के लिए queueReceiver.receive() विधि को कॉल कर सकते हैं। QueueBrowser कतार से संदेशों को नहीं हटाएगा।

मैं तुम्हें एक संदेश किसी विशेष मापदंड से मेल खाते को हटाना चाहते संभालने हूँ:

Answer 3

यहाँ कुछ मैं काम करने के लिए हो सकता है।

destinationJNDI "CommonJmsServer1@jms.jndi.dq.NL_Notifications.NLNotificationReprocessQ" की तरह, कतार के JNDI नाम शामिल करना चाहिए:

Queue destination = session.createQueue("your_q"); 

QueueBrowser browser = session.createBrowser(destination); 

Enumeration<?> enum1 = browser.getEnumeration(); 

while(enum1.hasMoreElements()) 
{ 
    TextMessage msg = (TextMessage)enum1.nextElement(); 
    if(msg.getStringProperty("any_prop").equals("some_prop")) 
    { 
     MessageConsumer consumer = session.createConsumer(destination, "id='" + msg.getStringProperty("id") + "'"); 
     consumer.receive(1000); 
    } 
} 

Answer 4

यह कुछ है कि मैं वास्तव weblogic पर सफलतापूर्वक परीक्षण किया है।

    javax.jms.Queue queue = (javax.jms.Queue) ctx.lookup(destinationJNDI.toString()); 

    // lookup the queue connection factory 
    QueueConnectionFactory queueConnFactory = (QueueConnectionFactory) ctx.lookup(WEBLOGIC_JMS_XA_CONNECTION_FACTORY); 
    // create a queue connection 
    QueueConnection queueConn = queueConnFactory.createQueueConnection(); 
    queueConn.start(); 

    // create a queue session 
    Session queueSession = queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); 
    for (String id : idlist.split(",")) { 
     if (id.startsWith("ID:")) { 
     MessageConsumer consumer = queueSession.createConsumer(queue, " JMSMessageID='" + id + "'"); 
     Message message = consumer.receive(1000); 
     out.write("message = " + message + " "); 
     out.write("deleted ID " + id + " "); 
     } 
    } 
    queueSession.close(); 
    queueConn.close(); 


 

Answer 5

मैं:

    Properties env = new Properties(); 
    env.put(javax.naming.Context.PROVIDER_URL, PROVIDER_URL); 
    env.put(Context.SECURITY_PRINCIPAL, WL_USER); 
    env.put(Context.SECURITY_CREDENTIALS, WL_PASSWORD); 
    env.put(Context.INITIAL_CONTEXT_FACTORY, WL_INITIAL_CONTEXT_FACTORY); 
    InitialContext ctx = new InitialContext(env); 

 

idlist संदेश आईडी कि आप हटाना चाहते हैं की एक सीएसवी सूची होना चाहिए

इस कोड है:

ctx की तरह एक वैध InitialContext होना चाहिए उपभोक्ता को संदेश हटाने के लिए अतिरिक्त रूप से session.commit() पर कॉल करना पड़ा।

इसके अतिरिक्त, receivenowait एपीआई काम नहीं करता है; इसके बजाय receive(1000) पर कॉल करें।

यहाँ कोड का एक काम कर टुकड़ा मुझे लगता है कि लिखा jboss पर काम किया है:

try { 
    connection = connectionFactory.createConnection(); 
    session = connection.createSession(true,-1); 
    Queue queue = (Queue) QueueConnectionFactory.getInitialContext().lookup("/queue/DLQ"); 
    QueueBrowser browser = session.createBrowser(queue); 
    Enumeration<?> enum1 = browser.getEnumeration(); 

    while(enum1.hasMoreElements()) { 
    TextMessage msg = (TextMessage)enum1.nextElement(); 
    MessageConsumer consumer = session.createConsumer(queue, "JMSMessageID='" + msg.getJMSMessageID() + "'"); 
    //You can try starting the connection outside while loop as well, I think I started it inside while loop by mistake, but since this code worked I am hence letting you know what worked 
    connection.start(); 
    Message message = consumer.receive(1000) ; 
    if (message != null) { 
     //do something with message 
    } 
    } 
} 
finally { 
    session.commit(); 
    consumer.close(); 
    browser.close(); 
    session.close(); 
    connection.close(); 
}