diff --git a/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs b/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs new file mode 100755 index 0000000000..a36d3f50f8 --- /dev/null +++ b/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs @@ -0,0 +1,32 @@ +using System; +using OpenWire.Core; +using OpenWire.Core.Commands; + +namespace OpenWire.Core +{ + /// + /// Summary description for ActiveMQTempTopic. + /// + public class ActiveMQTempTopic : ActiveMQDestination, TemporaryTopic + { + public const byte ID_ActiveMQTempTopic = 103; + + public ActiveMQTempTopic(): base() {} + public ActiveMQTempTopic(String name):base(name){} + + public String GetTopicName() + { + return PhysicalName; + } + public override int GetDestinationType() + { + return ACTIVEMQ_TOPIC; + } + + public override ActiveMQDestination CreateDestination(String name) + { + return new ActiveMQTempTopic(name); + } + + } +} diff --git a/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs b/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs new file mode 100644 index 0000000000..3238b92f02 --- /dev/null +++ b/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs @@ -0,0 +1,46 @@ +// +// Marshalling code for Open Wire Format for DiscoveryEvent +// +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Groovy scripts in the +// activemq-openwire module +// + +using System; +using System.Collections; +using System.IO; + +using OpenWire.Core; +using OpenWire.Core.Commands; +using OpenWire.Core.IO; + +namespace OpenWire.Core.IO +{ + public class DiscoveryEventMarshaller : AbstractCommandMarshaller + { + + + public override Command CreateCommand() { + return new DiscoveryEvent(); + } + + public override void BuildCommand(Command command, BinaryReader dataIn) { + base.BuildCommand(command, dataIn); + + DiscoveryEvent info = (DiscoveryEvent) command; + info.ServiceName = dataIn.ReadString(); + info.BrokerName = dataIn.ReadString(); + + } + + public override void WriteCommand(Command command, BinaryWriter dataOut) { + base.WriteCommand(command, dataOut); + + DiscoveryEvent info = (DiscoveryEvent) command; + dataOut.Write(info.ServiceName); + dataOut.Write(info.BrokerName); + + } + } +} diff --git a/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs b/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs new file mode 100755 index 0000000000..94a1914b55 --- /dev/null +++ b/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs @@ -0,0 +1,12 @@ +using System; +using OpenWire.Core.Commands; + +namespace OpenWire.Core +{ + /// + /// Summary description for TemporaryQueue. + /// + public interface TemporaryQueue : Destination + { + } +}