summaryrefslogtreecommitdiff
path: root/java/client/src/main
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2007-02-01 09:37:39 +0000
committerMartin Ritchie <ritchiem@apache.org>2007-02-01 09:37:39 +0000
commit4d1416cfd49aae6b3310d60d2357c26c56fd8918 (patch)
tree570d0963423177a352895584d708edc6bf8cbf90 /java/client/src/main
parentdb77ac7e5130d251f38c8d93d2a3a41004218334 (diff)
downloadqpid-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.java10
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/message/MessageConverter.java5
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);