[jboss-cvs] JBoss Messaging SVN: r4448 - trunk/tests/src/org/jboss/messaging/tests/unit/jms.

[jboss-cvs-commits at lists.jboss.org]

Author: jmesnil
Date: 2008-06-12 11:46:38 -0400 (Thu, 12 Jun 2008)
New Revision: 4448

Added:
   trunk/tests/src/org/jboss/messaging/tests/unit/jms/JBossTemporaryTopicTest.java
Log:
added unit test for JBossTemporaryTopic

Added: trunk/tests/src/org/jboss/messaging/tests/unit/jms/JBossTemporaryTopicTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/jms/JBossTemporaryTopicTest.java	                        (rev 0)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/jms/JBossTemporaryTopicTest.java	2008-06-12 15:46:38 UTC (rev 4448)
@@ -0,0 +1,101 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Distributable under LGPL license.
+ * See terms of license at gnu.org.
+ */
+package org.jboss.messaging.tests.unit.jms;
+
+import static org.easymock.EasyMock.createStrictMock;
+import static org.easymock.EasyMock.expect;
+import static org.easymock.EasyMock.replay;
+import static org.easymock.EasyMock.verify;
+import static org.jboss.messaging.tests.util.RandomUtil.randomString;
+
+import java.util.ArrayList;
+
+import javax.jms.Session;
+
+import junit.framework.TestCase;
+
+import org.jboss.messaging.core.client.ClientConnection;
+import org.jboss.messaging.core.client.ClientSession;
+import org.jboss.messaging.core.remoting.impl.wireformat.SessionBindingQueryResponseMessage;
+import org.jboss.messaging.jms.JBossTemporaryTopic;
+import org.jboss.messaging.jms.client.JBossConnection;
+import org.jboss.messaging.jms.client.JBossSession;
+import org.jboss.messaging.util.SimpleString;
+
+/**
+ * @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
+ * 
+ * @version <tt>$Revision$</tt>
+ * 
+ */
+public class JBossTemporaryTopicTest extends TestCase
+{
+   // Constants -----------------------------------------------------
+
+   // Attributes ----------------------------------------------------
+
+   // Static --------------------------------------------------------
+
+   // Constructors --------------------------------------------------
+
+   // Public --------------------------------------------------------
+
+   public void testIsTemporary() throws Exception
+   {
+      String topicName = randomString();
+
+      ClientConnection clientConn = createStrictMock(ClientConnection.class);
+      ClientSession clientSession = createStrictMock(ClientSession.class);
+      replay(clientConn, clientSession);
+
+      JBossConnection connection = new JBossConnection(clientConn,
+            JBossConnection.TYPE_TOPIC_CONNECTION, null, -1);
+      JBossSession session = new JBossSession(connection, false, false,
+            Session.AUTO_ACKNOWLEDGE, clientSession,
+            JBossSession.TYPE_TOPIC_SESSION);
+      JBossTemporaryTopic tempTopic = new JBossTemporaryTopic(session,
+            topicName);
+      assertEquals(true, tempTopic.isTemporary());
+
+      verify(clientConn, clientSession);
+   }
+
+   public void testDelete() throws Exception
+   {
+      String topicName = randomString();
+      SimpleString topicAddress = new SimpleString(
+            JBossTemporaryTopic.JMS_TEMP_TOPIC_ADDRESS_PREFIX + topicName);
+
+      ClientConnection clientConn = createStrictMock(ClientConnection.class);
+      ClientSession clientSession = createStrictMock(ClientSession.class);
+      SessionBindingQueryResponseMessage resp = new SessionBindingQueryResponseMessage(
+            true, new ArrayList<SimpleString>());
+      expect(clientSession.bindingQuery(topicAddress)).andReturn(resp);
+      clientSession.removeDestination(topicAddress, true);
+
+      replay(clientConn, clientSession);
+
+      JBossConnection connection = new JBossConnection(clientConn,
+            JBossConnection.TYPE_TOPIC_CONNECTION, null, -1);
+      JBossSession session = new JBossSession(connection, false, false,
+            Session.AUTO_ACKNOWLEDGE, clientSession,
+            JBossSession.TYPE_TOPIC_SESSION);
+      JBossTemporaryTopic tempTopic = new JBossTemporaryTopic(session,
+            topicName);
+      tempTopic.delete();
+
+      verify(clientConn, clientSession);
+   }
+   
+   // Package protected ---------------------------------------------
+
+   // Protected -----------------------------------------------------
+
+   // Private -------------------------------------------------------
+
+   // Inner classes -------------------------------------------------
+}