diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-02-01 09:37:39 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-02-01 09:37:39 +0000 |
| commit | 4d1416cfd49aae6b3310d60d2357c26c56fd8918 (patch) | |
| tree | 570d0963423177a352895584d708edc6bf8cbf90 /java/client/src/main | |
| parent | db77ac7e5130d251f38c8d93d2a3a41004218334 (diff) | |
| download | qpid-python-4d1416cfd49aae6b3310d60d2357c26c56fd8918.tar.gz | |
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
Diffstat (limited to 'java/client/src/main')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQTopic.java | 10 | ||||
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java | 5 |
2 files changed, 8 insertions, 7 deletions
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. - * + * <p/> * 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); |
