/* | |
* 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; | |
using Apache.NMS.Util; | |
using NUnit.Framework; | |
namespace Apache.NMS.Test | |
{ | |
// For ease of cross-platform exchange of information, you might generate objects from | |
// an XSD file using XSDObjectGen. However, C# has built-in support for serializing. | |
// All of the XML attributes that are commented out are optional, but give you fine-grained | |
// control over the serialized format if you need it. | |
// [Serializable] | |
public enum CheckType | |
{ | |
// [XmlEnum(Name = "message")] | |
message, | |
// [XmlEnum(Name = "command")] | |
command, | |
// [XmlEnum(Name = "response")] | |
response | |
} | |
// [XmlRoot(ElementName = "NMSTestXmlType1", IsNullable = false), Serializable] | |
public class NMSTestXmlType1 | |
{ | |
// [XmlElement(ElementName = "crcCheck", IsNullable = false, DataType = "int")] | |
public int crcCheck; | |
// [XmlElement(Type = typeof(CheckType), ElementName = "checkType", IsNullable = false)] | |
public CheckType checkType; | |
public NMSTestXmlType1() | |
{ | |
crcCheck = 0; | |
checkType = CheckType.message; | |
} | |
} | |
// [XmlRoot(ElementName = "NMSTestXmlType2", IsNullable = false), Serializable] | |
public class NMSTestXmlType2 | |
{ | |
// [XmlElement(ElementName = "stringCheck", IsNullable = false, DataType = "string")] | |
public string stringCheck; | |
public NMSTestXmlType2() | |
{ | |
stringCheck = String.Empty; | |
} | |
} | |
[TestFixture] | |
public class XmlMessageTest : NMSTestSupport | |
{ | |
protected static string DESTINATION_NAME = "XmlMessageDestination"; | |
protected static string TEST_CLIENT_ID = "XmlMessageClientId"; | |
#if NET_3_5 || MONO | |
[Test] | |
public void SendReceiveXmlMessage() | |
{ | |
using(IConnection connection = CreateConnection(TEST_CLIENT_ID)) | |
{ | |
connection.Start(); | |
using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge)) | |
{ | |
IDestination destination = session.GetDestination(DESTINATION_NAME); | |
using(IMessageConsumer consumer = session.CreateConsumer(destination)) | |
using(IMessageProducer producer = session.CreateProducer(destination)) | |
{ | |
producer.RequestTimeout = receiveTimeout; | |
NMSTestXmlType1 srcIntObject = new NMSTestXmlType1(); | |
srcIntObject.crcCheck = 0xbadf00d; | |
srcIntObject.checkType = CheckType.command; | |
producer.Send(srcIntObject); | |
NMSTestXmlType2 srcStringObject = new NMSTestXmlType2(); | |
srcStringObject.stringCheck = "BadFood"; | |
producer.Send(srcStringObject); | |
// Demonstrate the ability to generically handle multiple object types | |
// sent to the same consumer. If only one object type is ever sent to | |
// the destination, then a simple inline cast is all that is necessary | |
// when calling the NMSConvert.FromXmlMessage() function. | |
for(int index = 0; index < 2; index++) | |
{ | |
object receivedObject = consumer.Receive(receiveTimeout).ToObject(); | |
Assert.IsNotNull(receivedObject, "Failed to retrieve XML message object."); | |
if(receivedObject is NMSTestXmlType1) | |
{ | |
NMSTestXmlType1 destObject = (NMSTestXmlType1) receivedObject; | |
Assert.AreEqual(srcIntObject.crcCheck, destObject.crcCheck, "CRC integer mis-match."); | |
Assert.AreEqual(srcIntObject.checkType, destObject.checkType, "Check type mis-match."); | |
} | |
else if(receivedObject is NMSTestXmlType2) | |
{ | |
NMSTestXmlType2 destObject = (NMSTestXmlType2) receivedObject; | |
Assert.AreEqual(srcStringObject.stringCheck, destObject.stringCheck, "CRC string mis-match."); | |
} | |
else | |
{ | |
Assert.Fail("Invalid object type."); | |
} | |
} | |
} | |
} | |
} | |
} | |
#else | |
[Test] | |
public void SendReceiveXmlMessage() | |
{ | |
using(IConnection connection = CreateConnection(TEST_CLIENT_ID)) | |
{ | |
connection.Start(); | |
using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge)) | |
{ | |
IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME); | |
using(IMessageConsumer consumer = session.CreateConsumer(destination)) | |
using(IMessageProducer producer = session.CreateProducer(destination)) | |
{ | |
producer.RequestTimeout = receiveTimeout; | |
NMSTestXmlType1 srcIntObject = new NMSTestXmlType1(); | |
srcIntObject.crcCheck = 0xbadf00d; | |
srcIntObject.checkType = CheckType.command; | |
producer.Send(NMSConvert.ToXmlMessage(session, srcIntObject)); | |
NMSTestXmlType2 srcStringObject = new NMSTestXmlType2(); | |
srcStringObject.stringCheck = "BadFood"; | |
producer.Send(NMSConvert.ToXmlMessage(session, srcStringObject)); | |
// Demonstrate the ability to generically handle multiple object types | |
// sent to the same consumer. If only one object type is ever sent to | |
// the destination, then a simple inline cast is all that is necessary | |
// when calling the NMSConvert.FromXmlMessage() function. | |
for(int index = 0; index < 2; index++) | |
{ | |
object receivedObject = NMSConvert.FromXmlMessage(consumer.Receive(receiveTimeout)); | |
Assert.IsNotNull(receivedObject, "Failed to retrieve XML message object."); | |
if(receivedObject is NMSTestXmlType1) | |
{ | |
NMSTestXmlType1 destObject = (NMSTestXmlType1) receivedObject; | |
Assert.AreEqual(srcIntObject.crcCheck, destObject.crcCheck, "CRC integer mis-match."); | |
Assert.AreEqual(srcIntObject.checkType, destObject.checkType, "Check type mis-match."); | |
} | |
else if(receivedObject is NMSTestXmlType2) | |
{ | |
NMSTestXmlType2 destObject = (NMSTestXmlType2) receivedObject; | |
Assert.AreEqual(srcStringObject.stringCheck, destObject.stringCheck, "CRC string mis-match."); | |
} | |
else | |
{ | |
Assert.Fail("Invalid object type."); | |
} | |
} | |
} | |
} | |
} | |
} | |
#endif | |
} | |
} |