Add a few more test variations Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/dd57a725 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/dd57a725 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/dd57a725
Branch: refs/heads/master Commit: dd57a7250f9ce55cec99eadcc57ff0a68928d46d Parents: 5311cd7 Author: Timothy Bish <[email protected]> Authored: Mon Feb 2 16:56:01 2015 -0500 Committer: Timothy Bish <[email protected]> Committed: Mon Feb 2 16:56:01 2015 -0500 ---------------------------------------------------------------------- .../qpid/jms/JmsConnectionTestSupport.java | 11 +++ .../apache/qpid/jms/session/JmsSessionTest.java | 72 ++++++++++++++++++++ 2 files changed, 83 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/dd57a725/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java index 1605067..a4a4ef5 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsConnectionTestSupport.java @@ -125,6 +125,17 @@ public class JmsConnectionTestSupport extends QpidJmsTestCase { } }).when(provider).setProviderListener(Mockito.any(ProviderListener.class)); + Mockito.doAnswer(new Answer<Object>() { + @Override + public Object answer(InvocationOnMock invocation) throws Throwable { + Object[] args = invocation.getArguments(); + LOG.trace("Handling provider destroy resource: {}", args[0]); + ProviderFuture request = (ProviderFuture) args[1]; + request.onSuccess(); + return null; + } + }).when(provider).unsubscribe(Mockito.anyString(), Mockito.any(ProviderFuture.class)); + Mockito.when(provider.getProviderListener()).thenReturn(providerListener); Mockito.when(provider.getMessageFactory()).thenReturn(new JmsDefaultMessageFactory()); } http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/dd57a725/qpid-jms-client/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java index 7867474..5a0c945 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/session/JmsSessionTest.java @@ -26,7 +26,9 @@ import javax.jms.IllegalStateException; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; +import javax.jms.ObjectMessage; import javax.jms.Session; +import javax.jms.TextMessage; import org.apache.qpid.jms.JmsConnectionTestSupport; import org.apache.qpid.jms.JmsSession; @@ -74,6 +76,7 @@ public class JmsSessionTest extends JmsConnectionTestSupport { public void testIsAutoAcknowledge() throws JMSException { JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); assertTrue(session.isAutoAcknowledge()); + assertFalse(session.isClientAcknowledge()); assertFalse(session.isDupsOkAcknowledge()); } @@ -81,10 +84,19 @@ public class JmsSessionTest extends JmsConnectionTestSupport { public void testIsDupsOkAcknowledge() throws JMSException { JmsSession session = (JmsSession) connection.createSession(false, Session.DUPS_OK_ACKNOWLEDGE); assertFalse(session.isAutoAcknowledge()); + assertFalse(session.isClientAcknowledge()); assertTrue(session.isDupsOkAcknowledge()); } @Test(timeout = 10000) + public void testIsClientAcknowledge() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + assertFalse(session.isAutoAcknowledge()); + assertTrue(session.isClientAcknowledge()); + assertFalse(session.isDupsOkAcknowledge()); + } + + @Test(timeout = 10000) public void testIsTransacted() throws JMSException { JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); assertFalse(session.isTransacted()); @@ -109,4 +121,64 @@ public class JmsSessionTest extends JmsConnectionTestSupport { JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); session.commit(); } + + @Test(timeout = 10000) + public void testCreateMessage() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + assertNotNull(session.createMessage()); + } + + @Test(timeout = 10000) + public void testCreateBytesMessage() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + assertNotNull(session.createBytesMessage()); + } + + @Test(timeout = 10000) + public void testCreateStreamMessage() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + assertNotNull(session.createStreamMessage()); + } + + @Test(timeout = 10000) + public void testCreateMapMessage() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + assertNotNull(session.createMapMessage()); + } + + @Test(timeout = 10000) + public void testCreateObjectMessage() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + assertNotNull(session.createObjectMessage()); + } + + @Test(timeout = 10000) + public void testCreateObjectMessageWithValue() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + ObjectMessage message = session.createObjectMessage("TEST-MESSAGE"); + assertNotNull(message); + assertNotNull(message.getObject()); + assertTrue(message.getObject() instanceof String); + assertEquals("TEST-MESSAGE", message.getObject()); + } + + @Test(timeout = 10000) + public void testCreateTextMessage() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + assertNotNull(session.createTextMessage()); + } + + @Test(timeout = 10000) + public void testCreateTextMessageWithValue() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + TextMessage message = session.createTextMessage("TEST-MESSAGE"); + assertNotNull(message); + assertEquals("TEST-MESSAGE", message.getText()); + } + + @Test(timeout = 10000) + public void testUnsubscribe() throws JMSException { + JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + session.unsubscribe("some-subscription"); + } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
