summaryrefslogtreecommitdiff
path: root/dotnet/Qpid.Client/Client/Message
diff options
context:
space:
mode:
authorRupert Smith <rupertlssmith@apache.org>2007-08-07 09:44:59 +0000
committerRupert Smith <rupertlssmith@apache.org>2007-08-07 09:44:59 +0000
commitacdc3f1f9b6fd97e5461869a3e869736966bfac7 (patch)
tree1cadceff547aa00b2f722db38938291a53cf587c /dotnet/Qpid.Client/Client/Message
parenta1be116bdebdcda39d11664dff5c08acc7c018a0 (diff)
downloadqpid-python-acdc3f1f9b6fd97e5461869a3e869736966bfac7.tar.gz
Interop tests put into a working state.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@563434 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'dotnet/Qpid.Client/Client/Message')
-rw-r--r--dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs8
1 files changed, 7 insertions, 1 deletions
diff --git a/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs b/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs
index 19f59a4fc1..f8c44261f2 100644
--- a/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs
+++ b/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs
@@ -30,6 +30,8 @@ namespace Apache.Qpid.Client.Message
{
public abstract class AbstractQmsMessage : AMQMessage, IMessage
{
+ private static ILog log = LogManager.GetLogger(typeof(AbstractQmsMessage));
+
protected bool _redelivered;
protected ByteBuffer _data;
@@ -452,6 +454,8 @@ namespace Apache.Qpid.Client.Message
private Dest ReadReplyToHeader()
{
string replyToEncoding = ContentHeaderProperties.ReplyTo;
+
+ //log.Info("replyToEncoding = " + replyToEncoding);
if ( replyToEncoding == null )
{
@@ -469,7 +473,9 @@ namespace Apache.Qpid.Client.Message
// Extract the exchange name and routing key from the split replyto field.
string exchangeName = split[0];
- string routingKey = split[1];
+
+ string[] split2 = split[1].Split('/');
+ string routingKey = split2[3];
return new Dest(exchangeName, routingKey);
}