activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r419411 - in /incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ: Commands/ConnectionControl.cs Commands/ConsumerControl.cs OpenWire/V1/ConnectionControlMarshaller.cs OpenWire/V1/ConsumerControlMarshaller.cs
Date Thu, 06 Jul 2006 02:30:55 GMT
Author: chirino
Date: Wed Jul  5 19:30:55 2006
New Revision: 419411

URL: http://svn.apache.org/viewvc?rev=419411&view=rev
Log:
Setting the eol style to native

Modified:
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
  (contents, props changed)
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
  (contents, props changed)
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
  (contents, props changed)
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
  (contents, props changed)

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs?rev=419411&r1=419410&r2=419411&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
Wed Jul  5 19:30:55 2006
@@ -1 +1,96 @@
-/*
* 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 Comm
 and
	/// </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; }   
        
        }

    }
}
\ No newline at end of file
+/*
+* 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; }            
+        }
+
+    }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionControl.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs?rev=419411&r1=419410&r2=419411&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
Wed Jul  5 19:30:55 2006
@@ -1 +1,80 @@
-/*
* 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 Comman
 d
	/// </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; }            
     
    }

    }
}
\ No newline at end of file
+/*
+* 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; }            
+        }
+
+    }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerControl.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs?rev=419411&r1=419410&r2=419411&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
Wed Jul  5 19:30:55 2006
@@ -1 +1,131 @@
-/*
* 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
    //
    publ
 ic 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(OpenW
 ireFormat 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);

    }
    
  }
}
\ No newline at end of file
+/*
+* 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);
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConnectionControlMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs?rev=419411&r1=419410&r2=419411&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
Wed Jul  5 19:30:55 2006
@@ -1 +1,120 @@
-/*
* 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(wireForm
 at, 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);

    }
    
  }
}
\ No newline at end of file
+/*
+* 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);
+
+    }
+    
+  }
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ConsumerControlMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message