activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r384827 - in /incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ: Commands/ OpenWire/V1/
Date Fri, 10 Mar 2006 15:54:44 GMT
Author: jstrachan
Date: Fri Mar 10 07:54:42 2006
New Revision: 384827

URL: http://svn.apache.org/viewcvs?rev=384827&view=rev
Log:
Latest generated openwire

Added:
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/LastPartialCommand.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/PartialCommand.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs
Modified:
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ReplayCommand.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Response.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs

Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/LastPartialCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/LastPartialCommand.cs?rev=384827&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/LastPartialCommand.cs
(added)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/LastPartialCommand.cs
Fri Mar 10 07:54:42 2006
@@ -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
LastPartialCommand Com
 mand
	/// </summary>
    public class LastPartialCommand : PartialCommand
    {
  
     public const byte ID_LastPartialCommand = 61;
    			

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

		}
	


        public
override byte GetDataStructureType() {
            return ID_LastPartialCommand;
        }


       // Properties

    }
}
\ No newline at end of file

Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/PartialCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/PartialCommand.cs?rev=384827&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/PartialCommand.cs
(added)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/PartialCommand.cs
Fri Mar 10 07:54:42 2006
@@ -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
PartialCommand Command
 
	/// </summary>
    public class PartialCommand : BaseCommand
    {
        public
const byte ID_PartialCommand = 60;
    			
        byte[] data;

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

		}
	


        public override byte GetDataStructureType() {
     
      return ID_PartialCommand;
        }


        // Properties

        public byte[] Data
       {
            get { return data; }
            set { this.data = value; }         
  
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ReplayCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ReplayCommand.cs?rev=384827&r1=384826&r2=384827&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ReplayCommand.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ReplayCommand.cs
Fri Mar 10 07:54:42 2006
@@ -1 +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
ReplayCommand Command
 	/// </summary>
    public class ReplayCommand : BaseCommand
    {
        public const
byte ID_ReplayCommand = 38;
    			

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

		}
	


        public override byte GetDataStructureType()
{
            return ID_ReplayCommand;
        }


        // Properties

    }
}
\ 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
ReplayCommand Command
 	/// </summary>
    public class ReplayCommand : BaseCommand
    {
        public const
byte ID_ReplayCommand = 65;
    			
        int firstNakNumber;
        int lastNakNumber;

	public override string ToString() {
            return GetType().Name + "["
            
   + " FirstNakNumber=" + FirstNakNumber
                + " LastNakNumber=" + LastNakNumber
               + " ]";

		}
	


        public override byte GetDataStructureType() {
   
        return ID_ReplayCommand;
        }


        // Properties

        public int FirstNakNumber
       {
            get { return firstNakNumber; }
            set { this.firstNakNumber
= value; }            
        }

        public int LastNakNumber
        {
            get
{ return lastNakNumber; }
            set { this.lastNakNumber = value; }            
   
    }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Response.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Response.cs?rev=384827&r1=384826&r2=384827&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Response.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Response.cs
Fri Mar 10 07:54:42 2006
@@ -1 +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
Response Command
	/// 
 </summary>
    public class Response : BaseCommand
    {
        public const byte
ID_Response = 30;
    			
        short correlationId;

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

		}
	


        public override byte GetDataStructureType() {
   
        return ID_Response;
        }


        // Properties

        public short CorrelationId
       {
            get { return correlationId; }
            set { this.correlationId =
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
Response Command
	/// 
 </summary>
    public class Response : BaseCommand
    {
        public const byte
ID_Response = 30;
    			
        int correlationId;

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

		}
	


        public override byte GetDataStructureType() {
   
        return ID_Response;
        }


        // Properties

        public int CorrelationId
       {
            get { return correlationId; }
            set { this.correlationId =
value; }            
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs?rev=384827&r1=384826&r2=384827&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
Fri Mar 10 07:54:42 2006
@@ -45,7 +45,7 @@
         base.TightUnmarshal(wireFormat, o, dataIn, bs);
 
         BaseCommand info = (BaseCommand)o;
-        info.CommandId = dataIn.ReadInt16();
+        info.CommandId = dataIn.ReadInt32();
         info.ResponseRequired = bs.ReadBoolean();
 
     }
@@ -59,7 +59,7 @@
         int rc = base.TightMarshal1(wireFormat, info, bs);
         bs.WriteBoolean(info.ResponseRequired);
 
-        return rc + 2;
+        return rc + 4;
     }
 
     // 
@@ -82,7 +82,7 @@
         base.LooseUnmarshal(wireFormat, o, dataIn);
 
         BaseCommand info = (BaseCommand)o;
-        info.CommandId = dataIn.ReadInt16();
+        info.CommandId = dataIn.ReadInt32();
         info.ResponseRequired = dataIn.ReadBoolean();
 
     }

Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs?rev=384827&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs
(added)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/LastPartialCommandMarshaller.cs
Fri Mar 10 07:54:42 2006
@@ -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 LastPartialCommand
  /// </summary>
 class LastPartialCommandMarshaller : PartialCommandMarshaller
  {


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

    public override
byte GetDataStructureType() 
    {
        return LastPartialCommand.ID_LastPartialCommand;
   }

    // 
    // 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);

    }

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

        int rc = base.TightMarshal1(wireFormat,
info, bs);

        return rc + 0;
    }

    // 
    // Wri
 te 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);

    }

    // 
    // 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);

    }

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

        base.LooseMarshal(wireFormat,
o, dataOut);

    }
    
  }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MarshallerFactory.cs?rev=384827&r1=384826&r2=384827&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
Fri Mar 10 07:54:42 2006
@@ -40,6 +40,7 @@
         {
 
             format.addMarshaller(new LocalTransactionIdMarshaller());
+            format.addMarshaller(new PartialCommandMarshaller());
             format.addMarshaller(new IntegerResponseMarshaller());
             format.addMarshaller(new ActiveMQQueueMarshaller());
             format.addMarshaller(new ActiveMQObjectMessageMarshaller());
@@ -68,6 +69,7 @@
             format.addMarshaller(new SubscriptionInfoMarshaller());
             format.addMarshaller(new JournalTransactionMarshaller());
             format.addMarshaller(new ControlCommandMarshaller());
+            format.addMarshaller(new LastPartialCommandMarshaller());
             format.addMarshaller(new NetworkBridgeFilterMarshaller());
             format.addMarshaller(new ActiveMQBytesMessageMarshaller());
             format.addMarshaller(new WireFormatInfoMarshaller());

Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs?rev=384827&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs
(added)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/PartialCommandMarshaller.cs
Fri Mar 10 07:54:42 2006
@@ -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 PartialCommand
  /// </summary>
 class PartialCommandMarshaller : BaseCommandMarshaller
  {


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

    public override byte
GetDataStructureType() 
    {
        return PartialCommand.ID_PartialCommand;
    }

   
// 
    // 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);

        PartialCommand
info = (PartialCommand)o;
        info.Data = ReadBytes(dataIn, bs.ReadBoolean());

    }

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

        int rc = base.TightMarsh
 al1(wireFormat, info, bs);
        bs.WriteBoolean(info.Data!=null);
        rc += info.Data==null
? 0 : info.Data.Length+4;

        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);

        PartialCommand info = (PartialCommand)o;
        if(bs.ReadBoolean())
{
           dataOut.Write(info.Data.Length);
           dataOut.Write(info.Data);
      
 }

    }

    // 
    // 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);

        PartialCommand
info = (PartialCommand)o;
        info.Data = ReadBytes(dataIn, dataIn.ReadBoolean());

 
  }

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

        PartialCommand info = (PartialCommand)o;

        base.LooseMarshal(wireFormat,
o, dataOut);
        dataOut.Write(info.Data!=null);
        if(info.Data!=null) {
      
    dataOut.Write(info.Data.Length);
           dataOut.Write(info.Data);
        }

    }
   
  }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs?rev=384827&r1=384826&r2=384827&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ReplayCommandMarshaller.cs
Fri Mar 10 07:54:42 2006
@@ -1 +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 ReplayCommand
  /// </summary>
 class ReplayCommandMarshaller : BaseCommandMarshaller
  {


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

    public override byte
GetDataStructureType() 
    {
        return ReplayCommand.ID_ReplayCommand;
    }

    //

    // 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);

    }

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

       int rc = base.TightMarshal1(wireFormat, info, bs);

        return rc + 0;
    }

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

   
}

    // 
    // 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);

    }

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

        base.LooseMarshal(wireFormat, o, dataOut);

   }
    
  }
}
\ 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 ReplayCommand
  /// </summary>
 class ReplayCommandMarshaller : BaseCommandMarshaller
  {


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

    public override byte
GetDataStructureType() 
    {
        return ReplayCommand.ID_ReplayCommand;
    }

    //

    // 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);

        ReplayCommand
info = (ReplayCommand)o;
        info.FirstNakNumber = dataIn.ReadInt32();
        info.LastNakNumber
= dataIn.ReadInt32();

    }

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

        return rc + 8;
    }

   // 
    // 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);

        ReplayCommand info = (ReplayCommand)o;
       dataOut.Write(info.FirstNakNumber);
        dataOut.Write(info.LastNakNumber);

  
 }

    // 
    // 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);

        ReplayCommand info = (ReplayCommand)o;
       info.FirstNakNumber = dataIn.ReadInt32();
        info.LastNakNumber = dataIn.ReadInt32();

   }

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

        ReplayCommand info = (ReplayCommand)o;

       base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.FirstNakNumber);
       dataOut.Write(info.LastNakNumber);

    }
    
  }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs?rev=384827&r1=384826&r2=384827&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
(original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
Fri Mar 10 07:54:42 2006
@@ -56,7 +56,7 @@
         base.TightUnmarshal(wireFormat, o, dataIn, bs);
 
         Response info = (Response)o;
-        info.CorrelationId = dataIn.ReadInt16();
+        info.CorrelationId = dataIn.ReadInt32();
 
     }
 
@@ -68,7 +68,7 @@
 
         int rc = base.TightMarshal1(wireFormat, info, bs);
 
-        return rc + 2;
+        return rc + 4;
     }
 
     // 
@@ -90,7 +90,7 @@
         base.LooseUnmarshal(wireFormat, o, dataIn);
 
         Response info = (Response)o;
-        info.CorrelationId = dataIn.ReadInt16();
+        info.CorrelationId = dataIn.ReadInt32();
 
     }
 



Mime
View raw message