activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jgo...@apache.org
Subject svn commit: r956074 - in /activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp: MapMessage.cs MessageProperties.cs
Date Fri, 18 Jun 2010 18:09:50 GMT
Author: jgomes
Date: Fri Jun 18 18:09:50 2010
New Revision: 956074

URL: http://svn.apache.org/viewvc?rev=956074&view=rev
Log:
Implemented new SetBytes/GetBytes API in EMS Provider.
Fixes [AMQNET-257]. (See https://issues.apache.org/activemq/browse/AMQNET-257)

Modified:
    activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MapMessage.cs
    activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProperties.cs

Modified: activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MapMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MapMessage.cs?rev=956074&r1=956073&r2=956074&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MapMessage.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MapMessage.cs Fri Jun 18
18:09:50 2010
@@ -429,6 +429,43 @@ namespace Apache.NMS.EMS
 			}
 		}
 
+		public void SetBytes(string key, byte[] value)
+		{
+			try
+			{
+				this.tibcoMapMessage.SetBytes(key, value);
+			}
+			catch(Exception ex)
+			{
+				ExceptionUtil.WrapAndThrowNMSException(ex);
+			}
+		}
+
+		public void SetBytes(string key, byte[] value, int offset, int length)
+		{
+			try
+			{
+				this.tibcoMapMessage.SetBytes(key, value, offset, length);
+			}
+			catch(Exception ex)
+			{
+				ExceptionUtil.WrapAndThrowNMSException(ex);
+			}
+		}
+
+		public byte[] GetBytes(string key)
+		{
+			try
+			{
+				return this.tibcoMapMessage.GetBytes(key);
+			}
+			catch(Exception ex)
+			{
+				ExceptionUtil.WrapAndThrowNMSException(ex);
+				return null;
+			}
+		}
+
 		public IDictionary GetDictionary(string key)
 		{
 			try

Modified: activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProperties.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProperties.cs?rev=956074&r1=956073&r2=956074&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProperties.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProperties.cs Fri
Jun 18 18:09:50 2010
@@ -408,6 +408,50 @@ namespace Apache.NMS.EMS
 			}
 		}
 
+		public void SetBytes(string key, byte[] value)
+		{
+			try
+			{
+				this.tibcoMessage.SetObjectProperty(key, value);
+			}
+			catch(Exception ex)
+			{
+				ExceptionUtil.WrapAndThrowNMSException(ex);
+			}
+		}
+
+		public void SetBytes(string key, byte[] value, int offset, int length)
+		{
+			try
+			{
+				byte[] byteSection = new byte[length];
+
+				for(int srcIndex = offset, destIndex = 0; srcIndex < (offset + length); srcIndex++,
destIndex++)
+				{
+					byteSection[destIndex] = value[srcIndex];
+				}
+
+				this.tibcoMessage.SetObjectProperty(key, byteSection);
+			}
+			catch(Exception ex)
+			{
+				ExceptionUtil.WrapAndThrowNMSException(ex);
+			}
+		}
+
+		public byte[] GetBytes(string key)
+		{
+			try
+			{
+				return (byte[]) this.tibcoMessage.GetObjectProperty(key);
+			}
+			catch(Exception ex)
+			{
+				ExceptionUtil.WrapAndThrowNMSException(ex);
+				return null;
+			}
+		}
+
 		public IDictionary GetDictionary(string key)
 		{
 			try



Mime
View raw message