You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2012/02/27 23:27:40 UTC
svn commit: r1294370 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
Author: rgodfrey
Date: Mon Feb 27 22:27:40 2012
New Revision: 1294370
URL: http://svn.apache.org/viewvc?rev=1294370&view=rev
Log:
QPID-2020 : [Java Client] create[Durable]ConnectionConsumer should throw JMSException, not return null (until such time as QPID-3693 is completed)
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java?rev=1294370&r1=1294369&r2=1294370&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java Mon Feb 27 22:27:40 2012
@@ -968,7 +968,8 @@ public class AMQConnection extends Close
{
checkNotClosed();
- return null;
+ throw new JmsNotImplementedException();
+
}
public ConnectionConsumer createConnectionConsumer(Queue queue, String messageSelector, ServerSessionPool sessionPool,
@@ -976,7 +977,7 @@ public class AMQConnection extends Close
{
checkNotClosed();
- return null;
+ throw new JmsNotImplementedException();
}
public ConnectionConsumer createConnectionConsumer(Topic topic, String messageSelector, ServerSessionPool sessionPool,
@@ -984,7 +985,7 @@ public class AMQConnection extends Close
{
checkNotClosed();
- return null;
+ throw new JmsNotImplementedException();
}
public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String subscriptionName, String messageSelector,
@@ -993,7 +994,7 @@ public class AMQConnection extends Close
// TODO Auto-generated method stub
checkNotClosed();
- return null;
+ throw new JmsNotImplementedException();
}
public long getMaximumChannelCount() throws JMSException
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org