diff options
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java')
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java b/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java index 241a9abc9b..6c954ec3df 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQTemporaryTopic.java @@ -20,6 +20,8 @@ */ package org.apache.qpid.client; +import org.apache.qpid.framing.AMQShortString; + import javax.jms.JMSException; import javax.jms.TemporaryTopic; @@ -36,7 +38,7 @@ class AMQTemporaryTopic extends AMQTopic implements TemporaryTopic, TemporaryDes */ public AMQTemporaryTopic(AMQSession session) { - super("TempQueue" + Long.toString(System.currentTimeMillis())); + super(session.getTemporaryTopicExchangeName(),new AMQShortString("TempQueue" + Long.toString(System.currentTimeMillis()))); _session = session; } |