Added openwire classes that were generated for the .NET port

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398596 13f79535-47bb-0310-9956-ffa450edef68
2006-05-01 14:04:38 +00:00 · 2006-05-01 14:04:38 +00:00 · c3efc55084
parent 6b1682f949
commit c3efc55084
5 changed files with 6 additions and 1 deletions
--- a/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
+++ b/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
@ -0,0 +1 @@
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  NOTE!: This file is autogenerated - do not modify!
//         if you need to make a change, please see the Groovy scripts in the
//         activemq-core module
//

using System;
using System.Collections;

using ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ ConnectionControl Command
	/// </summary>
    public class ConnectionControl : BaseCommand
    {
        public const byte ID_ConnectionControl = 18;
    			
        bool close;
        bool exit;
        bool faultTolerant;
        bool resume;
        bool suspend;

		public override string ToString() {
            return GetType().Name + "["
                + " Close=" + Close
                + " Exit=" + Exit
                + " FaultTolerant=" + FaultTolerant
                + " Resume=" + Resume
                + " Suspend=" + Suspend
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_ConnectionControl;
        }


        // Properties

        public bool Close
        {
            get { return close; }
            set { this.close = value; }            
        }

        public bool Exit
        {
            get { return exit; }
            set { this.exit = value; }            
        }

        public bool FaultTolerant
        {
            get { return faultTolerant; }
            set { this.faultTolerant = value; }            
        }

        public bool Resume
        {
            get { return resume; }
            set { this.resume = value; }            
        }

        public bool Suspend
        {
            get { return suspend; }
            set { this.suspend = value; }            
        }

    }
}
--- a/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
+++ b/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
@ -0,0 +1 @@
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  NOTE!: This file is autogenerated - do not modify!
//         if you need to make a change, please see the Groovy scripts in the
//         activemq-core module
//

using System;
using System.Collections;

using ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ ConsumerControl Command
	/// </summary>
    public class ConsumerControl : BaseCommand
    {
        public const byte ID_ConsumerControl = 17;
    			
        bool close;
        ConsumerId consumerId;
        int prefetch;

		public override string ToString() {
            return GetType().Name + "["
                + " Close=" + Close
                + " ConsumerId=" + ConsumerId
                + " Prefetch=" + Prefetch
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_ConsumerControl;
        }


        // Properties

        public bool Close
        {
            get { return close; }
            set { this.close = value; }            
        }

        public ConsumerId ConsumerId
        {
            get { return consumerId; }
            set { this.consumerId = value; }            
        }

        public int Prefetch
        {
            get { return prefetch; }
            set { this.prefetch = value; }            
        }

    }
}
--- a/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
+++ b/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
@ -0,0 +1 @@
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
// NOTE!: This file is autogenerated - do not modify!
//        if you need to make a change, please see the Groovy scripts in the
//        activemq-core module
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for ConnectionControl
  /// </summary>
  class ConnectionControlMarshaller : BaseCommandMarshaller
  {


    public override DataStructure CreateObject() 
    {
        return new ConnectionControl();
    }

    public override byte GetDataStructureType() 
    {
        return ConnectionControl.ID_ConnectionControl;
    }

    // 
    // Un-marshal an object instance from the data input stream
    // 
    public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
    {
        base.TightUnmarshal(wireFormat, o, dataIn, bs);

        ConnectionControl info = (ConnectionControl)o;
        info.Close = bs.ReadBoolean();
        info.Exit = bs.ReadBoolean();
        info.FaultTolerant = bs.ReadBoolean();
        info.Resume = bs.ReadBoolean();
        info.Suspend = bs.ReadBoolean();

    }

    //
    // Write the booleans that this object uses to a BooleanStream
    //
    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
        ConnectionControl info = (ConnectionControl)o;

        int rc = base.TightMarshal1(wireFormat, info, bs);
        bs.WriteBoolean(info.Close);
        bs.WriteBoolean(info.Exit);
        bs.WriteBoolean(info.FaultTolerant);
        bs.WriteBoolean(info.Resume);
        bs.WriteBoolean(info.Suspend);

        return rc + 0;
    }

    // 
    // Write a object instance to data output stream
    //
    public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
        base.TightMarshal2(wireFormat, o, dataOut, bs);

        ConnectionControl info = (ConnectionControl)o;
        bs.ReadBoolean();
        bs.ReadBoolean();
        bs.ReadBoolean();
        bs.ReadBoolean();
        bs.ReadBoolean();

    }

    // 
    // Un-marshal an object instance from the data input stream
    // 
    public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn) 
    {
        base.LooseUnmarshal(wireFormat, o, dataIn);

        ConnectionControl info = (ConnectionControl)o;
        info.Close = dataIn.ReadBoolean();
        info.Exit = dataIn.ReadBoolean();
        info.FaultTolerant = dataIn.ReadBoolean();
        info.Resume = dataIn.ReadBoolean();
        info.Suspend = dataIn.ReadBoolean();

    }

    // 
    // Write a object instance to data output stream
    //
    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {

        ConnectionControl info = (ConnectionControl)o;

        base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.Close);
        dataOut.Write(info.Exit);
        dataOut.Write(info.FaultTolerant);
        dataOut.Write(info.Resume);
        dataOut.Write(info.Suspend);

    }
    
  }
}
--- a/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
+++ b/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
@ -0,0 +1 @@
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
// NOTE!: This file is autogenerated - do not modify!
//        if you need to make a change, please see the Groovy scripts in the
//        activemq-core module
//

using System;
using System.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V1;

namespace ActiveMQ.OpenWire.V1
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for ConsumerControl
  /// </summary>
  class ConsumerControlMarshaller : BaseCommandMarshaller
  {


    public override DataStructure CreateObject() 
    {
        return new ConsumerControl();
    }

    public override byte GetDataStructureType() 
    {
        return ConsumerControl.ID_ConsumerControl;
    }

    // 
    // Un-marshal an object instance from the data input stream
    // 
    public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn, BooleanStream bs) 
    {
        base.TightUnmarshal(wireFormat, o, dataIn, bs);

        ConsumerControl info = (ConsumerControl)o;
        info.Close = bs.ReadBoolean();
        info.ConsumerId = (ConsumerId) TightUnmarshalNestedObject(wireFormat, dataIn, bs);
        info.Prefetch = dataIn.ReadInt32();

    }

    //
    // Write the booleans that this object uses to a BooleanStream
    //
    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
        ConsumerControl info = (ConsumerControl)o;

        int rc = base.TightMarshal1(wireFormat, info, bs);
        bs.WriteBoolean(info.Close);
        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.ConsumerId, bs);

        return rc + 4;
    }

    // 
    // Write a object instance to data output stream
    //
    public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) {
        base.TightMarshal2(wireFormat, o, dataOut, bs);

        ConsumerControl info = (ConsumerControl)o;
        bs.ReadBoolean();
        TightMarshalNestedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs);
        dataOut.Write(info.Prefetch);

    }

    // 
    // Un-marshal an object instance from the data input stream
    // 
    public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn) 
    {
        base.LooseUnmarshal(wireFormat, o, dataIn);

        ConsumerControl info = (ConsumerControl)o;
        info.Close = dataIn.ReadBoolean();
        info.ConsumerId = (ConsumerId) LooseUnmarshalNestedObject(wireFormat, dataIn);
        info.Prefetch = dataIn.ReadInt32();

    }

    // 
    // Write a object instance to data output stream
    //
    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {

        ConsumerControl info = (ConsumerControl)o;

        base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.Close);
        LooseMarshalNestedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut);
        dataOut.Write(info.Prefetch);

    }
    
  }
}
--- a/pom.xml
+++ b/pom.xml
@ -321,7 +321,7 @@
        <artifactId>xbean-spring</artifactId>
        <version>2.2</version>
        <optional>true</optional>
-
+        <!--
        <exclusions>
          <exclusion>
            <groupId>backport-util-concurrent</groupId>
@ -348,6 +348,7 @@
            <artifactId>stax-api</artifactId>
          </exclusion>
        </exclusions>
+        -->

      </dependency>
				`@ -0,0 +1 @@`
				/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed 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. */ // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { /// <summary> /// The ActiveMQ ConnectionControl Command /// </summary> public class ConnectionControl : BaseCommand { public const byte ID_ConnectionControl = 18; bool close; bool exit; bool faultTolerant; bool resume; bool suspend; public override string ToString() { return GetType().Name + "[" + " Close=" + Close + " Exit=" + Exit + " FaultTolerant=" + FaultTolerant + " Resume=" + Resume + " Suspend=" + Suspend + " ]"; } public override byte GetDataStructureType() { return ID_ConnectionControl; } // Properties public bool Close { get { return close; } set { this.close = value; } } public bool Exit { get { return exit; } set { this.exit = value; } } public bool FaultTolerant { get { return faultTolerant; } set { this.faultTolerant = value; } } public bool Resume { get { return resume; } set { this.resume = value; } } public bool Suspend { get { return suspend; } set { this.suspend = value; } } } }