summaryrefslogtreecommitdiff
path: root/java/client
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2007-08-06 13:06:35 +0000
committerRobert Godfrey <rgodfrey@apache.org>2007-08-06 13:06:35 +0000
commitcebc6af8f10ab4058de3065a8948f32da8d85811 (patch)
tree82dd84f571e7f32c79f3adbb813d3be4ddc3bc53 /java/client
parent7608aa32f97193b2c329c5ea4c9a51f77b6f2fc0 (diff)
downloadqpid-python-cebc6af8f10ab4058de3065a8948f32da8d85811.tar.gz
QPID-543 : Add ability to register cusom exchange types
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@563125 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
index 0ee4882ec2..3691e80234 100644
--- a/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
+++ b/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
@@ -138,7 +138,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j
_channelId = channelId;
_session = session;
_producerId = producerId;
- if (destination != null)
+ if (destination != null && !(destination instanceof AMQUndefinedDestination))
{
declareDestination(destination);
}
@@ -150,7 +150,7 @@ public class BasicMessageProducer extends Closeable implements org.apache.qpid.j
void resubscribe() throws AMQException
{
- if (_destination != null)
+ if (_destination != null && !(_destination instanceof AMQUndefinedDestination))
{
declareDestination(_destination);
}