From 4d1416cfd49aae6b3310d60d2357c26c56fd8918 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Thu, 1 Feb 2007 09:37:39 +0000 Subject: QPID-333 Committed test class rename to stop it being picked up by Surefire AMQTopic.java - whitespace git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@502172 13f79535-47bb-0310-9956-ffa450edef68 --- java/client/src/main/java/org/apache/qpid/client/AMQTopic.java | 10 +++++----- .../java/org/apache/qpid/client/message/MessageConverter.java | 5 +++-- 2 files changed, 8 insertions(+), 7 deletions(-) (limited to 'java/client/src/main') diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java b/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java index f50b0390c5..c82187b2e7 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQTopic.java @@ -28,12 +28,12 @@ import javax.jms.JMSException; import javax.jms.Topic; public class AMQTopic extends AMQDestination implements Topic - { +{ /** - * Constructor for use in creating a topic using a BindingURL. + * Constructor for use in creating a topic using a BindingURL. * * @param binding The binding url object. - */ + */ public AMQTopic(BindingURL binding) { super(binding); @@ -78,7 +78,7 @@ public class AMQTopic extends AMQDestination implements Topic return super.getDestinationName().toString(); } - public AMQShortString getRoutingKey() + public AMQShortString getRoutingKey() { return getDestinationName(); } @@ -93,7 +93,7 @@ public class AMQTopic extends AMQDestination implements Topic * Override since the queue is always private and we must ensure it remains null. If not, * reuse of the topic when registering consumers will make all consumers listen on the same (private) queue rather * than getting their own (private) queue. - * + *

* This is relatively nasty but it is difficult to come up with a more elegant solution, given * the requirement in the case on AMQQueue and possibly other AMQDestination subclasses to * use the underlying queue name even where it is server generated. diff --git a/java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java b/java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java index f30b8ddc9d..6bb9b9912b 100644 --- a/java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java +++ b/java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java @@ -121,8 +121,9 @@ public class MessageConverter public MessageConverter(Message message) throws JMSException { - //TODO; Do we really want to create an empty message here ? - BytesMessage nativeMessage = new JMSBytesMessage(); + //Send a message with just properties. + // Throwing away content + BytesMessage nativeMessage = new JMSBytesMessage(); _newMessage = (AbstractJMSMessage) nativeMessage; setMessageProperties(message); -- cgit v1.2.1