You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/01/09 16:02:56 UTC
svn commit: r367314 - in
/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core:
ActiveMQTempTopic.cs IO/DiscoveryEventMarshaller.cs TemporaryQueue.cs
Author: jstrachan
Date: Mon Jan 9 07:02:52 2006
New Revision: 367314
URL: http://svn.apache.org/viewcvs?rev=367314&view=rev
Log:
latest generated openwire.net code which now compiles OK!
Added:
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs (with props)
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs (with props)
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs?rev=367314&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs Mon Jan 9 07:02:52 2006
@@ -0,0 +1,32 @@
+using System;
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core
+{
+ /// <summary>
+ /// Summary description for ActiveMQTempTopic.
+ /// </summary>
+ 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);
+ }
+
+ }
+}
Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempTopic.cs
------------------------------------------------------------------------------
svn:executable = *
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs?rev=367314&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DiscoveryEventMarshaller.cs Mon Jan 9 07:02:52 2006
@@ -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);
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs?rev=367314&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs Mon Jan 9 07:02:52 2006
@@ -0,0 +1,12 @@
+using System;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core
+{
+ /// <summary>
+ /// Summary description for TemporaryQueue.
+ /// </summary>
+ public interface TemporaryQueue : Destination
+ {
+ }
+}
Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs
------------------------------------------------------------------------------
svn:executable = *