You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/10/09 22:59:17 UTC
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...
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