activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1422112 - in /activemq/activemq-apollo/trunk/apollo-amqp/src: main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala test/scala/org/apache/activemq/apollo/amqp/test/QpidJmsTest.scala
Date Fri, 14 Dec 2012 21:56:49 GMT
Author: chirino
Date: Fri Dec 14 21:56:47 2012
New Revision: 1422112

URL: http://svn.apache.org/viewvc?rev=1422112&view=rev
Log:
Fixes failing amqp test.

Modified:
    activemq/activemq-apollo/trunk/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
    activemq/activemq-apollo/trunk/apollo-amqp/src/test/scala/org/apache/activemq/apollo/amqp/test/QpidJmsTest.scala

Modified: activemq/activemq-apollo/trunk/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala?rev=1422112&r1=1422111&r2=1422112&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-amqp/src/main/scala/org/apache/activemq/apollo/amqp/AmqpProtocolHandler.scala
Fri Dec 14 21:56:47 2012
@@ -190,7 +190,7 @@ class AmqpProtocolHandler extends Protoc
   }
 
   var amqp_connection:AmqpTransport = _
-  var amqp_trace = true
+  var amqp_trace = false
 
   def codec = connection.transport.getProtocolCodec.asInstanceOf[AmqpProtocolCodec]
 

Modified: activemq/activemq-apollo/trunk/apollo-amqp/src/test/scala/org/apache/activemq/apollo/amqp/test/QpidJmsTest.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-amqp/src/test/scala/org/apache/activemq/apollo/amqp/test/QpidJmsTest.scala?rev=1422112&r1=1422111&r2=1422112&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-amqp/src/test/scala/org/apache/activemq/apollo/amqp/test/QpidJmsTest.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-amqp/src/test/scala/org/apache/activemq/apollo/amqp/test/QpidJmsTest.scala
Fri Dec 14 21:56:47 2012
@@ -140,7 +140,12 @@ class QpidJmsTest extends AmqpTestSuppor
     val queue = new QueueImpl("queue://txqueue")
     val connection = createConnection()
     val session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
-    session.unsubscribe("does not exist")
+    try {
+      session.unsubscribe("does not exist")
+      fail("expected an InvalidDestinationException")
+    } catch {
+      case e:InvalidDestinationException =>
+    }
     connection.close
   }
 



Mime
View raw message