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/06 18:24:39 UTC
svn commit: r366537 [1/3] - in /incubator/activemq/trunk/openwire-dotnet: ./
src/ src/OpenWire.Core/ src/OpenWire.Core/Commands/ src/OpenWire.Core/IO/
Author: jstrachan
Date: Fri Jan 6 09:24:01 2006
New Revision: 366537
URL: http://svn.apache.org/viewcvs?rev=366537&view=rev
Log:
first spike of the code generated OpenWire.Net code and a NAnt build
Added:
incubator/activemq/trunk/openwire-dotnet/.project
incubator/activemq/trunk/openwire-dotnet/OpenWire.build
incubator/activemq/trunk/openwire-dotnet/src/
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs (with props)
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs (with props)
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs
- copied, changed from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQDestination.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs
- copied, changed from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQQueue.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs
- copied, changed from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQTopic.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs (with props)
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/CommandConstants.cs (with props)
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs
- copied, changed from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/DestinationFilter.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQBytesMessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQDestinationMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMapMessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQObjectMessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQQueueMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQStreamMessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempQueueMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempTopicMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTextMessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTopicMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/WireFormatInfoMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/XATransactionIdMarshaller.cs
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/OpenWire.Core.build (with props)
incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs
- copied, changed from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/TransactionConstants.cs
Added: incubator/activemq/trunk/openwire-dotnet/.project
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/.project?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/.project (added)
+++ incubator/activemq/trunk/openwire-dotnet/.project Fri Jan 6 09:24:01 2006
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+ <name>openwire-dotnet</name>
+ <comment></comment>
+ <projects>
+ </projects>
+ <buildSpec>
+ </buildSpec>
+ <natures>
+ </natures>
+</projectDescription>
Added: incubator/activemq/trunk/openwire-dotnet/OpenWire.build
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/OpenWire.build?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/OpenWire.build (added)
+++ incubator/activemq/trunk/openwire-dotnet/OpenWire.build Fri Jan 6 09:24:01 2006
@@ -0,0 +1,500 @@
+<?xml version="1.0" ?>
+<project name="openwire" default="test">
+ <!-- set build.date property to current date in format yyyy-MM-dd -->
+ <tstamp property="build.date" pattern="yyyy-MM-dd" />
+ <!-- global project settings -->
+ <property name="project.name" value="openwire" />
+ <property name="project.version" value="4.0" unless="${property::exists('project.version')}" />
+ <property name="project.release.type" value="SNAPSHOT" unless="${property::exists('project.release.type')}" /> <!-- nightly / dev / alpha / beta# / rc# / release -->
+
+ <if test="${project.release.type == 'nightly'}">
+ <property name="project.version.full" value="${project.version + '-nightly-' + build.date}" />
+ </if>
+ <if test="${project.release.type != 'nightly'}">
+ <property name="project.version.full" value="${project.version + if(project.release.type == 'release', '', '-' + project.release.type)}" dynamic="true" />
+ </if>
+
+ <!--
+ specifies whether the CommonAssemblyInfo.cs file should be created.
+ we do not want this for releases (whether they're beta or release) as
+ this would cause the build number to be updated
+ -->
+ <property name="create.assemblyinfo" value="true" />
+
+ <!-- global build settings -->
+ <property name="lib.dir" value="${path::combine(build.dir, 'bin/lib')}" dynamic="true" />
+ <property name="lib.family.dir" value="${path::combine(lib.dir, framework::get-family(framework::get-target-framework()))}" dynamic="true" />
+ <property name="lib.framework.dir" value="${path::combine(lib.family.dir, version::to-string(framework::get-version(framework::get-target-framework())))}" dynamic="true" />
+
+ <!-- default configuration -->
+ <property name="project.config" value="debug" /> <!-- debug|release -->
+ <property name="console.name" value="OpenWire" />
+ <property name="build.defines" value="" />
+ <property name="build.number" value="${math::abs(math::floor(timespan::get-total-days(datetime::now() - datetime::parse('01/01/2000'))))}" />
+
+ <!-- platform specific properties. These are the defaults -->
+ <property name="current.build.defines" value="${build.defines}" />
+
+ <fileset id="tas.msnet" basedir="src">
+ <include name="OpenWire.MSNet/OpenWire.MSNet.build" />
+ </fileset>
+
+ <fileset id="tas.msnet.tests" basedir="tests">
+ <include name="OpenWire.MSNet/OpenWire.MSNet.build" />
+ </fileset>
+
+ <fileset id="tas.win32" basedir="src">
+ <include name="OpenWire.Win32/OpenWire.Win32.build" />
+ <include name="OpenWire.VisualCpp/OpenWire.VisualCpp.build" />
+ <include name="OpenWire.VSNet/OpenWire.VSNet.build" />
+ </fileset>
+
+ <fileset id="tas.win32.tests" basedir="tests">
+ <include name="OpenWire.Win32/OpenWire.Win32.build" />
+ <include name="OpenWire.VisualCpp/OpenWire.VisualCpp.build" />
+ <include name="OpenWire.VSNet/OpenWire.VSNet.build" />
+ </fileset>
+
+ <fileset id="tas.core" basedir="src">
+ <include name="OpenWire.Resources/OpenWire.Resources.build" />
+ <include name="OpenWire.DotNet/OpenWire.DotNet.build" />
+ <include name="OpenWire.Compression/OpenWire.Compression.build" />
+ <include name="OpenWire.NUnit/OpenWire.NUnit.build" />
+ <include name="OpenWire.SourceControl/OpenWire.SourceControl.build" />
+ </fileset>
+
+ <fileset id="tas.core.tests" basedir="tests">
+ <include name="OpenWire.DotNet/OpenWire.DotNet.build" />
+ <include name="OpenWire.Compression/OpenWire.Compression.build" />
+ <include name="OpenWire.SourceControl/OpenWire.SourceControl.build" />
+ <!--
+ <include name="OpenWire.NUnit/OpenWire.NUnit.build" />
+ -->
+ </fileset>
+ <!-- named project configurations (used by self-test and self-doc tasks) -->
+ <target name="debug" description="Perform a 'debug' build">
+ <property name="project.config" value="debug" />
+ <property name="build.debug" value="true" />
+ <property name="build.dir" value="${project::get-base-directory()}/build/${framework::get-target-framework()}.${platform::get-name()}/${project.name}-${project.version}-${project.config}" />
+ </target>
+ <target name="release" description="Perform a 'release' build">
+ <property name="project.config" value="release" />
+ <property name="build.debug" value="false" />
+ <property name="build.dir" value="${project::get-base-directory()}/build/${project.name}-${project.version.full}" />
+ </target>
+ <!-- build tasks -->
+ <target name="init" description="Initializes build properties">
+ <call target="${project.config}" />
+ <call target="set-framework-configuration" />
+ </target>
+ <target name="create-common-assemblyinfo" if="${create.assemblyinfo}">
+ <!-- ensure src/CommonAssemblyInfo.cs is writable if it already exists -->
+ <attrib file="src/CommonAssemblyInfo.cs" readonly="false" if="${file::exists('src/CommonAssemblyInfo.cs')}" />
+ <!-- generate the source file holding the common assembly-level attributes -->
+ <asminfo output="src/CommonAssemblyInfo.cs" language="CSharp">
+ <imports>
+ <import namespace="System" />
+ <import namespace="System.Reflection" />
+ <import namespace="System.Runtime.InteropServices" />
+ </imports>
+ <attributes>
+ <attribute type="ComVisibleAttribute" value="false" />
+ <attribute type="CLSCompliantAttribute" value="true" />
+ <attribute type="AssemblyTitleAttribute" value="OpenWire" />
+ <attribute type="AssemblyDescriptionAttribute" value="A .NET Library for talking to ActiveMQ" />
+ <attribute type="AssemblyConfigurationAttribute" value="${project.release.type}" />
+ <attribute type="AssemblyCompanyAttribute" value="http://activemq.org/" />
+ <attribute type="AssemblyProductAttribute" value="OpenWire" />
+ <attribute type="AssemblyCopyrightAttribute" value="Copyright (C) 2005-${datetime::get-year(datetime::now())} Gerry Shaw" />
+ <attribute type="AssemblyTrademarkAttribute" value="" />
+ <attribute type="AssemblyCultureAttribute" value="" />
+ <attribute type="AssemblyVersionAttribute" value="${project.version}.${build.number}.0" />
+ <attribute type="AssemblyInformationalVersionAttribute" value="${project.version}" />
+ </attributes>
+ </asminfo>
+ </target>
+ <target name="clean" depends="init" description="Deletes current build configuration">
+ <delete dir="${build.dir}" if="${directory::exists(build.dir)}" />
+ </target>
+ <target name="cleanall" description="Deletes every build configuration">
+ <echo message="Deleting all builds from all configurations" />
+ <delete dir="build" if="${directory::exists('build')}" />
+ </target>
+ <target name="build" depends="init, create-common-assemblyinfo" description="Builds current configuration">
+ <echo message="Build Directory is ${build.dir}" />
+ <!-- ensure bin directory exists -->
+ <mkdir dir="${build.dir}/bin" />
+ <!-- ensure lib directory exists -->
+ <mkdir dir="${build.dir}/bin/lib" />
+ <!-- copy third party executables -->
+ <copy todir="${build.dir}/bin">
+ <fileset basedir="bin">
+ <include name="scvs.exe" />
+ </fileset>
+ </copy>
+ <copy todir="${build.dir}/bin">
+ <fileset basedir="lib">
+ <!-- copy log4net assembly, workaround for Mono bug #57602 -->
+ <include name="log4net.dll" />
+ <!-- #ziplib command line client -->
+ <include name="scvs.exe" />
+ </fileset>
+ </copy>
+ <!-- copy third party assemblies -->
+ <copy todir="${build.dir}/bin/lib">
+ <fileset basedir="lib">
+ <include name="**/*" />
+ <exclude name="log4net.dll" />
+ <exclude name="scvs.exe" />
+ </fileset>
+ </copy>
+ <!-- build OpenWire.Core assembly -->
+ <nant buildfile="src/OpenWire.Core/OpenWire.Core.build" target="build" />
+ <!-- build task assemblies -->
+ <nant target="build">
+ <buildfiles refid="tas.core"/>
+ </nant>
+ <!-- build Microsoft.NET specific task assemblies if we are on win32 and targeting a .NET Framework -->
+ <nant target="build" if="${platform::is-win32() and framework::get-family(framework::get-target-framework()) == 'net'}">
+ <buildfiles refid="tas.msnet"/>
+ </nant>
+ <!-- build win32 specific task assemblies if we are on win32 -->
+ <nant target="build" if="${platform::is-win32()}">
+ <buildfiles refid="tas.win32" />
+ </nant>
+ <!-- build OpenWire.Core.Tests assembly -->
+ <nant buildfile="tests/OpenWire.Core/OpenWire.Core.build" target="build" />
+ <!-- build tests for task assemblies -->
+ <nant target="build">
+ <buildfiles refid="tas.core.tests"/>
+ </nant>
+ <!-- build tests for Microsoft.NET specific extension assemblies if we are on win32 and targeting a .NET Framework -->
+ <nant target="build" if="${platform::is-win32() and framework::get-family(framework::get-target-framework()) == 'net'}">
+ <buildfiles refid="tas.msnet.tests"/>
+ </nant>
+ <nant target="build" if="${platform::is-win32()}">
+ <buildfiles refid="tas.win32.tests" />
+ </nant>
+ </target>
+
+ <target name="test" depends="build">
+ <!-- TODO NUnit stuff -->
+ </target>
+
+ <target name="package-doc">
+ </target>
+
+ <target name="package-common" depends="build">
+ <!-- move config file -->
+ <move file="${build.dir}/bin/OpenWire.exe.config" tofile="${build.dir}/bin/${console.name}.exe.config" />
+ <!-- remove non-release files -->
+ <delete>
+ <fileset basedir="${build.dir}/bin">
+ <include name="OpenWire.Console.*" />
+ <!-- remove test assemblies -->
+ <include name="*.Tests.*" />
+ </fileset>
+ </delete>
+ <!-- copy project files -->
+ <copy todir="${build.dir}">
+ <fileset>
+ <include name="*" />
+ <include name="doc/**" />
+ <include name="src/**" />
+ <include name="tests/**" />
+ <include name="examples/**" />
+ <include name="schema/**" />
+ <!-- third party assemblies -->
+ <include name="lib/**" />
+ <!-- website -->
+ <include name="web/**" />
+ <!-- docs -->
+ <include name="doc/**" />
+ <!-- exclude static html pages as these will be filter-copied -->
+ <exclude name="doc/**/*.html" />
+ <!-- exclude nighlty build file -->
+ <exclude name="nightly.xml" />
+ <!-- exclude release build file -->
+ <exclude name="release.xml" />
+ <!--exclude VS.Net stuff -->
+ <exclude name="**/*.suo" />
+ <exclude name="**/*j.user" />
+ <exclude name="**/bin/**" />
+ <exclude name="**/obj/**" />
+ </fileset>
+ </copy>
+ <!-- filter-copy static html pages -->
+ <copy todir="${build.dir}" overwrite="true">
+ <fileset>
+ <include name="doc/**/*.html" />
+ </fileset>
+ <filterchain>
+ <replacetokens>
+ <token key="PRODUCT_VERSION" value="${project.version.full}" />
+ </replacetokens>
+ <!-- when NOT building a release package, add prelimary notice -->
+ <replacestring
+ from="<!-- @PRELIMINARY_NOTICE@ -->"
+ to="<p class="topicstatus">[This is preliminary documentation and subject to change.]</p>"
+ unless="${project.release.type == 'release'}"
+ />
+ <!-- when building a release package, remove the placeholder -->
+ <replacestring
+ from="<!-- @PRELIMINARY_NOTICE@ -->"
+ to=""
+ if="${project.release.type == 'release'}"
+ />
+ </filterchain>
+ </copy>
+ <!-- determine the zip file prefix directory -->
+ <property name="project.zip.prefix" value="${project.name}-${project.version.full}" />
+ </target>
+
+
+ <target name="package-src" depends="package-common">
+ <!-- determine name of source zip distribution -->
+ <property name="project.zip-path.src" value="${project::get-base-directory()}/build/${project.name}-${project.version.full}-src.zip" />
+ <!-- remove package zip file if it already exists -->
+ <delete file="${project.zip-path.src}" if="${file::exists(project.zip-path.src)}" />
+ <!-- create package zip file -->
+ <zip zipfile="${project.zip-path.src}" ziplevel="9">
+ <fileset basedir="${build.dir}" prefix="${project.zip.prefix}">
+ <include name="Makefile" />
+ <include name="Makefile.nmake" />
+ <include name="OpenWire.build" />
+ <include name="OpenWire.sln" />
+ <include name="COPYING.txt" />
+ <include name="README.txt" />
+ <!-- third party assemblies -->
+ <include name="lib/**/*" />
+ <!-- license & release notes -->
+ <include name="doc/*" />
+ <!-- user manual (no SDK) -->
+ <include name="doc/help/**" />
+ <!-- examples -->
+ <include name="examples/**/*" />
+ <!-- sources -->
+ <include name="src/**/*" />
+ <!-- unit tests -->
+ <include name="tests/**/*" />
+ </fileset>
+ </zip>
+ <!-- determine name of source gzipped tar distribution -->
+ <property name="project.gzip-path.src" value="${project::get-base-directory()}/build/${project.name}-${project.version.full}-src.tar.gz" />
+ <!-- remove package gzip file if it already exists -->
+ <delete file="${project.gzip-path.src}" if="${file::exists(project.gzip-path.src)}" />
+ <!-- create package gzip file -->
+ <tar destfile="${project.gzip-path.src}" compression="GZip">
+ <fileset basedir="${build.dir}" prefix="${project.zip.prefix}">
+ <include name="Makefile" />
+ <include name="Makefile.nmake" />
+ <include name="OpenWire.build" />
+ <include name="OpenWire.sln" />
+ <include name="COPYING.txt" />
+ <include name="README.txt" />
+ <!-- third party assemblies -->
+ <include name="lib/**/*" />
+ <!-- license & release notes -->
+ <include name="doc/*" />
+ <!-- user manual (no SDK) -->
+ <include name="doc/help/**" />
+ <!-- examples -->
+ <include name="examples/**/*" />
+ <!-- sources -->
+ <include name="src/**/*" />
+ <!-- unit tests -->
+ <include name="tests/**/*" />
+ </fileset>
+ </tar>
+ <echo message="Created '${project.config}' source packages at file://${project::get-base-directory()}/build/" />
+ </target>
+
+ <target name="package-bin" depends="package-common">
+ <!-- determine name of binary zip distribution -->
+ <property name="project.zip-path.bin" value="${project::get-base-directory()}/build/${project.name}-${project.version.full}-bin.zip" />
+ <!-- remove package zip file if it already exists -->
+ <delete file="${project.zip-path.bin}" if="${file::exists(project.zip-path.bin)}" />
+ <!-- create package zip file -->
+ <zip zipfile="${project.zip-path.bin}" ziplevel="9">
+ <fileset basedir="${build.dir}" prefix="${project.zip.prefix}">
+ <include name="COPYING.txt" />
+ <include name="README.txt" />
+ <include name="bin/**/*" />
+ <!-- license & release notes -->
+ <include name="doc/*" />
+ <!-- user manual -->
+ <include name="doc/help/**" />
+ <!-- SDK (in HTML Help format) -->
+ <include name="doc/sdk/OpenWire-SDK.chm" />
+ <!-- examples -->
+ <include name="examples/**/*" />
+ <!-- XML Schema -->
+ <include name="schema/**/*" />
+ </fileset>
+ </zip>
+ <!-- determine name of binary gzipped tar distribution -->
+ <property name="project.gzip-path.bin" value="${project::get-base-directory()}/build/${project.name}-${project.version.full}-bin.tar.gz" />
+ <!-- remove package gzip file if it already exists -->
+ <delete file="${project.gzip-path.bin}" if="${file::exists(project.gzip-path.bin)}" />
+ <!-- create package gzip file -->
+ <tar destfile="${project.gzip-path.bin}" compression="GZip">
+ <fileset basedir="${build.dir}" prefix="${project.zip.prefix}">
+ <include name="COPYING.txt" />
+ <include name="README.txt" />
+ <include name="bin/**/*" />
+ <!-- license & release notes -->
+ <include name="doc/*" />
+ <!-- user manual -->
+ <include name="doc/help/**" />
+ <!-- SDK (in plain HTML format) -->
+ <include name="doc/sdk/*" />
+ <exclude name="doc/sdk/OpenWire-SDK.chm" />
+ <!-- examples -->
+ <include name="examples/**/*" />
+ <!-- XML Schema -->
+ <include name="schema/**/*" />
+ </fileset>
+ </tar>
+ <echo message="Created '${project.config}' binary packages at file://${project.zip-path.bin}" />
+ </target>
+
+ <target name="package" depends="package-doc, package-src, package-bin" description="Creates a binary and source distribution package." />
+
+ <!-- Copies files to the bin folder. -->
+ <target name="UpdateBin" depends="build" description="Does a release build and copies them to the bin folder.">
+ <delete if="false">
+ <fileset basedir="bin">
+ <include name="OpenWire*" />
+ <exclude name="${console.name}.exe" />
+ </fileset>
+ </delete>
+ <copy todir="bin" overwrite="true">
+ <fileset basedir="${build.dir}/bin/">
+ <include name="OpenWire*" />
+ <exclude name="*Test*" />
+ <exclude name="${console.name}.xml" />
+ <exclude name="${console.name}.exe" />
+ </fileset>
+ </copy>
+ </target>
+
+ <!-- Framework support targets -->
+ <target name="set-framework-configuration">
+ <if test="${not(target::exists('set-'+framework::get-target-framework()+'-framework-configuration'))}">
+ <fail message="The '${framework::get-target-framework()}' framework is not supported by this version of OpenWire." />
+ </if>
+ <call target="set-${framework::get-target-framework()}-framework-configuration" />
+ </target>
+ <target name="set-net-1.0-framework-configuration">
+ <property name="nant.settings.currentframework" value="net-1.0" />
+ <property name="current.build.defines" value="${build.defines}NET,NET_1_0" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_0" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+ <target name="set-net-1.1-framework-configuration">
+ <property name="nant.settings.currentframework" value="net-1.1" />
+ <property name="current.build.defines" value="${build.defines}NET,NET_1_1" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_1" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+ <target name="set-net-2.0-framework-configuration">
+ <property name="nant.settings.currentframework" value="net-2.0" />
+ <property name="current.build.defines" value="${build.defines}NET,NET_2_0" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_1" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+ <target name="set-netcf-1.0-framework-configuration">
+ <property name="nant.settings.currentframework" value="netcf-1.0" />
+ <property name="current.build.defines" value="${build.defines}NETCF,NETCF_1_0" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_1" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+ <target name="set-mono-1.0-framework-configuration">
+ <property name="nant.settings.currentframework" value="mono-1.0" />
+ <property name="current.build.defines" value="${build.defines}MONO,MONO_1_0" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_1" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+ <target name="set-mono-2.0-framework-configuration">
+ <property name="nant.settings.currentframework" value="mono-2.0" />
+ <property name="current.build.defines" value="${build.defines}MONO,MONO_2_0" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_1" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+ <target name="set-sscli-1.0-framework-configuration">
+ <property name="nant.settings.currentframework" value="sscli-1.0" />
+ <property name="current.build.defines" value="${build.defines}SSCLI,SSCLI_1_0" dynamic="true" />
+ <property name="link.sdkdoc.version" value="SDK_v1_0" />
+ <property name="link.sdkdoc.web" value="true" />
+ </target>
+
+ <!-- install targets -->
+
+ <target name="install" depends="install-windows, install-linux" />
+
+<!--depends="userdoc" -->
+ <target name="install-windows" depends="build" if="${platform::is-win32()}">
+ <!-- install to program files directory by default -->
+ <property name="install.realprefix" value="${environment::get-folder-path('ProgramFiles')}" />
+ <if test="${property::exists('install.prefix') and string::get-length(install.prefix) != 0}">
+ <property name="install.realprefix" value="${install.prefix}" />
+ </if>
+ <property name="install.copylocation" value="${path::combine(install.realprefix, 'OpenWire')}"/>
+ <echo message="Installing OpenWire to '${install.copylocation}' ..." />
+
+ <copy todir="${install.copylocation}" overwrite="true">
+ <fileset basedir="${build.dir}">
+ <include name="bin/**/*" />
+ <include name="doc/**/*" />
+
+ <exclude name="bin/nant.tests.config" />
+ <exclude name="bin/*.Tests.*" />
+ </fileset>
+ </copy>
+ </target>
+
+ <target name="install-linux" depends="build" if="${platform::is-unix()}">
+ <property name="install.realprefix" value="/usr/local" />
+ <if test="${property::exists('install.prefix') and string::get-length(install.prefix) != 0}">
+ <property name="install.realprefix" value="${install.prefix}" />
+ </if>
+ <property name="install.bindir" value="${path::combine(install.realprefix, 'bin')}"/>
+ <property name="install.share" value="${path::combine(install.realprefix, 'share')}"/>
+ <property name="install.copylocation" value="${path::combine (install.share, 'OpenWire')}"/>
+ <property name="prefix" value="${pkg-config::get-variable('mono', 'prefix')}"/>
+ <echo message="Installing OpenWire to '${install.copylocation}' ..." />
+
+ <copy todir="${install.copylocation}" overwrite="true">
+ <fileset basedir="${build.dir}">
+ <include name="bin/**/*" />
+ <include name="doc/**/*" />
+
+ <exclude name="bin/nant.tests.config" />
+ <exclude name="bin/*.Tests.*" />
+ </fileset>
+ </copy>
+ <echo message="Installing OpenWire wrapper script to '${install.bindir}' ..." />
+ <!-- store filename of wrapper script in property -->
+ <property name="wrapper" value="${path::combine(install.bindir, 'nant')}" />
+ <!--
+ create wrapper file using separate echo tasks for each line to ensure
+ the line endings of the generated file match the platform on which
+ the wrapper is created
+ -->
+ <echo file="${wrapper}" append="false">#!/bin/sh</echo>
+ <echo file="${wrapper}" append="true">exec ${path::combine(prefix, 'bin')}/mono ${path::combine(install.copylocation, 'bin')}/OpenWire.exe "$@"</echo>
+ <exec program="chmod" commandline="a+x ${path::combine(install.bindir, 'nant')}"/>
+ </target>
+
+ <target name="rpm" depends="init, build">
+ <echo message="Build dir: ${build.dir}"/>
+ <copy todir="${build.dir}">
+ <fileset>
+ <include name="OpenWire.spec" />
+ </fileset>
+ </copy>
+
+ <nant buildfile="release.xml" target="prepare-rpm"/>
+ <nant buildfile="release.xml" target="binary-rpm"/>
+ </target>
+</project>
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,166 @@
+using System;
+
+namespace OpenWire.Core
+{
+ /// <summary>
+ /// Summary description for AbstractCommand.
+ /// </summary>
+ public abstract class AbstractCommand {
+
+ public const int NON_PERSISTENT = 1;
+ public const int PERSISTENT = 2;
+
+ /**
+ * Message flag indexes (used for writing/reading to/from a Stream
+ */
+ public const int RECEIPT_REQUIRED_INDEX = 0;
+ public const int BROKERS_VISITED_INDEX =1;
+ private short id = 0;
+ private bool receiptRequired;
+
+ protected AbstractCommand()
+ {
+
+ }
+
+ public virtual int GetCommandType()
+ {
+ return 0;
+ }
+
+ public short getId()
+ {
+ return this.id;
+ }
+
+ public virtual void setId(short newId)
+ {
+ this.id = newId;
+ }
+
+ public virtual bool isReceiptRequired()
+ {
+ return this.receiptRequired;
+ }
+
+
+ public virtual bool isReceipt()
+ {
+ return false;
+ }
+
+ public void setReceiptRequired(bool value)
+ {
+ this.receiptRequired = value;
+ }
+
+ public virtual bool isJMSMessage()
+ {
+ return false;
+ }
+
+ public int hashCode()
+ {
+ return this.id;
+ }
+
+ public virtual short getCommandType()
+ {
+ return id;
+ }
+
+ public String toString()
+ {
+ return getCommandTypeAsString(getCommandType()) + ": id = " + getId();
+ }
+
+
+ public static String getCommandTypeAsString(int type)
+ {
+ String packetTypeStr = "";
+ switch (type)
+ {
+ case CommandConstants.ACTIVEMQ_MESSAGE:
+ packetTypeStr = "ACTIVEMQ_MESSAGE";
+ break;
+ case CommandConstants.ACTIVEMQ_TEXT_MESSAGE:
+ packetTypeStr = "ACTIVEMQ_TEXT_MESSAGE";
+ break;
+ case CommandConstants.ACTIVEMQ_OBJECT_MESSAGE:
+ packetTypeStr = "ACTIVEMQ_OBJECT_MESSAGE";
+ break;
+ case CommandConstants.ACTIVEMQ_BYTES_MESSAGE:
+ packetTypeStr = "ACTIVEMQ_BYTES_MESSAGE";
+ break;
+ case CommandConstants.ACTIVEMQ_STREAM_MESSAGE:
+ packetTypeStr = "ACTIVEMQ_STREAM_MESSAGE";
+ break;
+ case CommandConstants.ACTIVEMQ_MAP_MESSAGE:
+ packetTypeStr = "ACTIVEMQ_MAP_MESSAGE";
+ break;
+ case CommandConstants.ACTIVEMQ_MSG_ACK:
+ packetTypeStr = "ACTIVEMQ_MSG_ACK";
+ break;
+ case CommandConstants.RECEIPT_INFO:
+ packetTypeStr = "RECEIPT_INFO";
+ break;
+ case CommandConstants.CONSUMER_INFO:
+ packetTypeStr = "CONSUMER_INFO";
+ break;
+ case CommandConstants.PRODUCER_INFO:
+ packetTypeStr = "PRODUCER_INFO";
+ break;
+ case CommandConstants.TRANSACTION_INFO:
+ packetTypeStr = "TRANSACTION_INFO";
+ break;
+ case CommandConstants.XA_TRANSACTION_INFO:
+ packetTypeStr = "XA_TRANSACTION_INFO";
+ break;
+ case CommandConstants.ACTIVEMQ_BROKER_INFO:
+ packetTypeStr = "ACTIVEMQ_BROKER_INFO";
+ break;
+ case CommandConstants.ACTIVEMQ_CONNECTION_INFO:
+ packetTypeStr = "ACTIVEMQ_CONNECTION_INFO";
+ break;
+ case CommandConstants.SESSION_INFO:
+ packetTypeStr = "SESSION_INFO";
+ break;
+ case CommandConstants.DURABLE_UNSUBSCRIBE:
+ packetTypeStr = "DURABLE_UNSUBSCRIBE";
+ break;
+ case CommandConstants.RESPONSE_RECEIPT_INFO:
+ packetTypeStr = "RESPONSE_RECEIPT_INFO";
+ break;
+ case CommandConstants.INT_RESPONSE_RECEIPT_INFO:
+ packetTypeStr = "INT_RESPONSE_RECEIPT_INFO";
+ break;
+ case CommandConstants.CAPACITY_INFO:
+ packetTypeStr = "CAPACITY_INFO";
+ break;
+ case CommandConstants.CAPACITY_INFO_REQUEST:
+ packetTypeStr = "CAPACITY_INFO_REQUEST";
+ break;
+ case CommandConstants.WIRE_FORMAT_INFO:
+ packetTypeStr = "WIRE_FORMAT_INFO";
+ break;
+ case CommandConstants.KEEP_ALIVE:
+ packetTypeStr = "KEEP_ALIVE";
+ break;
+ case CommandConstants.CACHED_VALUE_COMMAND:
+ packetTypeStr = "CachedValue";
+ break;
+ default :
+ packetTypeStr = "UNKNOWN PACKET TYPE: " + type;
+ break;
+ }
+ return packetTypeStr;
+ }
+
+ protected virtual bool equals(Object left, Object right)
+ {
+ return left == right || (left != null && left.Equals(right));
+ }
+
+ }
+}
+
Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs
------------------------------------------------------------------------------
svn:executable = *
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,19 @@
+using System;
+
+namespace OpenWire.Core
+{
+ /// <summary>
+ /// A base class with useful implementation inheritence methods
+ /// for creating marshallers of the OpenWire protocol
+ /// </summary>
+ public abstract class AbstractCommandMarshaller {
+
+ public abstract Command CreateCommand();
+
+ public abstract void BuildCommand(Command command, BinaryReader dataIn);
+
+ public abstract void WriteCommand(Command command, BinaryWriter dataOut);
+
+ }
+}
+
Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs
------------------------------------------------------------------------------
svn:executable = *
Copied: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs (from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQDestination.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs&p1=incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQDestination.cs&r1=366455&r2=366537&rev=366537&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQDestination.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs Fri Jan 6 09:24:01 2006
@@ -1,6 +1,6 @@
using System;
-namespace ActiveMQ
+namespace OpenWire.Core
{
/// <summary>
/// Summary description for ActiveMQDestination.
@@ -282,7 +282,7 @@
/**
* @param o object to compare
- * @return 1 if this > o else 0 if they are equal or -1 if this < o
+ * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
*/
public int compareTo(Object o) {
if (o is ActiveMQDestination) {
@@ -295,7 +295,7 @@
* Lets sort by name first then lets sort topics greater than queues
*
* @param that another destination to compare against
- * @return 1 if this > that else 0 if they are equal or -1 if this < that
+ * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
*/
public int compareTo(ActiveMQDestination that) {
int answer = 0;
Copied: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs (from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQQueue.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs&p1=incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQQueue.cs&r1=366455&r2=366537&rev=366537&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs Fri Jan 6 09:24:01 2006
@@ -1,6 +1,6 @@
using System;
-namespace ActiveMQ
+namespace OpenWire.Core
{
/// <summary>
/// Summary description for ActiveMQQueue.
Copied: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs (from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQTopic.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs&p1=incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQTopic.cs&r1=366455&r2=366537&rev=366537&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/ActiveMQTopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs Fri Jan 6 09:24:01 2006
@@ -1,6 +1,6 @@
using System;
-namespace ActiveMQ
+namespace OpenWire.Core
{
/// <summary>
/// Summary description for ActiveMQTopic.
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,14 @@
+using System;
+
+namespace OpenWire.Core
+{
+ /// <summary>
+ /// An OpenWire command
+ /// </summary>
+ public interface Command {
+
+ int GetCommandType();
+
+ }
+}
+
Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs
------------------------------------------------------------------------------
svn:executable = *
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/CommandConstants.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/CommandConstants.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/CommandConstants.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/CommandConstants.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,157 @@
+using System;
+
+namespace OpenWire.Core
+{
+ /// <summary>
+ /// TODO autogenerate this file!
+ /// </summary>
+ class CommandConstants
+ {
+ CommandConstants()
+ {}
+
+ public const int NOT_SET = 0;
+
+ /**
+ * ActiveMQMessage object
+ */
+ public const int ACTIVEMQ_MESSAGE = 6;
+
+ /**
+ * ActiveMQTextMessage object
+ */
+
+ public const int ACTIVEMQ_TEXT_MESSAGE = 7;
+
+ /**
+ * ActiveMQObjectMessage object
+ */
+
+ public const int ACTIVEMQ_OBJECT_MESSAGE = 8;
+
+ /**
+ * ActiveMQBytesMessage
+ */
+
+ public const int ACTIVEMQ_BYTES_MESSAGE = 9;
+
+ /**
+ * ActiveMQStreamMessage object
+ */
+
+ public const int ACTIVEMQ_STREAM_MESSAGE = 10;
+
+ /**
+ * ActiveMQMapMessage object
+ */
+
+ public const int ACTIVEMQ_MAP_MESSAGE = 11;
+
+ /**
+ * Message acknowledge
+ */
+ public const int ACTIVEMQ_MSG_ACK = 15;
+
+ /**
+ * Recipt message
+ */
+
+ public const int RECEIPT_INFO = 16;
+
+ /**
+ * Consumer Infomation
+ */
+
+ public const int CONSUMER_INFO = 17;
+
+ /**
+ * Producer Info
+ */
+
+ public const int PRODUCER_INFO = 18;
+
+ /**
+ * Transaction info
+ */
+
+ public const int TRANSACTION_INFO = 19;
+
+ /**
+ * XA Transaction info
+ */
+
+ public const int XA_TRANSACTION_INFO = 20;
+
+ /**
+ * Broker infomation message
+ */
+
+ public const int ACTIVEMQ_BROKER_INFO = 21;
+
+ /**
+ * Connection info message
+ */
+
+ public const int ACTIVEMQ_CONNECTION_INFO = 22;
+
+
+ /**
+ * Session Info message
+ */
+ public const int SESSION_INFO = 23;
+
+ /**
+ * Durable Unsubscribe message
+ */
+
+ public const int DURABLE_UNSUBSCRIBE = 24;
+
+
+ /**
+ * A receipt with an Object reponse.
+ */
+ public const int RESPONSE_RECEIPT_INFO = 25;
+
+
+ /**
+ * A receipt with an Integer reponse.
+ */
+ public const int INT_RESPONSE_RECEIPT_INFO = 26;
+
+ /**
+ * Infomation about the Capacity for more Messages for either Connection/Broker
+ */
+ public const int CAPACITY_INFO = 27;
+
+ /**
+ * Request infomation about the current capacity
+ */
+ public const int CAPACITY_INFO_REQUEST = 28;
+
+ /**
+ * Infomation about the wire format expected
+ */
+ public const int WIRE_FORMAT_INFO = 29;
+
+ /**
+ * Keep-alive message
+ */
+ public const int KEEP_ALIVE = 30;
+
+ /**
+ * A command to the Broker Admin
+ */
+ public const int BROKER_ADMIN_COMMAND = 31;
+
+ /**
+ * transmit cached values for the wire format
+ */
+ public const int CACHED_VALUE_COMMAND = 32;
+
+ /**
+ * transmit cached values for the wire format
+ */
+ public const int CLEANUP_CONNECTION_INFO = 33;
+ }
+ }
+
Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/CommandConstants.cs
------------------------------------------------------------------------------
svn:executable = *
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQBytesMessage
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQBytesMessage : ActiveMQMessage
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQDestination
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQDestination : AbstractCommand
+ {
+ string physicalName;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string PhysicalName
+ {
+ get
+ {
+ return physicalName;
+ }
+ set
+ {
+ physicalName = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQMapMessage
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQMapMessage : ActiveMQMessage
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQMessage
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQMessage : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQObjectMessage
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQObjectMessage : ActiveMQMessage
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQQueue
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQQueue : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQStreamMessage
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQStreamMessage : ActiveMQMessage
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTempDestination
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQTempDestination : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTempQueue
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQTempQueue : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTempTopic
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQTempTopic : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTextMessage
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQTextMessage : ActiveMQMessage
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTopic
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ActiveMQTopic : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,62 @@
+//
+// Marshalling code for Open Wire Format for BaseCommand
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class BaseCommand : AbstractCommand
+ {
+ short commandId;
+ bool responseRequired;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public short CommandId
+ {
+ get
+ {
+ return commandId;
+ }
+ set
+ {
+ commandId = value;
+ }
+ }
+
+ public bool ResponseRequired
+ {
+ get
+ {
+ return responseRequired;
+ }
+ set
+ {
+ responseRequired = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for BrokerId
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class BrokerId : AbstractCommand
+ {
+ string brokerId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string BrokerIdValue
+ {
+ get
+ {
+ return brokerId;
+ }
+ set
+ {
+ brokerId = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,88 @@
+//
+// Marshalling code for Open Wire Format for BrokerInfo
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class BrokerInfo : AbstractCommand
+ {
+ BrokerId brokerId;
+ string brokerURL;
+ BrokerInfo[] peerBrokerInfos;
+ string brokerName;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public BrokerId BrokerId
+ {
+ get
+ {
+ return brokerId;
+ }
+ set
+ {
+ brokerId = value;
+ }
+ }
+
+ public string BrokerURL
+ {
+ get
+ {
+ return brokerURL;
+ }
+ set
+ {
+ brokerURL = value;
+ }
+ }
+
+ public BrokerInfo[] PeerBrokerInfos
+ {
+ get
+ {
+ return peerBrokerInfos;
+ }
+ set
+ {
+ peerBrokerInfos = value;
+ }
+ }
+
+ public string BrokerName
+ {
+ get
+ {
+ return brokerName;
+ }
+ set
+ {
+ brokerName = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for ConnectionId
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ConnectionId : AbstractCommand
+ {
+ string connectionId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string ConnectionIdValue
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,101 @@
+//
+// Marshalling code for Open Wire Format for ConnectionInfo
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ConnectionInfo : AbstractCommand
+ {
+ ConnectionId connectionId;
+ string clientId;
+ string password;
+ string userName;
+ BrokerId[] brokerPath;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ConnectionId ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public string ClientId
+ {
+ get
+ {
+ return clientId;
+ }
+ set
+ {
+ clientId = value;
+ }
+ }
+
+ public string Password
+ {
+ get
+ {
+ return password;
+ }
+ set
+ {
+ password = value;
+ }
+ }
+
+ public string UserName
+ {
+ get
+ {
+ return userName;
+ }
+ set
+ {
+ userName = value;
+ }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get
+ {
+ return brokerPath;
+ }
+ set
+ {
+ brokerPath = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for ConsumerId
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ConsumerId : AbstractCommand
+ {
+ string connectionId;
+ long sessionId;
+ long consumerId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public long SessionId
+ {
+ get
+ {
+ return sessionId;
+ }
+ set
+ {
+ sessionId = value;
+ }
+ }
+
+ public long ConsumerIdValue
+ {
+ get
+ {
+ return consumerId;
+ }
+ set
+ {
+ consumerId = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,205 @@
+//
+// Marshalling code for Open Wire Format for ConsumerInfo
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ConsumerInfo : AbstractCommand
+ {
+ ConsumerId consumerId;
+ bool browser;
+ ActiveMQDestination destination;
+ int prefetchSize;
+ bool dispatchAsync;
+ string selector;
+ string subcriptionName;
+ bool noLocal;
+ bool exclusive;
+ bool retroactive;
+ byte priority;
+ BrokerId[] brokerPath;
+ bool networkSubscription;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ConsumerId ConsumerId
+ {
+ get
+ {
+ return consumerId;
+ }
+ set
+ {
+ consumerId = value;
+ }
+ }
+
+ public bool Browser
+ {
+ get
+ {
+ return browser;
+ }
+ set
+ {
+ browser = value;
+ }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public int PrefetchSize
+ {
+ get
+ {
+ return prefetchSize;
+ }
+ set
+ {
+ prefetchSize = value;
+ }
+ }
+
+ public bool DispatchAsync
+ {
+ get
+ {
+ return dispatchAsync;
+ }
+ set
+ {
+ dispatchAsync = value;
+ }
+ }
+
+ public string Selector
+ {
+ get
+ {
+ return selector;
+ }
+ set
+ {
+ selector = value;
+ }
+ }
+
+ public string SubcriptionName
+ {
+ get
+ {
+ return subcriptionName;
+ }
+ set
+ {
+ subcriptionName = value;
+ }
+ }
+
+ public bool NoLocal
+ {
+ get
+ {
+ return noLocal;
+ }
+ set
+ {
+ noLocal = value;
+ }
+ }
+
+ public bool Exclusive
+ {
+ get
+ {
+ return exclusive;
+ }
+ set
+ {
+ exclusive = value;
+ }
+ }
+
+ public bool Retroactive
+ {
+ get
+ {
+ return retroactive;
+ }
+ set
+ {
+ retroactive = value;
+ }
+ }
+
+ public byte Priority
+ {
+ get
+ {
+ return priority;
+ }
+ set
+ {
+ priority = value;
+ }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get
+ {
+ return brokerPath;
+ }
+ set
+ {
+ brokerPath = value;
+ }
+ }
+
+ public bool NetworkSubscription
+ {
+ get
+ {
+ return networkSubscription;
+ }
+ set
+ {
+ networkSubscription = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for ControlCommand
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class ControlCommand : AbstractCommand
+ {
+ string command;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string Command
+ {
+ get
+ {
+ return command;
+ }
+ set
+ {
+ command = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for DataArrayResponse
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class DataArrayResponse : AbstractCommand
+ {
+ Command[] data;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public Command[] Data
+ {
+ get
+ {
+ return data;
+ }
+ set
+ {
+ data = value;
+ }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for DataResponse
+//
+//
+// 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 OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+ public class DataResponse : AbstractCommand
+ {
+ Command data;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public Command Data
+ {
+ get
+ {
+ return data;
+ }
+ set
+ {
+ data = value;
+ }
+ }
+
+ }
+}