diff options
Diffstat (limited to 'qpid/dotnet/client-010/client/client/Message.cs')
-rw-r--r-- | qpid/dotnet/client-010/client/client/Message.cs | 131 |
1 files changed, 0 insertions, 131 deletions
diff --git a/qpid/dotnet/client-010/client/client/Message.cs b/qpid/dotnet/client-010/client/client/Message.cs deleted file mode 100644 index 6ab62070d2..0000000000 --- a/qpid/dotnet/client-010/client/client/Message.cs +++ /dev/null @@ -1,131 +0,0 @@ -/* -* -* Licensed to the Apache Software Foundation (ASF) under one -* or more contributor license agreements. See the NOTICE file -* distributed with this work for additional information -* regarding copyright ownership. The ASF licenses this file -* to you under the Apache License, Version 2.0 (the -* "License"); you may not use this file except in compliance -* with the License. You may obtain a copy of the License at -* -* http://www.apache.org/licenses/LICENSE-2.0 -* -* Unless required by applicable law or agreed to in writing, -* software distributed under the License is distributed on an -* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -* KIND, either express or implied. See the License for the -* specific language governing permissions and limitations -* under the License. -* -*/ -using System.Collections.Generic; -using System.IO; -using org.apache.qpid.transport; - -namespace org.apache.qpid.client -{ - public class Message : IMessage - { - private readonly MessageTransfer _message; - - public Message(MessageTransfer m) - { - _message = m; - } - - public Message() - { - _message = new MessageTransfer(); - _message.Header = new Header( new MessageProperties(), new DeliveryProperties()); - ((MessageProperties) _message.Header.Structs[0]).SetApplicationHeaders(new Dictionary<string, object>()); - } - - public MessageProperties MessageProperties - { - get - { - if (_message.Header != null && Header.Structs.Length > 1) - return (MessageProperties) Header.Structs[0]; - return null; - } - set - { - if (_message.Header != null) - { - Header.Structs[0] = value; - } - } - } - - public DeliveryProperties DeliveryProperties - { - get - { - if (Header != null) - { - if( Header.Structs.Length > 1 ) - return (DeliveryProperties)Header.Structs[1]; - return (DeliveryProperties)Header.Structs[0]; - } - - return null; - } - set - { - if (Header != null) - { - Header.Structs[1] = value; - } - } - } - - public Dictionary<string, object> ApplicationHeaders - { - get - { - if (Header != null) - return ((MessageProperties) Header.Structs[0]).GetApplicationHeaders(); - return null; - } - set - { - if (Header != null) - { - ((MessageProperties) Header.Structs[0]).SetApplicationHeaders(value); - } - } - } - - public void AppendData(byte[] bytes) - { - Body.Write(bytes, 0, bytes.Length); - } - - public void ClearData() - { - Body.Seek(0, SeekOrigin.Begin); - } - - public Header Header - { - get{ return _message.Header;} - set{ _message.Header = value;} - } - - public MemoryStream Body - { - get { return _message.Body; } - set { _message.Body = value; } - } - - public int Id - { - get { return _message.Id; } - } - - public string Destination - { - get{ return _message.GetDestination();} - } - } -} |