diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2010-07-17 02:30:59 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2010-07-17 02:30:59 +0000 |
| commit | 1a54722f6d029deac324c8a5f0221b7de9381c5c (patch) | |
| tree | 8bc5c71358d0fa007183d9e9910ae9f3da0cc7ec /qpid/java/client | |
| parent | 41202c7d20f905f3b8f5d7c39ac7dbbcd7da3b44 (diff) | |
| download | qpid-python-1a54722f6d029deac324c8a5f0221b7de9381c5c.tar.gz | |
QPID-2735
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@964998 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java index aeceec4f57..e0fbed5ea7 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java @@ -1219,15 +1219,15 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic } } - @SuppressWarnings("deprecation") private void verifySubject(AMQDestination dest) throws AMQException { if (dest.getSubject() == null || dest.getSubject().trim().equals("")) { - if (dest.getExchangeClass() == ExchangeDefaults.TOPIC_EXCHANGE_CLASS) + + if ("topic".equals(dest.getExchangeClass().toString())) { - dest.setRoutingKey(ExchangeDefaults.WILDCARD_ANY); - dest.setSubject(ExchangeDefaults.WILDCARD_ANY.toString()); + dest.setRoutingKey(new AMQShortString("#")); + dest.setSubject(dest.getRoutingKey().toString()); } else { |