activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r454506 [7/11] - in /incubator/activemq/activemq-dotnet/trunk/src: main/csharp/ActiveMQ/ main/csharp/ActiveMQ/Commands/ main/csharp/ActiveMQ/OpenWire/ main/csharp/ActiveMQ/OpenWire/V2/ main/csharp/ActiveMQ/Transport/ main/csharp/ActiveMQ/Ut...
Date Mon, 09 Oct 2006 20:59:17 GMT
Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/SubscriptionInfoMarshaller.cs Mon Oct  9 13:59:14 2006
@@ -1 +1,125 @@
-/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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 S
 ystem.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;

namespace ActiveMQ.OpenWire.V2
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for SubscriptionInfo
  /// </summary>
  class SubscriptionInfoMarshaller : BaseDataStreamMarshaller
  {


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

    public override byte GetDataStructureType() 
    {
        return SubscriptionInfo.ID_SubscriptionInfo;
    }

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

        SubscriptionInfo info = (SubscriptionInfo)o;
        info.ClientId = TightUnmarshalString(dataIn, bs);
        info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireForma
 t, dataIn, bs);
        info.Selector = TightUnmarshalString(dataIn, bs);
        info.SubcriptionName = TightUnmarshalString(dataIn, bs);

    }

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

        int rc = base.TightMarshal1(wireFormat, info, bs);
        rc += TightMarshalString1(info.ClientId, bs);
        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
        rc += TightMarshalString1(info.Selector, bs);
        rc += TightMarshalString1(info.SubcriptionName, bs);

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

        Subscription
 Info info = (SubscriptionInfo)o;
        TightMarshalString2(info.ClientId, dataOut, bs);
        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
        TightMarshalString2(info.Selector, dataOut, bs);
        TightMarshalString2(info.SubcriptionName, 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);

        SubscriptionInfo info = (SubscriptionInfo)o;
        info.ClientId = LooseUnmarshalString(dataIn);
        info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
        info.Selector = LooseUnmarshalString(dataIn);
        info.SubcriptionName = LooseUnmarshalString(dataIn);

    }

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

        SubscriptionInfo info = (SubscriptionInfo)o;

        base.LooseMarshal(wireFormat, o, dataOut);
        LooseMarshalString(info.ClientId, dataOut);
        LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
        LooseMarshalString(info.Selector, dataOut);
        LooseMarshalString(info.SubcriptionName, dataOut);

    }
  }
}
\ No newline at end of file
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.V2;
+
+namespace ActiveMQ.OpenWire.V2
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for SubscriptionInfo
+  /// </summary>
+  class SubscriptionInfoMarshaller : BaseDataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new SubscriptionInfo();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return SubscriptionInfo.ID_SubscriptionInfo;
+    }
+
+    // 
+    // 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);
+
+        SubscriptionInfo info = (SubscriptionInfo)o;
+        info.ClientId = TightUnmarshalString(dataIn, bs);
+        info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.Selector = TightUnmarshalString(dataIn, bs);
+        info.SubcriptionName = TightUnmarshalString(dataIn, bs);
+
+    }
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        SubscriptionInfo info = (SubscriptionInfo)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        rc += TightMarshalString1(info.ClientId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs);
+        rc += TightMarshalString1(info.Selector, bs);
+        rc += TightMarshalString1(info.SubcriptionName, bs);
+
+        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);
+
+        SubscriptionInfo info = (SubscriptionInfo)o;
+        TightMarshalString2(info.ClientId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs);
+        TightMarshalString2(info.Selector, dataOut, bs);
+        TightMarshalString2(info.SubcriptionName, 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);
+
+        SubscriptionInfo info = (SubscriptionInfo)o;
+        info.ClientId = LooseUnmarshalString(dataIn);
+        info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn);
+        info.Selector = LooseUnmarshalString(dataIn);
+        info.SubcriptionName = LooseUnmarshalString(dataIn);
+
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+        SubscriptionInfo info = (SubscriptionInfo)o;
+
+        base.LooseMarshal(wireFormat, o, dataOut);
+        LooseMarshalString(info.ClientId, dataOut);
+        LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+        LooseMarshalString(info.Selector, dataOut);
+        LooseMarshalString(info.SubcriptionName, dataOut);
+
+    }
+  }
+}

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionIdMarshaller.cs Mon Oct  9 13:59:14 2006
@@ -1 +1,86 @@
-/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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 S
 ystem.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;

namespace ActiveMQ.OpenWire.V2
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for TransactionId
  /// </summary>
  abstract class TransactionIdMarshaller : BaseDataStreamMarshaller
  {

    // 
    // 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) {
        TransactionId info = (TransactionId)o;

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

        return rc + 0;
    }

    // 
    // Write a object instance to data output stream
    //
    public override vo
 id 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
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.V2;
+
+namespace ActiveMQ.OpenWire.V2
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for TransactionId
+  /// </summary>
+  abstract class TransactionIdMarshaller : BaseDataStreamMarshaller
+  {
+
+    // 
+    // 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) {
+        TransactionId info = (TransactionId)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+
+        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);
+
+    }
+
+    // 
+    // 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);
+
+    }
+  }
+}

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/TransactionInfoMarshaller.cs Mon Oct  9 13:59:14 2006
@@ -1 +1,119 @@
-/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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 S
 ystem.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;

namespace ActiveMQ.OpenWire.V2
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for TransactionInfo
  /// </summary>
  class TransactionInfoMarshaller : BaseCommandMarshaller
  {


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

    public override byte GetDataStructureType() 
    {
        return TransactionInfo.ID_TransactionInfo;
    }

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

        TransactionInfo info = (TransactionInfo)o;
        info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
        info.TransactionId = (TransactionId) TightUnmarsha
 lCachedObject(wireFormat, dataIn, bs);
        info.Type = dataIn.ReadByte();

    }

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

        int rc = base.TightMarshal1(wireFormat, info, bs);
        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);

        return rc + 1;
    }

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

        TransactionInfo info = (TransactionInfo)o;
        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
        TightM
 arshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
        dataOut.Write(info.Type);

    }

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

        TransactionInfo info = (TransactionInfo)o;
        info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
        info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
        info.Type = dataIn.ReadByte();

    }

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

        TransactionInfo info = (TransactionInfo)o;

        base.LooseMarshal(wireFormat, o, dataOut);
        LooseMarshalCachedObject(wireFormat, (DataStructure)info.Connection
 Id, dataOut);
        LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
        dataOut.Write(info.Type);

    }
  }
}
\ No newline at end of file
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.V2;
+
+namespace ActiveMQ.OpenWire.V2
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for TransactionInfo
+  /// </summary>
+  class TransactionInfoMarshaller : BaseCommandMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new TransactionInfo();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return TransactionInfo.ID_TransactionInfo;
+    }
+
+    // 
+    // 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);
+
+        TransactionInfo info = (TransactionInfo)o;
+        info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs);
+        info.Type = dataIn.ReadByte();
+
+    }
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        TransactionInfo info = (TransactionInfo)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs);
+        rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs);
+
+        return rc + 1;
+    }
+
+    // 
+    // 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);
+
+        TransactionInfo info = (TransactionInfo)o;
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs);
+        TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs);
+        dataOut.Write(info.Type);
+
+    }
+
+    // 
+    // 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);
+
+        TransactionInfo info = (TransactionInfo)o;
+        info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+        info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+        info.Type = dataIn.ReadByte();
+
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+        TransactionInfo info = (TransactionInfo)o;
+
+        base.LooseMarshal(wireFormat, o, dataOut);
+        LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+        LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+        dataOut.Write(info.Type);
+
+    }
+  }
+}

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/WireFormatInfoMarshaller.cs Mon Oct  9 13:59:14 2006
@@ -1 +1,144 @@
-/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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 S
 ystem.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;

namespace ActiveMQ.OpenWire.V2
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for WireFormatInfo
  /// </summary>
  class WireFormatInfoMarshaller : BaseDataStreamMarshaller
  {


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

    public override byte GetDataStructureType() 
    {
        return WireFormatInfo.ID_WireFormatInfo;
    }

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

        WireFormatInfo info = (WireFormatInfo)o;

        info.BeforeUnmarshall(wireFormat);

        info.Magic = ReadBytes(dataIn, 8);
        info.Version = dataIn.ReadInt32();
        info.MarshalledPro
 perties = ReadBytes(dataIn, bs.ReadBoolean());

        info.AfterUnmarshall(wireFormat);

    }

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

        info.BeforeMarshall(wireFormat);

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

        return rc + 12;
    }

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

        WireFormatInfo info = (WireFormatInfo)o;
        dataOut.Write(info.Magic, 0, 8);
        dataOut.Write(info.Version);
        if(bs.Re
 adBoolean()) {
           dataOut.Write(info.MarshalledProperties.Length);
           dataOut.Write(info.MarshalledProperties);
        }

        info.AfterMarshall(wireFormat);

    }

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

        WireFormatInfo info = (WireFormatInfo)o;

        info.BeforeUnmarshall(wireFormat);

        info.Magic = ReadBytes(dataIn, 8);
        info.Version = dataIn.ReadInt32();
        info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());

        info.AfterUnmarshall(wireFormat);

    }

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

        WireFormatInfo info = (WireFormatInfo)o;

        info.BeforeMarshall(wireFormat
 );

        base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.Magic, 0, 8);
        dataOut.Write(info.Version);
        dataOut.Write(info.MarshalledProperties!=null);
        if(info.MarshalledProperties!=null) {
           dataOut.Write(info.MarshalledProperties.Length);
           dataOut.Write(info.MarshalledProperties);
        }

        info.AfterMarshall(wireFormat);

    }
  }
}
\ No newline at end of file
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.V2;
+
+namespace ActiveMQ.OpenWire.V2
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for WireFormatInfo
+  /// </summary>
+  class WireFormatInfoMarshaller : BaseDataStreamMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new WireFormatInfo();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return WireFormatInfo.ID_WireFormatInfo;
+    }
+
+    // 
+    // 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);
+
+        WireFormatInfo info = (WireFormatInfo)o;
+
+        info.BeforeUnmarshall(wireFormat);
+
+        info.Magic = ReadBytes(dataIn, 8);
+        info.Version = dataIn.ReadInt32();
+        info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean());
+
+        info.AfterUnmarshall(wireFormat);
+
+    }
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        WireFormatInfo info = (WireFormatInfo)o;
+
+        info.BeforeMarshall(wireFormat);
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        bs.WriteBoolean(info.MarshalledProperties!=null);
+        rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4;
+
+        return rc + 12;
+    }
+
+    // 
+    // 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);
+
+        WireFormatInfo info = (WireFormatInfo)o;
+        dataOut.Write(info.Magic, 0, 8);
+        dataOut.Write(info.Version);
+        if(bs.ReadBoolean()) {
+           dataOut.Write(info.MarshalledProperties.Length);
+           dataOut.Write(info.MarshalledProperties);
+        }
+
+        info.AfterMarshall(wireFormat);
+
+    }
+
+    // 
+    // 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);
+
+        WireFormatInfo info = (WireFormatInfo)o;
+
+        info.BeforeUnmarshall(wireFormat);
+
+        info.Magic = ReadBytes(dataIn, 8);
+        info.Version = dataIn.ReadInt32();
+        info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());
+
+        info.AfterUnmarshall(wireFormat);
+
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+        WireFormatInfo info = (WireFormatInfo)o;
+
+        info.BeforeMarshall(wireFormat);
+
+        base.LooseMarshal(wireFormat, o, dataOut);
+        dataOut.Write(info.Magic, 0, 8);
+        dataOut.Write(info.Version);
+        dataOut.Write(info.MarshalledProperties!=null);
+        if(info.MarshalledProperties!=null) {
+           dataOut.Write(info.MarshalledProperties.Length);
+           dataOut.Write(info.MarshalledProperties);
+        }
+
+        info.AfterMarshall(wireFormat);
+
+    }
+  }
+}

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/OpenWire/V2/XATransactionIdMarshaller.cs Mon Oct  9 13:59:14 2006
@@ -1 +1,135 @@
-/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You 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 S
 ystem.Collections;
using System.IO;

using ActiveMQ.Commands;
using ActiveMQ.OpenWire;
using ActiveMQ.OpenWire.V2;

namespace ActiveMQ.OpenWire.V2
{
  /// <summary>
  ///  Marshalling code for Open Wire Format for XATransactionId
  /// </summary>
  class XATransactionIdMarshaller : TransactionIdMarshaller
  {


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

    public override byte GetDataStructureType() 
    {
        return XATransactionId.ID_XATransactionId;
    }

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

        XATransactionId info = (XATransactionId)o;
        info.FormatId = dataIn.ReadInt32();
        info.GlobalTransactionId = ReadBytes(dataIn, bs.ReadBoolean());
        info.BranchQualifier = Read
 Bytes(dataIn, bs.ReadBoolean());

    }

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

        int rc = base.TightMarshal1(wireFormat, info, bs);
        bs.WriteBoolean(info.GlobalTransactionId!=null);
        rc += info.GlobalTransactionId==null ? 0 : info.GlobalTransactionId.Length+4;
        bs.WriteBoolean(info.BranchQualifier!=null);
        rc += info.BranchQualifier==null ? 0 : info.BranchQualifier.Length+4;

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

        XATransactionId info = (XATransactionId)o;
        dataOut.Write(info.FormatId);
        if(bs.ReadBoolea
 n()) {
           dataOut.Write(info.GlobalTransactionId.Length);
           dataOut.Write(info.GlobalTransactionId);
        }
        if(bs.ReadBoolean()) {
           dataOut.Write(info.BranchQualifier.Length);
           dataOut.Write(info.BranchQualifier);
        }

    }

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

        XATransactionId info = (XATransactionId)o;
        info.FormatId = dataIn.ReadInt32();
        info.GlobalTransactionId = ReadBytes(dataIn, dataIn.ReadBoolean());
        info.BranchQualifier = ReadBytes(dataIn, dataIn.ReadBoolean());

    }

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

        XATransactionId info = (XATransactionId)o;
         base.LooseMarshal(wireFormat, o, dataOut);
        dataOut.Write(info.FormatId);
        dataOut.Write(info.GlobalTransactionId!=null);
        if(info.GlobalTransactionId!=null) {
           dataOut.Write(info.GlobalTransactionId.Length);
           dataOut.Write(info.GlobalTransactionId);
        }
        dataOut.Write(info.BranchQualifier!=null);
        if(info.BranchQualifier!=null) {
           dataOut.Write(info.BranchQualifier.Length);
           dataOut.Write(info.BranchQualifier);
        }

    }
  }
}
\ No newline at end of file
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.V2;
+
+namespace ActiveMQ.OpenWire.V2
+{
+  /// <summary>
+  ///  Marshalling code for Open Wire Format for XATransactionId
+  /// </summary>
+  class XATransactionIdMarshaller : TransactionIdMarshaller
+  {
+
+
+    public override DataStructure CreateObject() 
+    {
+        return new XATransactionId();
+    }
+
+    public override byte GetDataStructureType() 
+    {
+        return XATransactionId.ID_XATransactionId;
+    }
+
+    // 
+    // 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);
+
+        XATransactionId info = (XATransactionId)o;
+        info.FormatId = dataIn.ReadInt32();
+        info.GlobalTransactionId = ReadBytes(dataIn, bs.ReadBoolean());
+        info.BranchQualifier = ReadBytes(dataIn, bs.ReadBoolean());
+
+    }
+
+    //
+    // Write the booleans that this object uses to a BooleanStream
+    //
+    public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) {
+        XATransactionId info = (XATransactionId)o;
+
+        int rc = base.TightMarshal1(wireFormat, info, bs);
+        bs.WriteBoolean(info.GlobalTransactionId!=null);
+        rc += info.GlobalTransactionId==null ? 0 : info.GlobalTransactionId.Length+4;
+        bs.WriteBoolean(info.BranchQualifier!=null);
+        rc += info.BranchQualifier==null ? 0 : info.BranchQualifier.Length+4;
+
+        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);
+
+        XATransactionId info = (XATransactionId)o;
+        dataOut.Write(info.FormatId);
+        if(bs.ReadBoolean()) {
+           dataOut.Write(info.GlobalTransactionId.Length);
+           dataOut.Write(info.GlobalTransactionId);
+        }
+        if(bs.ReadBoolean()) {
+           dataOut.Write(info.BranchQualifier.Length);
+           dataOut.Write(info.BranchQualifier);
+        }
+
+    }
+
+    // 
+    // 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);
+
+        XATransactionId info = (XATransactionId)o;
+        info.FormatId = dataIn.ReadInt32();
+        info.GlobalTransactionId = ReadBytes(dataIn, dataIn.ReadBoolean());
+        info.BranchQualifier = ReadBytes(dataIn, dataIn.ReadBoolean());
+
+    }
+
+    // 
+    // Write a object instance to data output stream
+    //
+    public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
+
+        XATransactionId info = (XATransactionId)o;
+
+        base.LooseMarshal(wireFormat, o, dataOut);
+        dataOut.Write(info.FormatId);
+        dataOut.Write(info.GlobalTransactionId!=null);
+        if(info.GlobalTransactionId!=null) {
+           dataOut.Write(info.GlobalTransactionId.Length);
+           dataOut.Write(info.GlobalTransactionId);
+        }
+        dataOut.Write(info.BranchQualifier!=null);
+        if(info.BranchQualifier!=null) {
+           dataOut.Write(info.BranchQualifier.Length);
+           dataOut.Write(info.BranchQualifier);
+        }
+
+    }
+  }
+}

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/WireFormatNegotiator.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/WireFormatNegotiator.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/WireFormatNegotiator.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Transport/WireFormatNegotiator.cs Mon Oct  9 13:59:14 2006
@@ -1,106 +1,106 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-using System.IO;
-using System.Threading;
-using ActiveMQ.Commands;
-using ActiveMQ.OpenWire;
-using ActiveMQ.Transport;
-using System;
-using ActiveMQ.Util;
-
-namespace ActiveMQ.Transport
-{
-	
-    /// <summary>
-    /// A Transport which negotiates the wire format
-    /// </summary>
-    public class WireFormatNegotiator : TransportFilter
-    {
-        private OpenWireFormat wireFormat;
-        private TimeSpan negotiateTimeout=new TimeSpan(0,0,15);
-    
-        private AtomicBoolean firstStart=new AtomicBoolean(true);
-        private CountDownLatch readyCountDownLatch = new CountDownLatch(1);
-        private CountDownLatch wireInfoSentDownLatch = new CountDownLatch(1);
-
-        public WireFormatNegotiator(ITransport next, OpenWireFormat wireFormat)
-            : base(next)
-        {
-            this.wireFormat = wireFormat;
-        }
-        
-        public override void Start() {
-            base.Start();
-            if (firstStart.compareAndSet(true, false))
-            {
-                try
-                {
-                    next.Oneway(wireFormat.PreferedWireFormatInfo);
-                }
-                finally
-                {
-                    wireInfoSentDownLatch.countDown();
-                }
-            }
-        }
-        
-        public override void Dispose() {
-        	base.Dispose();
-            readyCountDownLatch.countDown();
-        }
-
-        public override void Oneway(Command command)
-        {
-            if (!readyCountDownLatch.await(negotiateTimeout))
-                throw new IOException("Wire format negociation timeout: peer did not send his wire format.");
-            next.Oneway(command);
-        }
-
-        protected override void OnCommand(ITransport sender, Command command)
-        {
-            if ( command.GetDataStructureType() == WireFormatInfo.ID_WireFormatInfo )
-            {
-                WireFormatInfo info = (WireFormatInfo)command;
-                try
-                {
-                    if (!info.Valid)
-                    {
-                        throw new IOException("Remote wire format magic is invalid");
-                    }
-                    wireInfoSentDownLatch.await(negotiateTimeout);
-                    wireFormat.renegotiateWireFormat(info);
-                }
-                catch (Exception e)
-                {
-                    OnException(this, e);
-                } 
-                finally
-                {
-                    readyCountDownLatch.countDown();
-                }
-            }
-            this.commandHandler(sender, command);
-        }
-
-        protected override void OnException(ITransport sender, Exception command)
-        {
-            readyCountDownLatch.countDown();
-            this.exceptionHandler(sender, command);
-        }
-    }
-}
-
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+using System.IO;
+using System.Threading;
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.Transport;
+using System;
+using ActiveMQ.Util;
+
+namespace ActiveMQ.Transport
+{
+	
+    /// <summary>
+    /// A Transport which negotiates the wire format
+    /// </summary>
+    public class WireFormatNegotiator : TransportFilter
+    {
+        private OpenWireFormat wireFormat;
+        private TimeSpan negotiateTimeout=new TimeSpan(0,0,15);
+    
+        private AtomicBoolean firstStart=new AtomicBoolean(true);
+        private CountDownLatch readyCountDownLatch = new CountDownLatch(1);
+        private CountDownLatch wireInfoSentDownLatch = new CountDownLatch(1);
+
+        public WireFormatNegotiator(ITransport next, OpenWireFormat wireFormat)
+            : base(next)
+        {
+            this.wireFormat = wireFormat;
+        }
+        
+        public override void Start() {
+            base.Start();
+            if (firstStart.compareAndSet(true, false))
+            {
+                try
+                {
+                    next.Oneway(wireFormat.PreferedWireFormatInfo);
+                }
+                finally
+                {
+                    wireInfoSentDownLatch.countDown();
+                }
+            }
+        }
+        
+        public override void Dispose() {
+        	base.Dispose();
+            readyCountDownLatch.countDown();
+        }
+
+        public override void Oneway(Command command)
+        {
+            if (!readyCountDownLatch.await(negotiateTimeout))
+                throw new IOException("Wire format negociation timeout: peer did not send his wire format.");
+            next.Oneway(command);
+        }
+
+        protected override void OnCommand(ITransport sender, Command command)
+        {
+            if ( command.GetDataStructureType() == WireFormatInfo.ID_WireFormatInfo )
+            {
+                WireFormatInfo info = (WireFormatInfo)command;
+                try
+                {
+                    if (!info.Valid)
+                    {
+                        throw new IOException("Remote wire format magic is invalid");
+                    }
+                    wireInfoSentDownLatch.await(negotiateTimeout);
+                    wireFormat.renegotiateWireFormat(info);
+                }
+                catch (Exception e)
+                {
+                    OnException(this, e);
+                } 
+                finally
+                {
+                    readyCountDownLatch.countDown();
+                }
+            }
+            this.commandHandler(sender, command);
+        }
+
+        protected override void OnException(ITransport sender, Exception command)
+        {
+            readyCountDownLatch.countDown();
+            this.exceptionHandler(sender, command);
+        }
+    }
+}
+

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/AtomicBoolean.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/AtomicBoolean.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/AtomicBoolean.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/AtomicBoolean.cs Mon Oct  9 13:59:14 2006
@@ -1,45 +1,45 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-using System;
-using System.Collections.Generic;
-using System.Text;
-
-namespace ActiveMQ.Util
-{
-    class AtomicBoolean
-    {
-        bool value;
-
-        public AtomicBoolean(bool b)
-        {
-            value = b;
-        }
-
-        public bool compareAndSet(bool expected, bool newValue)
-        {
-            lock(this)
-            {
-                if (value == expected)
-                {
-                    value = newValue;
-                    return true;
-                }
-                return false;                
-            }
-        }
-    }
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace ActiveMQ.Util
+{
+    class AtomicBoolean
+    {
+        bool value;
+
+        public AtomicBoolean(bool b)
+        {
+            value = b;
+        }
+
+        public bool compareAndSet(bool expected, bool newValue)
+        {
+            lock(this)
+            {
+                if (value == expected)
+                {
+                    value = newValue;
+                    return true;
+                }
+                return false;                
+            }
+        }
+    }
+}

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/CountDownLatch.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/CountDownLatch.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/CountDownLatch.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/CountDownLatch.cs Mon Oct  9 13:59:14 2006
@@ -1,59 +1,59 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-using System;
-using System.Collections.Generic;
-using System.Text;
-using System.Threading;
-
-namespace ActiveMQ.Util
-{
-    class CountDownLatch
-    {
-        int remaining;
-        public CountDownLatch(int i)
-        {
-            remaining=i;
-        }
-
-        public void countDown()
-        {
-            lock(this)
-            {
-                if( remaining > 0 ) {
-                    remaining--;
-                    Monitor.PulseAll(this);
-                }
-            }
-        }
-
-        public bool await(TimeSpan timeout)
-        {
-            lock (this)
-            {
-                if (remaining > 0)
-                {
-                    Monitor.Wait(this, timeout);
-                    if (remaining > 0)
-                    {
-                        return false;
-                    }
-                }
-            }
-            return true;
-        }
-    }
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading;
+
+namespace ActiveMQ.Util
+{
+    class CountDownLatch
+    {
+        int remaining;
+        public CountDownLatch(int i)
+        {
+            remaining=i;
+        }
+
+        public void countDown()
+        {
+            lock(this)
+            {
+                if( remaining > 0 ) {
+                    remaining--;
+                    Monitor.PulseAll(this);
+                }
+            }
+        }
+
+        public bool await(TimeSpan timeout)
+        {
+            lock (this)
+            {
+                if (remaining > 0)
+                {
+                    Monitor.Wait(this, timeout);
+                    if (remaining > 0)
+                    {
+                        return false;
+                    }
+                }
+            }
+            return true;
+        }
+    }
+}

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

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

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BaseMessage.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BaseMessage.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BaseMessage.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BaseMessage.cs Mon Oct  9 13:59:14 2006
@@ -1,205 +1,205 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-using NMS;
-using System;
-
-namespace MSMQ
-{
-	public delegate void AcknowledgeHandler(BaseMessage baseMessage);
-
-    public class BaseMessage : IMessage
-    {
-        private PrimitiveMap properties;
-        private Destination destination;
-        private string correlationId;
-        private TimeSpan expiration;
-        private string messageId;
-        private bool persistent;
-        private byte priority;
-        private Destination replyTo;
-        private string type;
-        private event AcknowledgeHandler Acknowledger;
-        private byte[] content;
-        private DateTime timestamp;
-
-        public byte[] Content
-        {
-            get { return content; }
-            set { content = value; }
-        }
-
-        public void Acknowledge()
-        {
-            if (Acknowledger == null)
-			{
-                throw new NMSException("No Acknowledger has been associated with this message: " + this);
-			}
-            else
-			{
-                Acknowledger(this);
-            }
-        }
-        
-        
-        // Properties
-        
-        public IPrimitiveMap Properties
-        {
-            get {
-                return properties;
-            }
-        }
-        
-        
-        // IMessage interface
-        
-        // NMS headers
-        
-        /// <summary>
-        /// The correlation ID used to correlate messages with conversations or long running business processes
-        /// </summary>
-        public string NMSCorrelationID
-        {
-            get {
-                return correlationId;
-            }
-            set {
-                correlationId = value;
-            }
-        }
-        
-        /// <summary>
-        /// The destination of the message
-        /// </summary>
-        public IDestination NMSDestination
-        {
-            get {
-                return destination;
-            }
-        }
-        
-        /// <summary>
-        /// The time in milliseconds that this message should expire in
-        /// </summary>
-        public TimeSpan NMSExpiration
-        {
-            get {
-                return expiration;
-            }
-            set {
-                expiration = value;
-            }
-        }
-        
-        /// <summary>
-        /// The message ID which is set by the provider
-        /// </summary>
-        public string NMSMessageId
-        {
-            get {
-                return messageId;
-            }
-        }
-        
-        /// <summary>
-        /// Whether or not this message is persistent
-        /// </summary>
-        public bool NMSPersistent
-        {
-            get {
-                return persistent;
-            }
-            set {
-                persistent = value;
-            }
-        }
-        
-        /// <summary>
-        /// The Priority on this message
-        /// </summary>
-        public byte NMSPriority
-        {
-            get {
-                return priority;
-            }
-            set {
-                priority = value;
-            }
-        }
-        
-        /// <summary>
-        /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
-        /// </summary>
-        public bool NMSRedelivered
-        {
-            get {
-                return false;
-            }
-        }
-        
-        
-        /// <summary>
-        /// The destination that the consumer of this message should send replies to
-        /// </summary>
-        public IDestination NMSReplyTo
-        {
-            get {
-                return replyTo;
-            }
-            set {
-                replyTo = (Destination) value;
-            }
-        }
-        
-        
-        /// <summary>
-        /// The timestamp the broker added to the message
-        /// </summary>
-        public DateTime NMSTimestamp
-        {
-            get {
-                return timestamp;
-            }
-        }
-        
-        /// <summary>
-        /// The type name of this message
-        /// </summary>
-        public string NMSType
-        {
-            get {
-                return type;
-            }
-            set {
-                type = value;
-            }
-        }
-        
-
-        public object GetObjectProperty(string name)
-        {
-            return null;
-        }
-        
-        public void SetObjectProperty(string name, object value)
-        {
-        }
-                
-        
-    }
-}
-
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+using NMS;
+using System;
+
+namespace MSMQ
+{
+	public delegate void AcknowledgeHandler(BaseMessage baseMessage);
+
+    public class BaseMessage : IMessage
+    {
+        private PrimitiveMap properties;
+        private Destination destination;
+        private string correlationId;
+        private TimeSpan expiration;
+        private string messageId;
+        private bool persistent;
+        private byte priority;
+        private Destination replyTo;
+        private string type;
+        private event AcknowledgeHandler Acknowledger;
+        private byte[] content;
+        private DateTime timestamp;
+
+        public byte[] Content
+        {
+            get { return content; }
+            set { content = value; }
+        }
+
+        public void Acknowledge()
+        {
+            if (Acknowledger == null)
+			{
+                throw new NMSException("No Acknowledger has been associated with this message: " + this);
+			}
+            else
+			{
+                Acknowledger(this);
+            }
+        }
+        
+        
+        // Properties
+        
+        public IPrimitiveMap Properties
+        {
+            get {
+                return properties;
+            }
+        }
+        
+        
+        // IMessage interface
+        
+        // NMS headers
+        
+        /// <summary>
+        /// The correlation ID used to correlate messages with conversations or long running business processes
+        /// </summary>
+        public string NMSCorrelationID
+        {
+            get {
+                return correlationId;
+            }
+            set {
+                correlationId = value;
+            }
+        }
+        
+        /// <summary>
+        /// The destination of the message
+        /// </summary>
+        public IDestination NMSDestination
+        {
+            get {
+                return destination;
+            }
+        }
+        
+        /// <summary>
+        /// The time in milliseconds that this message should expire in
+        /// </summary>
+        public TimeSpan NMSExpiration
+        {
+            get {
+                return expiration;
+            }
+            set {
+                expiration = value;
+            }
+        }
+        
+        /// <summary>
+        /// The message ID which is set by the provider
+        /// </summary>
+        public string NMSMessageId
+        {
+            get {
+                return messageId;
+            }
+        }
+        
+        /// <summary>
+        /// Whether or not this message is persistent
+        /// </summary>
+        public bool NMSPersistent
+        {
+            get {
+                return persistent;
+            }
+            set {
+                persistent = value;
+            }
+        }
+        
+        /// <summary>
+        /// The Priority on this message
+        /// </summary>
+        public byte NMSPriority
+        {
+            get {
+                return priority;
+            }
+            set {
+                priority = value;
+            }
+        }
+        
+        /// <summary>
+        /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
+        /// </summary>
+        public bool NMSRedelivered
+        {
+            get {
+                return false;
+            }
+        }
+        
+        
+        /// <summary>
+        /// The destination that the consumer of this message should send replies to
+        /// </summary>
+        public IDestination NMSReplyTo
+        {
+            get {
+                return replyTo;
+            }
+            set {
+                replyTo = (Destination) value;
+            }
+        }
+        
+        
+        /// <summary>
+        /// The timestamp the broker added to the message
+        /// </summary>
+        public DateTime NMSTimestamp
+        {
+            get {
+                return timestamp;
+            }
+        }
+        
+        /// <summary>
+        /// The type name of this message
+        /// </summary>
+        public string NMSType
+        {
+            get {
+                return type;
+            }
+            set {
+                type = value;
+            }
+        }
+        
+
+        public object GetObjectProperty(string name)
+        {
+            return null;
+        }
+        
+        public void SetObjectProperty(string name, object value)
+        {
+        }
+                
+        
+    }
+}
+

Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BaseMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BytesMessage.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BytesMessage.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BytesMessage.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BytesMessage.cs Mon Oct  9 13:59:14 2006
@@ -1,27 +1,27 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-using System;
-using NMS;
-
-
-namespace MSMQ
-{
-	public class BytesMessage : BaseMessage, IBytesMessage
-    {
-    }
-}
-
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+using System;
+using NMS;
+
+
+namespace MSMQ
+{
+	public class BytesMessage : BaseMessage, IBytesMessage
+    {
+    }
+}
+

Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/BytesMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/CommonAssemblyInfo.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/CommonAssemblyInfo.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/CommonAssemblyInfo.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/CommonAssemblyInfo.cs Mon Oct  9 13:59:14 2006
@@ -1,27 +1,27 @@
-using System;
-using System.Reflection;
-using System.Runtime.InteropServices;
-
-//------------------------------------------------------------------------------
-// <auto-generated>
-//     This code was generated by a tool.
-//     Runtime Version:2.0.50727.42
-//
-//     Changes to this file may cause incorrect behavior and will be lost if
-//     the code is regenerated.
-// </auto-generated>
-//------------------------------------------------------------------------------
-
-[assembly: ComVisibleAttribute(false)]
-[assembly: CLSCompliantAttribute(true)]
-[assembly: AssemblyTitleAttribute("Apache NMS for MSMQ")]
-[assembly: AssemblyDescriptionAttribute("An NMS (.Net Messaging Library) to MSMQ")]
-[assembly: AssemblyConfigurationAttribute("SNAPSHOT")]
-[assembly: AssemblyCompanyAttribute("http://incubator.apache.org/activemq/")]
-[assembly: AssemblyProductAttribute("Apache ActiveMQ")]
-[assembly: AssemblyCopyrightAttribute("Copyright (C) 2005-2006 Apache Software Foundation")]
-[assembly: AssemblyTrademarkAttribute("")]
-[assembly: AssemblyCultureAttribute("")]
-[assembly: AssemblyVersionAttribute("4.0")]
-[assembly: AssemblyInformationalVersionAttribute("4.0")]
-
+using System;
+using System.Reflection;
+using System.Runtime.InteropServices;
+
+//------------------------------------------------------------------------------
+// <auto-generated>
+//     This code was generated by a tool.
+//     Runtime Version:2.0.50727.42
+//
+//     Changes to this file may cause incorrect behavior and will be lost if
+//     the code is regenerated.
+// </auto-generated>
+//------------------------------------------------------------------------------
+
+[assembly: ComVisibleAttribute(false)]
+[assembly: CLSCompliantAttribute(true)]
+[assembly: AssemblyTitleAttribute("Apache NMS for MSMQ")]
+[assembly: AssemblyDescriptionAttribute("An NMS (.Net Messaging Library) to MSMQ")]
+[assembly: AssemblyConfigurationAttribute("SNAPSHOT")]
+[assembly: AssemblyCompanyAttribute("http://incubator.apache.org/activemq/")]
+[assembly: AssemblyProductAttribute("Apache ActiveMQ")]
+[assembly: AssemblyCopyrightAttribute("Copyright (C) 2005-2006 Apache Software Foundation")]
+[assembly: AssemblyTrademarkAttribute("")]
+[assembly: AssemblyCultureAttribute("")]
+[assembly: AssemblyVersionAttribute("4.0")]
+[assembly: AssemblyInformationalVersionAttribute("4.0")]
+

Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/CommonAssemblyInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs?view=diff&rev=454506&r1=454505&r2=454506
==============================================================================
--- incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs (original)
+++ incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs Mon Oct  9 13:59:14 2006
@@ -1,113 +1,113 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You 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.
- */
-using NMS;
-
-namespace MSMQ
-{
-    /// <summary>
-    /// Represents a NMS connection MSMQ.  Since the underlying MSMQ APIs are actually 
-    /// connectionless, NMS connection in the MSMQ case are not expensive operations.
-    /// </summary>
-    /// 
-    public class Connection : IConnection
-    {
-        
-        private AcknowledgementMode acknowledgementMode = AcknowledgementMode.AutoAcknowledge;
-        private IMessageConverter messageConverter = new DefaultMessageConverter();
-
-        private bool connected;
-        private bool closed;
-        private string clientId;
-
-        /// <summary>
-        /// Starts message delivery for this connection.
-        /// </summary>
-        public void Start()
-        {
-            CheckConnected();
-        }
-                
-        /// <summary>
-        /// Stop message delivery for this connection.
-        /// </summary>
-        public void Stop()
-        {
-            CheckConnected();
-        }
-        
-        /// <summary>
-        /// Creates a new session to work on this connection
-        /// </summary>
-        public ISession CreateSession()
-        {
-            return CreateSession(acknowledgementMode);
-        }
-        
-        /// <summary>
-        /// Creates a new session to work on this connection
-        /// </summary>
-        public ISession CreateSession(AcknowledgementMode mode)
-        {
-            CheckConnected();
-            return new Session(this, mode);
-        }
-        
-        public void Dispose()
-        {
-            closed = true;
-        }
-        
-        public AcknowledgementMode AcknowledgementMode
-        {
-            get { return acknowledgementMode; }
-            set { acknowledgementMode = value; }
-        }
-
-        public IMessageConverter MessageConverter
-        {
-            get { return messageConverter; }
-            set { messageConverter = value; }
-        }
-
-        public string ClientId
-        {
-            get { return clientId; }
-            set {
-                if (connected)
-                {
-                    throw new NMSException("You cannot change the ClientId once the Connection is connected");
-                }
-                clientId = value;
-            }
-        }
-                
-        protected void CheckConnected()
-        {
-            if (closed)
-            {
-                throw new NMSException("Connection Closed");
-            }
-            if (!connected)
-            {
-                connected = true;
-                // now lets send the connection and see if we get an ack/nak
-                // TODO: establish a connection
-            }
-        }
-        	        
-    }
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.
+ */
+using NMS;
+
+namespace MSMQ
+{
+    /// <summary>
+    /// Represents a NMS connection MSMQ.  Since the underlying MSMQ APIs are actually 
+    /// connectionless, NMS connection in the MSMQ case are not expensive operations.
+    /// </summary>
+    /// 
+    public class Connection : IConnection
+    {
+        
+        private AcknowledgementMode acknowledgementMode = AcknowledgementMode.AutoAcknowledge;
+        private IMessageConverter messageConverter = new DefaultMessageConverter();
+
+        private bool connected;
+        private bool closed;
+        private string clientId;
+
+        /// <summary>
+        /// Starts message delivery for this connection.
+        /// </summary>
+        public void Start()
+        {
+            CheckConnected();
+        }
+                
+        /// <summary>
+        /// Stop message delivery for this connection.
+        /// </summary>
+        public void Stop()
+        {
+            CheckConnected();
+        }
+        
+        /// <summary>
+        /// Creates a new session to work on this connection
+        /// </summary>
+        public ISession CreateSession()
+        {
+            return CreateSession(acknowledgementMode);
+        }
+        
+        /// <summary>
+        /// Creates a new session to work on this connection
+        /// </summary>
+        public ISession CreateSession(AcknowledgementMode mode)
+        {
+            CheckConnected();
+            return new Session(this, mode);
+        }
+        
+        public void Dispose()
+        {
+            closed = true;
+        }
+        
+        public AcknowledgementMode AcknowledgementMode
+        {
+            get { return acknowledgementMode; }
+            set { acknowledgementMode = value; }
+        }
+
+        public IMessageConverter MessageConverter
+        {
+            get { return messageConverter; }
+            set { messageConverter = value; }
+        }
+
+        public string ClientId
+        {
+            get { return clientId; }
+            set {
+                if (connected)
+                {
+                    throw new NMSException("You cannot change the ClientId once the Connection is connected");
+                }
+                clientId = value;
+            }
+        }
+                
+        protected void CheckConnected()
+        {
+            if (closed)
+            {
+                throw new NMSException("Connection Closed");
+            }
+            if (!connected)
+            {
+                connected = true;
+                // now lets send the connection and see if we get an ack/nak
+                // TODO: establish a connection
+            }
+        }
+        	        
+    }
+}

Propchange: incubator/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message