summaryrefslogtreecommitdiff
path: root/qpid/dotnet/client-010/client/client/Message.cs
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/dotnet/client-010/client/client/Message.cs')
-rw-r--r--qpid/dotnet/client-010/client/client/Message.cs131
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();}
- }
- }
-}