Examples of javax.jms.Message.acknowledge()

javax.jms.Message.acknowledge()


        resendMessagesIfNecessary();


        // tests whether receiving and acknowledgment is working after recover
        lastMessage = consumeMessages();
        lastMessage.acknowledge();
    }


    /**
     * Test that calling acknowledge before failover leaves the session
     * clean for use after failover.

View Full Code Here


        produceMessages();


        // consume messages and acknowledge them
        Message lastMessage = consumeMessages();
        lastMessage.acknowledge();


        causeFailure();


        assertFailoverException();

View Full Code Here


        produceMessages();


        // tests whether receiving and acknowledgment is working after recover
        lastMessage = consumeMessages();
        lastMessage.acknowledge();
    }


    /**
     * Test that receiving of messages after failover prior to calling
     * {@link Message#acknowledge()} still results in acknowledge throwing an exception.

View Full Code Here

        // consume again on dirty session
        Message lastMessage = consumeMessages();
        try
        {
            // an implicit recover performed when acknowledge throws an exception due to failover 
            lastMessage.acknowledge();
            fail("JMSException should be thrown");
        }
        catch (JMSException t)
        {
            // TODO: assert error code and/or expected exception type

View Full Code Here

            // TODO: assert error code and/or expected exception type
        }


        // tests whether receiving and acknowledgment is working on a clean session
        lastMessage = consumeMessages();
        lastMessage.acknowledge();
    }


    /**
     * Tests that call to {@link Message#acknowledge()} after failover throws an exception in asynchronous consumer
     * and we can consume messages after acknowledge.

View Full Code Here

        assertFailoverException();




        try
        {
            currentMessage.acknowledge();
            fail("JMSException should be thrown!");
        }
        catch (JMSException e)
        {
            // TODO: assert error code and/or expected exception type

View Full Code Here

            assertReceivedMessage(message, TEST_MESSAGE_FORMAT, counter++);
            currentMessage = message;
        }


        // acknowledge again. It should be successful
        currentMessage.acknowledge();
    }


    /**
     * Test whether {@link Session#recover()} works as expected after failover
     * in AA mode.

View Full Code Here

    }


    public void testPublishClientAcknowledgedWhileFailover() throws Exception
    {
        Message receivedMessage = publishWhileFailingOver(Session.CLIENT_ACKNOWLEDGE);
        receivedMessage.acknowledge();
    }


    public void testPublishTransactedAcknowledgedWhileFailover() throws Exception
    {
        publishWhileFailingOver(Session.SESSION_TRANSACTED);

View Full Code Here

            (MessageType.JMQ_MESSAGE_TYPE, MessageType.CREATE_DESTINATION);
        requestMesg.setObject(di);
        sender.send(requestMesg);


        replyMesg = receiver.receive(timeout);
        replyMesg.acknowledge();


        checkReplyTypeStatus(replyMesg,
                             MessageType.CREATE_DESTINATION_REPLY,
                             "CREATE_DESTINATION_REPLY");
    }

View Full Code Here

        requestMesg.setIntProperty(MessageType.JMQ_DEST_TYPE, 
           this.getDestTypeMask(type, null));
        sender.send(requestMesg);


        replyMesg = receiver.receive(timeout);
        replyMesg.acknowledge();


        checkReplyTypeStatus(replyMesg,
            MessageType.DESTROY_DESTINATION_REPLY,
            "DESTROY_DESTINATION_REPLY");
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.