From cebc6af8f10ab4058de3065a8948f32da8d85811 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 6 Aug 2007 13:06:35 +0000 Subject: 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 --- .../src/main/java/org/apache/qpid/client/BasicMessageProducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'java/client') 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); } -- cgit v1.2.1