diff options
| author | Steven Shaw <steshaw@apache.org> | 2006-12-13 15:39:24 +0000 |
|---|---|---|
| committer | Steven Shaw <steshaw@apache.org> | 2006-12-13 15:39:24 +0000 |
| commit | 0c7018b2f05701a30790d721771ce1d4c357f0bb (patch) | |
| tree | ca3c2e1b1be43b20ecd30dd83be33beacb930b76 /qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs | |
| parent | 2b616f52ae028c78761ed5cb0822849c5335227a (diff) | |
| download | qpid-python-0c7018b2f05701a30790d721771ce1d4c357f0bb.tar.gz | |
QPID-173. Re-port JmsByteBytes (QpidBytesMessage) from Java. Notably missing was the _data.rewind() in the Text getter. Also removed/tidied up some commented out code.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@486688 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs')
| -rw-r--r-- | qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs | 41 |
1 files changed, 2 insertions, 39 deletions
diff --git a/qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs b/qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs index 54ce8d023c..cc4f6dafe1 100644 --- a/qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs +++ b/qpid/dotnet/Qpid.Client/Client/Message/QpidTextMessageFactory.cs @@ -18,48 +18,13 @@ * under the License. * */ -using System; -using System.Collections; -using Qpid.Framing; using Qpid.Buffer; +using Qpid.Framing; namespace Qpid.Client.Message { public class QpidTextMessageFactory : AbstractQmsMessageFactory - { - - // protected override AbstractQmsMessage CreateMessageWithBody(long messageNbr, ContentHeaderBody contentHeader, - // IList bodies) - // { - // byte[] data; - - // // we optimise the non-fragmented case to avoid copying - // if (bodies != null && bodies.Count == 1) - // { - // data = ((ContentBody)bodies[0]).Payload; - // } - // else - // { - // data = new byte[(int)contentHeader.BodySize]; - // int currentPosition = 0; - // foreach (ContentBody cb in bodies) - // { - // Array.Copy(cb.Payload, 0, data, currentPosition, cb.Payload.Length); - // currentPosition += cb.Payload.Length; - // } - // } - - // return new QpidTextMessage(messageNbr, data, (BasicContentHeaderProperties)contentHeader.Properties); - // } - - - // public override AbstractQmsMessage CreateMessage() - // { - // return new QpidTextMessage(); - // } - - - + { public override AbstractQmsMessage CreateMessage() { return new QpidTextMessage(); @@ -69,7 +34,5 @@ namespace Qpid.Client.Message { return new QpidTextMessage(deliveryTag, (BasicContentHeaderProperties) contentHeader.Properties, data); } - } } - |
