WebSphere MQ MessageListener (Ähnlich wie JMS Message Listener)

Habe ich die MQConsumerClass abrufen der Nachrichten aus der Warteschlange wie folgt.

while (running)
{
    try
    {
        MQMessage rcvMessage = new MQMessage();
        MQGetMessageOptions gmo = new MQGetMessageOptions();

        gmo.options = MQConstants.MQGMO_WAIT;
        gmo.waitInterval = 60000; 
        queue.get(rcvMessage, gmo);

        if(rcvMessage.getTotalMessageLength() > 0)
        {
            String msgText = rcvMessage.readUTF();
        }
    }
    catch blocks{}
}

Aber das problem ist, wenn es keine Nachricht in der queue, die 2033 Ausnahme geworfen wird.

Ich denke 2033 NO_MSG_AVAILABLE Ausnahme ist NICHT ernst Ausnahme, wahrscheinlich können Sie den Vorgang beenden.

Jedoch möchte ich nennen onMessage(Message msg) Funktion, sobald eine neue message in der queue.

Möchte ich diese Klasse erstellt mit MessageListener aber ich kann nicht finden, MessageListener oder irgendein Beispiel, die damit verbunden sind.

So, bitte sagen Sie mir, wenn es irgendeine MessageListener-Funktion in ein Fehler in WMQ Java-API.

oder

irgendeiner Weise, dies zu tun?

InformationsquelleAutor Lwin Htoo Ko | 2012-06-29
Schreibe einen Kommentar