activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r631240 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
Date Tue, 26 Feb 2008 14:55:46 GMT
Author: rajdavies
Date: Tue Feb 26 06:55:45 2008
New Revision: 631240

URL: http://svn.apache.org/viewvc?rev=631240&view=rev
Log:
removed tmp destination tests - the check is done client side now

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java?rev=631240&r1=631239&r2=631240&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java
Tue Feb 26 06:55:45 2008
@@ -737,48 +737,7 @@
     //        
     // }
 
-    public void initCombosForTestTempDestinationsOnlyAllowsLocalConsumers() {
-        addCombinationValues("deliveryMode", new Object[] {Integer.valueOf(DeliveryMode.NON_PERSISTENT),
-                                                           Integer.valueOf(DeliveryMode.PERSISTENT)});
-        addCombinationValues("destinationType",
-                             new Object[] {Byte.valueOf(ActiveMQDestination.TEMP_QUEUE_TYPE),
-                                           Byte.valueOf(ActiveMQDestination.TEMP_TOPIC_TYPE)});
-    }
-
-    public void testTempDestinationsOnlyAllowsLocalConsumers() throws Exception {
-
-        // Setup a first connection
-        StubConnection connection1 = createConnection();
-        ConnectionInfo connectionInfo1 = createConnectionInfo();
-        SessionInfo sessionInfo1 = createSessionInfo(connectionInfo1);
-        connection1.send(connectionInfo1);
-        connection1.send(sessionInfo1);
-
-        DestinationInfo destinationInfo = createTempDestinationInfo(connectionInfo1, destinationType);
-        connection1.request(destinationInfo);
-        destination = destinationInfo.getDestination();
-
-        // Setup a second connection
-        StubConnection connection2 = createConnection();
-        ConnectionInfo connectionInfo2 = createConnectionInfo();
-        SessionInfo sessionInfo2 = createSessionInfo(connectionInfo2);
-        connection2.send(connectionInfo2);
-        connection2.send(sessionInfo2);
-
-        // Only consumers local to the temp destination should be allowed to
-        // subscribe.
-        try {
-            ConsumerInfo consumerInfo2 = createConsumerInfo(sessionInfo2, destination);
-            connection2.request(consumerInfo2);
-            fail("Expected JMSException.");
-        } catch (JMSException success) {
-        }
-
-        // This should succeed since it's local.
-        ConsumerInfo consumerInfo1 = createConsumerInfo(sessionInfo1, destination);
-        connection1.send(consumerInfo1);
-    }
-
+    
     public void initCombosForTestExclusiveQueueDeliversToOnlyOneConsumer() {
         addCombinationValues("deliveryMode", new Object[] {Integer.valueOf(DeliveryMode.NON_PERSISTENT),
                                                            Integer.valueOf(DeliveryMode.PERSISTENT)});



Mime
View raw message