Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.cpp URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.cpp?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.cpp (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.cpp Wed Jun 9 11:59:38 2010 @@ -29,10 +29,10 @@ #include "QpidTypeCheck.h" #include "QpidMarshal.h" -namespace org { -namespace apache { -namespace qpid { -namespace messaging { +namespace Org { +namespace Apache { +namespace Qpid { +namespace Messaging { /// <summary> /// Translate between managed and native types. @@ -42,11 +42,12 @@ namespace messaging { // The given object is a Dictionary. // Add its elements to the qpid map. // - void TypeTranslator::ManagedToNative(::qpid::types::Variant::Map & theMapp, - QpidMap ^ theObjp) + void TypeTranslator::ManagedToNative(QpidMap ^ theDictionary, + ::qpid::types::Variant::Map & qpidMap) { // iterate the items, converting each to a variant and adding to the map - for each (System::Collections::Generic::KeyValuePair<System::String^, System::Object^> kvp in theObjp) + for each (System::Collections::Generic::KeyValuePair + <System::String^, System::Object^> kvp in theDictionary) { if (QpidTypeCheck::ObjectIsMap(kvp.Value)) { @@ -55,7 +56,7 @@ namespace messaging { ::qpid::types::Variant::Map newMap; // Add the map variables to the map - ManagedToNative(newMap, (QpidMap ^)kvp.Value); + ManagedToNative((QpidMap ^)kvp.Value, newMap); // Create a variant entry for the inner map std::auto_ptr<::qpid::types::Variant> newVariantp(new ::qpid::types::Variant(newMap)); @@ -64,7 +65,7 @@ namespace messaging { std::string entryName = QpidMarshal::ToNative(kvp.Key); // Add inner map to outer map - theMapp.insert(std::make_pair<std::string, ::qpid::types::Variant>(entryName, *newVariantp)); + qpidMap.insert(std::make_pair<std::string, ::qpid::types::Variant>(entryName, *newVariantp)); } else if (QpidTypeCheck::ObjectIsList(kvp.Value)) { @@ -73,7 +74,7 @@ namespace messaging { ::qpid::types::Variant::List newList; // Add the List variables to the list - ManagedToNative(newList, (QpidList ^)kvp.Value); + ManagedToNative((QpidList ^)kvp.Value, newList); // Create a variant entry for the inner map ::qpid::types::Variant::List newVariant(newList); @@ -84,7 +85,7 @@ namespace messaging { std::string entryName = QpidMarshal::ToNative(kvp.Key); // Add inner list to outer map - theMapp.insert(std::make_pair<std::string, ::qpid::types::Variant>(entryName, newVariant)); + qpidMap.insert(std::make_pair<std::string, ::qpid::types::Variant>(entryName, newVariant)); } else { @@ -92,7 +93,7 @@ namespace messaging { ::qpid::types::Variant entryValue; ManagedToNativeObject(kvp.Value, entryValue); std::string entryName = QpidMarshal::ToNative(kvp.Key); - theMapp.insert(std::make_pair<std::string, ::qpid::types::Variant>(entryName, entryValue)); + qpidMap.insert(std::make_pair<std::string, ::qpid::types::Variant>(entryName, entryValue)); } } } @@ -103,11 +104,11 @@ namespace messaging { // The given object is a List. // Add its elements to the qpid list. // - void TypeTranslator::ManagedToNative(::qpid::types::Variant::List & theListp, - QpidList ^ theObjp) + void TypeTranslator::ManagedToNative(QpidList ^ theList, + ::qpid::types::Variant::List & qpidList) { // iterate the items, converting each to a variant and adding to the map - for each (System::Object ^ listObj in theObjp) + for each (System::Object ^ listObj in theList) { if (QpidTypeCheck::ObjectIsMap(listObj)) { @@ -116,13 +117,13 @@ namespace messaging { ::qpid::types::Variant::Map newMap; // Add the map variables to the map - ManagedToNative(newMap, (QpidMap ^)listObj); + ManagedToNative((QpidMap ^)listObj, newMap); // Create a variant entry for the inner map std::auto_ptr<::qpid::types::Variant> newVariantp(new ::qpid::types::Variant(newMap)); // Add inner map to outer list - theListp.push_back(*newVariantp); + qpidList.push_back(*newVariantp); } else if (QpidTypeCheck::ObjectIsList(listObj)) { @@ -131,20 +132,20 @@ namespace messaging { ::qpid::types::Variant::List newList; // Add the List variables to the list - ManagedToNative(newList, (QpidList ^)listObj); + ManagedToNative((QpidList ^)listObj, newList); // Create a variant entry for the inner list std::auto_ptr<::qpid::types::Variant> newVariantp(new ::qpid::types::Variant(newList)); // Add inner list to outer list - theListp.push_back(*newVariantp); + qpidList.push_back(*newVariantp); } else { // Add a simple native type to list ::qpid::types::Variant entryValue; ManagedToNativeObject(listObj, entryValue); - theListp.push_back(entryValue); + qpidList.push_back(entryValue); } } } @@ -155,57 +156,57 @@ namespace messaging { // Returns a variant representing simple native type object. // Not to be called for Map/List objects. // - void TypeTranslator::ManagedToNativeObject(System::Object ^ theObjp, - ::qpid::types::Variant & targetp) + void TypeTranslator::ManagedToNativeObject(System::Object ^ managedValue, + ::qpid::types::Variant & qpidVariant) { - System::Type ^ typeP = (*theObjp).GetType(); + System::Type ^ typeP = (*managedValue).GetType(); System::TypeCode typeCode = System::Type::GetTypeCode( typeP ); switch (typeCode) { case System::TypeCode::Boolean : - targetp = System::Convert::ToBoolean(theObjp); + qpidVariant = System::Convert::ToBoolean(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Byte : - targetp = System::Convert::ToByte(theObjp); + qpidVariant = System::Convert::ToByte(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::UInt16 : - targetp = System::Convert::ToUInt16(theObjp); + qpidVariant = System::Convert::ToUInt16(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::UInt32 : - targetp = System::Convert::ToUInt32(theObjp); + qpidVariant = System::Convert::ToUInt32(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::UInt64 : - targetp = System::Convert::ToUInt64(theObjp); + qpidVariant = System::Convert::ToUInt64(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Char : case System::TypeCode::SByte : - targetp = System::Convert::ToSByte(theObjp); + qpidVariant = System::Convert::ToSByte(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Int16 : - targetp = System::Convert::ToInt16(theObjp); + qpidVariant = System::Convert::ToInt16(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Int32 : - targetp = System::Convert::ToInt32(theObjp); + qpidVariant = System::Convert::ToInt32(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Int64 : - targetp = System::Convert::ToInt64(theObjp); + qpidVariant = System::Convert::ToInt64(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Single : - targetp = System::Convert::ToSingle(theObjp); + qpidVariant = System::Convert::ToSingle(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::Double : - targetp = System::Convert::ToDouble(theObjp); + qpidVariant = System::Convert::ToDouble(managedValue, System::Globalization::CultureInfo::InvariantCulture); break; case System::TypeCode::String : @@ -213,10 +214,10 @@ namespace messaging { std::string rString; System::String ^ rpString; - rpString = System::Convert::ToString(theObjp); + rpString = System::Convert::ToString(managedValue, System::Globalization::CultureInfo::InvariantCulture); rString = QpidMarshal::ToNative(rpString); - targetp = rString; - targetp.setEncoding(QpidMarshal::ToNative("utf8")); + qpidVariant = rString; + qpidVariant.setEncoding(QpidMarshal::ToNative("utf8")); } break; @@ -232,11 +233,12 @@ namespace messaging { // Given a user Dictionary and a qpid map, // extract the qpid elements and put them into the dictionary. // - void TypeTranslator::NativeToManaged(QpidMap ^ dict, ::qpid::types::Variant::Map & map) + void TypeTranslator::NativeToManaged(::qpid::types::Variant::Map & qpidMap, + QpidMap ^ dict) { // For each object in the message map, // create a .NET object and add it to the dictionary. - for (::qpid::types::Variant::Map::const_iterator i = map.begin(); i != map.end(); ++i) { + for (::qpid::types::Variant::Map::const_iterator i = qpidMap.begin(); i != qpidMap.end(); ++i) { // Get the name System::String ^ elementName = gcnew String(i->first.c_str()); @@ -299,7 +301,7 @@ namespace messaging { { QpidMap ^ newDict = gcnew QpidMap(); - NativeToManaged(newDict, variant.asMap()); + NativeToManaged(variant.asMap(), newDict); dict[elementName] = newDict; break; @@ -309,7 +311,7 @@ namespace messaging { { QpidList ^ newList = gcnew QpidList(); - NativeToManaged(newList, variant.asList()); + NativeToManaged(variant.asList(), newList); dict[elementName] = newList; break; @@ -322,10 +324,10 @@ namespace messaging { } - void TypeTranslator::NativeToManaged(QpidList ^ vList, ::qpid::types::Variant::List & qpidList) + void TypeTranslator::NativeToManaged(::qpid::types::Variant::List & qpidList, QpidList ^ managedList) { - // For each object in the message map, - // create a .NET object and add it to the dictionary. + // For each object in the qpidList + // create a .NET object and add it to the managed List. for (::qpid::types::Variant::List::const_iterator i = qpidList.begin(); i != qpidList.end(); ++i) { ::qpid::types::Variant variant = *i; @@ -334,62 +336,62 @@ namespace messaging { switch (vType) { case ::qpid::types::VAR_BOOL: - (*vList).Add(variant.asBool()); + (*managedList).Add(variant.asBool()); break; case ::qpid::types::VAR_UINT8: - (*vList).Add(variant.asUint8()); + (*managedList).Add(variant.asUint8()); break; case ::qpid::types::VAR_UINT16: - (*vList).Add(variant.asUint16()); + (*managedList).Add(variant.asUint16()); break; case ::qpid::types::VAR_UINT32: - (*vList).Add(variant.asUint32()); + (*managedList).Add(variant.asUint32()); break; case ::qpid::types::VAR_UINT64: - (*vList).Add(variant.asUint64()); + (*managedList).Add(variant.asUint64()); break; case ::qpid::types::VAR_INT8: - (*vList).Add(variant.asInt8()); + (*managedList).Add(variant.asInt8()); break; case ::qpid::types::VAR_INT16: - (*vList).Add(variant.asInt16()); + (*managedList).Add(variant.asInt16()); break; case ::qpid::types::VAR_INT32: - (*vList).Add(variant.asInt32()); + (*managedList).Add(variant.asInt32()); break; case ::qpid::types::VAR_INT64: - (*vList).Add(variant.asInt64()); + (*managedList).Add(variant.asInt64()); break; case ::qpid::types::VAR_FLOAT: - (*vList).Add(variant.asFloat()); + (*managedList).Add(variant.asFloat()); break; case ::qpid::types::VAR_DOUBLE: - (*vList).Add(variant.asDouble()); + (*managedList).Add(variant.asDouble()); break; case ::qpid::types::VAR_STRING: { System::String ^ elementValue = gcnew System::String(variant.asString().c_str()); - (*vList).Add(elementValue); + (*managedList).Add(elementValue); break; } case ::qpid::types::VAR_MAP: { QpidMap ^ newDict = gcnew QpidMap(); - NativeToManaged(newDict, variant.asMap()); + NativeToManaged(variant.asMap(), newDict); - (*vList).Add(newDict); + (*managedList).Add(newDict); break; } @@ -397,9 +399,9 @@ namespace messaging { { QpidList ^ newList = gcnew QpidList(); - NativeToManaged(newList, variant.asList()); + NativeToManaged(variant.asList(), newList); - (*vList).Add(newList); + (*managedList).Add(newList); break; }
Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.h URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.h?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.h (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/TypeTranslator.h Wed Jun 9 11:59:38 2010 @@ -28,43 +28,44 @@ #include "QpidTypeCheck.h" -namespace org { -namespace apache { -namespace qpid { -namespace messaging { +namespace Org { +namespace Apache { +namespace Qpid { +namespace Messaging { /// <summary> /// TypeTranslator provides codec between .NET Dictionary/List and /// qpid messaging Map/List. /// </summary> - - public ref class TypeTranslator + public ref class TypeTranslator sealed { + private: + TypeTranslator::TypeTranslator() {} public: - // The given object is a Dictionary. + // The given object is a managed Dictionary. // Add its elements to the qpid map. - static void ManagedToNative(::qpid::types::Variant::Map & theMapp, - QpidMap ^ theObjp); + static void ManagedToNative(QpidMap ^ theDictionary, + ::qpid::types::Variant::Map & qpidMap); - // The given object is a List. + // The given object is a managed List. // Add its elements to the qpid list. - static void ManagedToNative(::qpid::types::Variant::List & theListp, - QpidList ^ theObjp); + static void ManagedToNative(QpidList ^ theList, + ::qpid::types::Variant::List & qpidList); - // The given object is a simple native type (not a Dictionary or List) + // The given object is a simple managed type (not a Dictionary or List) // Returns a variant representing simple native type object. - static void ManagedToNativeObject(System::Object ^ theObjp, - ::qpid::types::Variant & targetp); + static void ManagedToNativeObject(System::Object ^ managedValue, + ::qpid::types::Variant & qpidVariant); - // Given a Dictionary, - // Return its values in a Qpid map - static void NativeToManaged(QpidMap ^ dict, - ::qpid::types::Variant::Map & map); - - // Given a List, - // Return its values in a Qpid list - static void NativeToManaged(QpidList ^ vList, - ::qpid::types::Variant::List & qpidList); + // The given object is a qpid map. + // Add its elements to the managed Dictionary. + static void NativeToManaged(::qpid::types::Variant::Map & qpidMap, + QpidMap ^ dict); + + // The given object is a qpid list. + // Add its elements to the managed List. + static void NativeToManaged(::qpid::types::Variant::List & qpidList, + QpidList ^ managedList); }; }}}} Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.rc URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.rc?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.rc (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.rc Wed Jun 9 11:59:38 2010 @@ -69,12 +69,12 @@ BEGIN BEGIN BLOCK "040904b0" BEGIN - VALUE "FileDescription", "org" + VALUE "FileDescription", "org.apache.qpid.messaging" VALUE "FileVersion", "1, 3, 0, 1" - VALUE "InternalName", "org" + VALUE "InternalName", "org.apache.qpid.messaging" VALUE "LegalCopyright", "Copyright (C) 2010" VALUE "OriginalFilename", "org.apache.qpid.messaging" - VALUE "ProductName", "org" + VALUE "ProductName", "org.apache.qpid.messaging" VALUE "ProductVersion", "1, 3, 0, 1" END END Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.vcproj URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.vcproj?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.vcproj (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/org.apache.qpid.messaging.vcproj Wed Jun 9 11:59:38 2010 @@ -2,7 +2,7 @@ <VisualStudioProject ProjectType="Visual C++" Version="9.00" - Name="org.apache.qpid.messaging" + Name="Org.Apache.Qpid.Messaging" ProjectGUID="{AA5A3B83-5F98-406D-A01C-5A921467A57D}" RootNamespace="org.apache.qpid.messaging" Keyword="ManagedCProj" @@ -244,6 +244,10 @@ > </File> <File + RelativePath=".\QpidException.h" + > + </File> + <File RelativePath=".\QpidMarshal.h" > </File> Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/Properties/AssemblyInfo.cs URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/Properties/AssemblyInfo.cs?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/Properties/AssemblyInfo.cs (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/Properties/AssemblyInfo.cs Wed Jun 9 11:59:38 2010 @@ -24,11 +24,11 @@ using System.Runtime.InteropServices; // General Information about an assembly is controlled through the following // set of attributes. Change these attribute values to modify the information // associated with an assembly. -[assembly: AssemblyTitle("org.apache.qpid.messaging.sessionreceiver")] +[assembly: AssemblyTitle("Org.Apache.Qpid.Messaging.SessionReceiver")] [assembly: AssemblyDescription("")] [assembly: AssemblyConfiguration("")] [assembly: AssemblyCompany("")] -[assembly: AssemblyProduct("org.apache.qpid.messaging.sessionreceiver")] +[assembly: AssemblyProduct("Org.Apache.Qpid.Messaging.SessionReceiver")] [assembly: AssemblyCopyright("Copyright © 2010")] [assembly: AssemblyTrademark("")] [assembly: AssemblyCulture("")] Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/sessionreceiver.cs URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/sessionreceiver.cs?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/sessionreceiver.cs (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/sessionreceiver/sessionreceiver.cs Wed Jun 9 11:59:38 2010 @@ -23,9 +23,9 @@ using System; using System.Collections.Generic; using System.Linq; using System.Text; -using org.apache.qpid.messaging; +using Org.Apache.Qpid.Messaging; -namespace org.apache.qpid.messaging.sessionreceiver +namespace Org.Apache.Qpid.Messaging.SessionReceiver { /// <summary> /// ISessionReceiver interface defines the callback for users to supply. @@ -43,19 +43,19 @@ namespace org.apache.qpid.messaging.sess /// <summary> - /// eventEngine - wait for messages from the underlying C++ code. + /// EventEngine - wait for messages from the underlying C++ code. /// When available get them and deliver them via callback to our /// client through the ISessionReceiver interface. /// This class consumes the thread that calls the Run() function. /// </summary> - internal class eventEngine + internal class EventEngine { private Session session; private ISessionReceiver callback; private bool keepRunning; - public eventEngine(Session theSession, ISessionReceiver thecallback) + public EventEngine(Session theSession, ISessionReceiver thecallback) { this.session = theSession; this.callback = thecallback; @@ -65,35 +65,35 @@ namespace org.apache.qpid.messaging.sess /// Function to call Session's nextReceiver, discover messages, /// and to deliver messages through the callback. /// </summary> - public void open() + public void Open() { - Receiver rcvr = session.createReceiver(); + Receiver rcvr = session.CreateReceiver(); Message msg; keepRunning = true; while (keepRunning) { - if (session.nextReceiver(rcvr, DurationConstants.SECOND)) + if (session.NextReceiver(rcvr, DurationConstants.SECOND)) { if (keepRunning) { - msg = rcvr.fetch(DurationConstants.SECOND); + msg = rcvr.Fetch(DurationConstants.SECOND); this.callback.SessionReceiver(rcvr, msg); } } //else // receive timed out - // eventEngine exits the nextReceiver() function periodically + // EventEngine exits the nextReceiver() function periodically // in order to test the keepRunning flag } // Private thread is now exiting. } /// <summary> - /// Function to stop the eventEngine. Private thread will exit within + /// Function to stop the EventEngine. Private thread will exit within /// one second. /// </summary> - public void close() + public void Close() { keepRunning = false; } @@ -104,9 +104,9 @@ namespace org.apache.qpid.messaging.sess /// server is the class that users instantiate to connect a SessionReceiver /// callback to the stream of received messages received on a Session. /// </summary> - public class server + public class CallbackServer { - private eventEngine ee; + private EventEngine ee; /// <summary> /// Constructor for the server. @@ -114,20 +114,20 @@ namespace org.apache.qpid.messaging.sess /// <param name="session">The Session whose messages are collected.</param> /// <param name="callback">The user function call with each message.</param> /// - public server(Session session, ISessionReceiver callback) + public CallbackServer(Session session, ISessionReceiver callback) { - ee = new eventEngine(session, callback); + ee = new EventEngine(session, callback); new System.Threading.Thread( - new System.Threading.ThreadStart(ee.open)).Start(); + new System.Threading.ThreadStart(ee.Open)).Start(); } /// <summary> /// Function to stop the server. /// </summary> - public void close() + public void Close() { - ee.close(); + ee.Close(); } } } Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/test/messaging.test/messaging.test.cs URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/test/messaging.test/messaging.test.cs?rev=952968&r1=952967&r2=952968&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/test/messaging.test/messaging.test.cs (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/test/messaging.test/messaging.test.cs Wed Jun 9 11:59:38 2010 @@ -2,9 +2,9 @@ using System; using System.Collections.Generic; using System.Linq; using System.Text; -using org.apache.qpid.messaging; +using Org.Apache.Qpid.Messaging; -namespace org.apache.qpid.messaging +namespace Org.Apache.Qpid.Messaging { class Program { @@ -64,22 +64,22 @@ namespace org.apache.qpid.messaging Address aType = new Address ("check3", "subj", options, "hot"); - Console.WriteLine("aEmpty : {0}", aEmpty.str()); - Console.WriteLine("aStr : {0}", aStr.str()); - Console.WriteLine("aSubj : {0}", aSubj.str()); - Console.WriteLine("aType : {0}", aType.str()); + Console.WriteLine("aEmpty : {0}", aEmpty.ToStr()); + Console.WriteLine("aStr : {0}", aStr.ToStr()); + Console.WriteLine("aSubj : {0}", aSubj.ToStr()); + Console.WriteLine("aType : {0}", aType.ToStr()); // // Raw message data retrieval // Message m2 = new Message("rarey"); - UInt64 m2Size = m2.getContentSize(); + UInt64 m2Size = m2.GetContentSize(); byte[] myRaw = new byte [m2Size]; - m2.getRaw(myRaw); + m2.GetRaw(myRaw); Console.WriteLine("Got raw array size {0}", m2Size); for (UInt64 i = 0; i < m2Size; i++) Console.Write("{0} ", myRaw[i].ToString()); --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
