You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by vi...@apache.org on 2006/12/29 00:42:59 UTC
svn commit: r490872 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java
Author: vinoski
Date: Thu Dec 28 15:42:59 2006
New Revision: 490872
URL: http://svn.apache.org/viewvc?view=rev&rev=490872
Log:
apply patch for QPID-231
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java
Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java?view=diff&rev=490872&r1=490871&r2=490872
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QueueSenderAdapter.java Thu Dec 28 15:42:59 2006
@@ -132,10 +132,6 @@
throw new javax.jms.IllegalStateException("Publisher is closed");
}
- if(queue == null){
- throw new UnsupportedOperationException("Queue is null");
- }
-
AMQSession session = ((BasicMessageProducer) _delegate).getSession();
if(session == null || session.isClosed()){