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/03/05 09:29:09 UTC
svn commit: r383295 [2/4] - in /incubator/activemq/trunk/openwire-dotnet:
src/ src/ActiveMQ/ src/ActiveMQ/Commands/ src/ActiveMQ/OpenWire/
src/ActiveMQ/OpenWire/Commands/ src/ActiveMQ/OpenWire/V1/
src/ActiveMQ/Transport/ src/JMS/ tests/ tests/ActiveMQ/...
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ConsumerInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,167 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for ConsumerInfo
+ //
+ //
+ // 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
+ //
+ public class ConsumerInfo : BaseCommand
+ {
+ public const byte ID_ConsumerInfo = 5;
+
+ ConsumerId consumerId;
+ bool browser;
+ ActiveMQDestination destination;
+ int prefetchSize;
+ int maximumPendingMessageLimit;
+ bool dispatchAsync;
+ string selector;
+ string subcriptionName;
+ bool noLocal;
+ bool exclusive;
+ bool retroactive;
+ byte priority;
+ BrokerId[] brokerPath;
+ bool networkSubscription;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConsumerId=" + ConsumerId
+ + " Browser=" + Browser
+ + " Destination=" + Destination
+ + " PrefetchSize=" + PrefetchSize
+ + " MaximumPendingMessageLimit=" + MaximumPendingMessageLimit
+ + " DispatchAsync=" + DispatchAsync
+ + " Selector=" + Selector
+ + " SubcriptionName=" + SubcriptionName
+ + " NoLocal=" + NoLocal
+ + " Exclusive=" + Exclusive
+ + " Retroactive=" + Retroactive
+ + " Priority=" + Priority
+ + " BrokerPath=" + BrokerPath
+ + " NetworkSubscription=" + NetworkSubscription
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ConsumerInfo;
+ }
+
+
+ // Properties
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public bool Browser
+ {
+ get { return browser; }
+ set { this.browser = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public int PrefetchSize
+ {
+ get { return prefetchSize; }
+ set { this.prefetchSize = value; }
+ }
+
+ public int MaximumPendingMessageLimit
+ {
+ get { return maximumPendingMessageLimit; }
+ set { this.maximumPendingMessageLimit = value; }
+ }
+
+ public bool DispatchAsync
+ {
+ get { return dispatchAsync; }
+ set { this.dispatchAsync = value; }
+ }
+
+ public string Selector
+ {
+ get { return selector; }
+ set { this.selector = value; }
+ }
+
+ public string SubcriptionName
+ {
+ get { return subcriptionName; }
+ set { this.subcriptionName = value; }
+ }
+
+ public bool NoLocal
+ {
+ get { return noLocal; }
+ set { this.noLocal = value; }
+ }
+
+ public bool Exclusive
+ {
+ get { return exclusive; }
+ set { this.exclusive = value; }
+ }
+
+ public bool Retroactive
+ {
+ get { return retroactive; }
+ set { this.retroactive = value; }
+ }
+
+ public byte Priority
+ {
+ get { return priority; }
+ set { this.priority = value; }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get { return brokerPath; }
+ set { this.brokerPath = value; }
+ }
+
+ public bool NetworkSubscription
+ {
+ get { return networkSubscription; }
+ set { this.networkSubscription = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ControlCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ControlCommand.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ControlCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ControlCommand.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for ControlCommand
+ //
+ //
+ // 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
+ //
+ public class ControlCommand : BaseCommand
+ {
+ public const byte ID_ControlCommand = 14;
+
+ string command;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Command=" + Command
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ControlCommand;
+ }
+
+
+ // Properties
+
+ public string Command
+ {
+ get { return command; }
+ set { this.command = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataArrayResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataArrayResponse.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataArrayResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataArrayResponse.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for DataArrayResponse
+ //
+ //
+ // 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
+ //
+ public class DataArrayResponse : Response
+ {
+ public const byte ID_DataArrayResponse = 33;
+
+ DataStructure[] data;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Data=" + Data
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_DataArrayResponse;
+ }
+
+
+ // Properties
+
+ public DataStructure[] Data
+ {
+ get { return data; }
+ set { this.data = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataResponse.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataResponse.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for DataResponse
+ //
+ //
+ // 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
+ //
+ public class DataResponse : Response
+ {
+ public const byte ID_DataResponse = 32;
+
+ DataStructure data;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Data=" + Data
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_DataResponse;
+ }
+
+
+ // Properties
+
+ public DataStructure Data
+ {
+ get { return data; }
+ set { this.data = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DestinationInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DestinationInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DestinationInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DestinationInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,95 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for DestinationInfo
+ //
+ //
+ // 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
+ //
+ public class DestinationInfo : BaseCommand
+ {
+ public const byte ID_DestinationInfo = 8;
+
+ ConnectionId connectionId;
+ ActiveMQDestination destination;
+ byte operationType;
+ long timeout;
+ BrokerId[] brokerPath;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConnectionId=" + ConnectionId
+ + " Destination=" + Destination
+ + " OperationType=" + OperationType
+ + " Timeout=" + Timeout
+ + " BrokerPath=" + BrokerPath
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_DestinationInfo;
+ }
+
+
+ // Properties
+
+ public ConnectionId ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public byte OperationType
+ {
+ get { return operationType; }
+ set { this.operationType = value; }
+ }
+
+ public long Timeout
+ {
+ get { return timeout; }
+ set { this.timeout = value; }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get { return brokerPath; }
+ set { this.brokerPath = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DiscoveryEvent.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DiscoveryEvent.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DiscoveryEvent.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DiscoveryEvent.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for DiscoveryEvent
+ //
+ //
+ // 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
+ //
+ public class DiscoveryEvent : AbstractCommand
+ {
+ public const byte ID_DiscoveryEvent = 40;
+
+ string serviceName;
+ string brokerName;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ServiceName=" + ServiceName
+ + " BrokerName=" + BrokerName
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_DiscoveryEvent;
+ }
+
+
+ // Properties
+
+ public string ServiceName
+ {
+ get { return serviceName; }
+ set { this.serviceName = value; }
+ }
+
+ public string BrokerName
+ {
+ get { return brokerName; }
+ set { this.brokerName = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ExceptionResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ExceptionResponse.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ExceptionResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ExceptionResponse.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for ExceptionResponse
+ //
+ //
+ // 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
+ //
+ public class ExceptionResponse : Response
+ {
+ public const byte ID_ExceptionResponse = 31;
+
+ BrokerError exception;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Exception=" + Exception
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ExceptionResponse;
+ }
+
+
+ // Properties
+
+ public BrokerError Exception
+ {
+ get { return exception; }
+ set { this.exception = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/FlushCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/FlushCommand.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/FlushCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/FlushCommand.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,55 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for FlushCommand
+ //
+ //
+ // 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
+ //
+ public class FlushCommand : BaseCommand
+ {
+ public const byte ID_FlushCommand = 15;
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_FlushCommand;
+ }
+
+
+ // Properties
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/IntegerResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/IntegerResponse.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/IntegerResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/IntegerResponse.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for IntegerResponse
+ //
+ //
+ // 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
+ //
+ public class IntegerResponse : Response
+ {
+ public const byte ID_IntegerResponse = 34;
+
+ int result;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Result=" + Result
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_IntegerResponse;
+ }
+
+
+ // Properties
+
+ public int Result
+ {
+ get { return result; }
+ set { this.result = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalQueueAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalQueueAck.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalQueueAck.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalQueueAck.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,71 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for JournalQueueAck
+ //
+ //
+ // 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
+ //
+ public class JournalQueueAck : AbstractCommand
+ {
+ public const byte ID_JournalQueueAck = 52;
+
+ ActiveMQDestination destination;
+ MessageAck messageAck;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Destination=" + Destination
+ + " MessageAck=" + MessageAck
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_JournalQueueAck;
+ }
+
+
+ // Properties
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public MessageAck MessageAck
+ {
+ get { return messageAck; }
+ set { this.messageAck = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTopicAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTopicAck.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTopicAck.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTopicAck.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,103 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for JournalTopicAck
+ //
+ //
+ // 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
+ //
+ public class JournalTopicAck : AbstractCommand
+ {
+ public const byte ID_JournalTopicAck = 50;
+
+ ActiveMQDestination destination;
+ MessageId messageId;
+ long messageSequenceId;
+ string subscritionName;
+ string clientId;
+ TransactionId transactionId;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Destination=" + Destination
+ + " MessageId=" + MessageId
+ + " MessageSequenceId=" + MessageSequenceId
+ + " SubscritionName=" + SubscritionName
+ + " ClientId=" + ClientId
+ + " TransactionId=" + TransactionId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_JournalTopicAck;
+ }
+
+
+ // Properties
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public MessageId MessageId
+ {
+ get { return messageId; }
+ set { this.messageId = value; }
+ }
+
+ public long MessageSequenceId
+ {
+ get { return messageSequenceId; }
+ set { this.messageSequenceId = value; }
+ }
+
+ public string SubscritionName
+ {
+ get { return subscritionName; }
+ set { this.subscritionName = value; }
+ }
+
+ public string ClientId
+ {
+ get { return clientId; }
+ set { this.clientId = value; }
+ }
+
+ public TransactionId TransactionId
+ {
+ get { return transactionId; }
+ set { this.transactionId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTrace.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTrace.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTrace.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTrace.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for JournalTrace
+ //
+ //
+ // 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
+ //
+ public class JournalTrace : AbstractCommand
+ {
+ public const byte ID_JournalTrace = 53;
+
+ string message;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Message=" + Message
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_JournalTrace;
+ }
+
+
+ // Properties
+
+ public string Message
+ {
+ get { return message; }
+ set { this.message = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTransaction.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTransaction.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTransaction.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/JournalTransaction.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,79 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for JournalTransaction
+ //
+ //
+ // 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
+ //
+ public class JournalTransaction : AbstractCommand
+ {
+ public const byte ID_JournalTransaction = 54;
+
+ TransactionId transactionId;
+ byte type;
+ bool wasPrepared;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " TransactionId=" + TransactionId
+ + " Type=" + Type
+ + " WasPrepared=" + WasPrepared
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_JournalTransaction;
+ }
+
+
+ // Properties
+
+ public TransactionId TransactionId
+ {
+ get { return transactionId; }
+ set { this.transactionId = value; }
+ }
+
+ public byte Type
+ {
+ get { return type; }
+ set { this.type = value; }
+ }
+
+ public bool WasPrepared
+ {
+ get { return wasPrepared; }
+ set { this.wasPrepared = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/KeepAliveInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/KeepAliveInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/KeepAliveInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/KeepAliveInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,55 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for KeepAliveInfo
+ //
+ //
+ // 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
+ //
+ public class KeepAliveInfo : AbstractCommand
+ {
+ public const byte ID_KeepAliveInfo = 10;
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_KeepAliveInfo;
+ }
+
+
+ // Properties
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/LocalTransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/LocalTransactionId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/LocalTransactionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/LocalTransactionId.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,95 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for LocalTransactionId
+ //
+ //
+ // 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
+ //
+ public class LocalTransactionId : TransactionId
+ {
+ public const byte ID_LocalTransactionId = 111;
+
+ long value;
+ ConnectionId connectionId;
+
+ public override int GetHashCode() {
+ int answer = 0;
+ answer = (answer * 37) + HashCode(Value);
+ answer = (answer * 37) + HashCode(ConnectionId);
+ return answer;
+
+ }
+
+
+ public override bool Equals(object that) {
+ if (that is LocalTransactionId) {
+ return Equals((LocalTransactionId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(LocalTransactionId that) {
+ if (! Equals(this.Value, that.Value)) return false;
+ if (! Equals(this.ConnectionId, that.ConnectionId)) return false;
+ return true;
+
+ }
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Value=" + Value
+ + " ConnectionId=" + ConnectionId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_LocalTransactionId;
+ }
+
+
+ // Properties
+
+ public long Value
+ {
+ get { return value; }
+ set { this.value = value; }
+ }
+
+ public ConnectionId ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Message.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Message.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Message.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Message.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,255 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for Message
+ //
+ //
+ // 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
+ //
+ public class Message : BaseCommand
+ {
+ public const byte ID_Message = 0;
+
+ ProducerId producerId;
+ ActiveMQDestination destination;
+ TransactionId transactionId;
+ ActiveMQDestination originalDestination;
+ MessageId messageId;
+ TransactionId originalTransactionId;
+ string groupID;
+ int groupSequence;
+ string correlationId;
+ bool persistent;
+ long expiration;
+ byte priority;
+ ActiveMQDestination replyTo;
+ long timestamp;
+ string type;
+ byte[] content;
+ byte[] marshalledProperties;
+ DataStructure dataStructure;
+ ConsumerId targetConsumerId;
+ bool compressed;
+ int redeliveryCounter;
+ BrokerId[] brokerPath;
+ long arrival;
+ string userID;
+ bool recievedByDFBridge;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ProducerId=" + ProducerId
+ + " Destination=" + Destination
+ + " TransactionId=" + TransactionId
+ + " OriginalDestination=" + OriginalDestination
+ + " MessageId=" + MessageId
+ + " OriginalTransactionId=" + OriginalTransactionId
+ + " GroupID=" + GroupID
+ + " GroupSequence=" + GroupSequence
+ + " CorrelationId=" + CorrelationId
+ + " Persistent=" + Persistent
+ + " Expiration=" + Expiration
+ + " Priority=" + Priority
+ + " ReplyTo=" + ReplyTo
+ + " Timestamp=" + Timestamp
+ + " Type=" + Type
+ + " Content=" + Content
+ + " MarshalledProperties=" + MarshalledProperties
+ + " DataStructure=" + DataStructure
+ + " TargetConsumerId=" + TargetConsumerId
+ + " Compressed=" + Compressed
+ + " RedeliveryCounter=" + RedeliveryCounter
+ + " BrokerPath=" + BrokerPath
+ + " Arrival=" + Arrival
+ + " UserID=" + UserID
+ + " RecievedByDFBridge=" + RecievedByDFBridge
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_Message;
+ }
+
+
+ // Properties
+
+ public ProducerId ProducerId
+ {
+ get { return producerId; }
+ set { this.producerId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public TransactionId TransactionId
+ {
+ get { return transactionId; }
+ set { this.transactionId = value; }
+ }
+
+ public ActiveMQDestination OriginalDestination
+ {
+ get { return originalDestination; }
+ set { this.originalDestination = value; }
+ }
+
+ public MessageId MessageId
+ {
+ get { return messageId; }
+ set { this.messageId = value; }
+ }
+
+ public TransactionId OriginalTransactionId
+ {
+ get { return originalTransactionId; }
+ set { this.originalTransactionId = value; }
+ }
+
+ public string GroupID
+ {
+ get { return groupID; }
+ set { this.groupID = value; }
+ }
+
+ public int GroupSequence
+ {
+ get { return groupSequence; }
+ set { this.groupSequence = value; }
+ }
+
+ public string CorrelationId
+ {
+ get { return correlationId; }
+ set { this.correlationId = value; }
+ }
+
+ public bool Persistent
+ {
+ get { return persistent; }
+ set { this.persistent = value; }
+ }
+
+ public long Expiration
+ {
+ get { return expiration; }
+ set { this.expiration = value; }
+ }
+
+ public byte Priority
+ {
+ get { return priority; }
+ set { this.priority = value; }
+ }
+
+ public ActiveMQDestination ReplyTo
+ {
+ get { return replyTo; }
+ set { this.replyTo = value; }
+ }
+
+ public long Timestamp
+ {
+ get { return timestamp; }
+ set { this.timestamp = value; }
+ }
+
+ public string Type
+ {
+ get { return type; }
+ set { this.type = value; }
+ }
+
+ public byte[] Content
+ {
+ get { return content; }
+ set { this.content = value; }
+ }
+
+ public byte[] MarshalledProperties
+ {
+ get { return marshalledProperties; }
+ set { this.marshalledProperties = value; }
+ }
+
+ public DataStructure DataStructure
+ {
+ get { return dataStructure; }
+ set { this.dataStructure = value; }
+ }
+
+ public ConsumerId TargetConsumerId
+ {
+ get { return targetConsumerId; }
+ set { this.targetConsumerId = value; }
+ }
+
+ public bool Compressed
+ {
+ get { return compressed; }
+ set { this.compressed = value; }
+ }
+
+ public int RedeliveryCounter
+ {
+ get { return redeliveryCounter; }
+ set { this.redeliveryCounter = value; }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get { return brokerPath; }
+ set { this.brokerPath = value; }
+ }
+
+ public long Arrival
+ {
+ get { return arrival; }
+ set { this.arrival = value; }
+ }
+
+ public string UserID
+ {
+ get { return userID; }
+ set { this.userID = value; }
+ }
+
+ public bool RecievedByDFBridge
+ {
+ get { return recievedByDFBridge; }
+ set { this.recievedByDFBridge = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageAck.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageAck.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageAck.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,111 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for MessageAck
+ //
+ //
+ // 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
+ //
+ public class MessageAck : BaseCommand
+ {
+ public const byte ID_MessageAck = 22;
+
+ ActiveMQDestination destination;
+ TransactionId transactionId;
+ ConsumerId consumerId;
+ byte ackType;
+ MessageId firstMessageId;
+ MessageId lastMessageId;
+ int messageCount;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " Destination=" + Destination
+ + " TransactionId=" + TransactionId
+ + " ConsumerId=" + ConsumerId
+ + " AckType=" + AckType
+ + " FirstMessageId=" + FirstMessageId
+ + " LastMessageId=" + LastMessageId
+ + " MessageCount=" + MessageCount
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_MessageAck;
+ }
+
+
+ // Properties
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public TransactionId TransactionId
+ {
+ get { return transactionId; }
+ set { this.transactionId = value; }
+ }
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public byte AckType
+ {
+ get { return ackType; }
+ set { this.ackType = value; }
+ }
+
+ public MessageId FirstMessageId
+ {
+ get { return firstMessageId; }
+ set { this.firstMessageId = value; }
+ }
+
+ public MessageId LastMessageId
+ {
+ get { return lastMessageId; }
+ set { this.lastMessageId = value; }
+ }
+
+ public int MessageCount
+ {
+ get { return messageCount; }
+ set { this.messageCount = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatch.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatch.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatch.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatch.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,87 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for MessageDispatch
+ //
+ //
+ // 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
+ //
+ public class MessageDispatch : BaseCommand
+ {
+ public const byte ID_MessageDispatch = 21;
+
+ ConsumerId consumerId;
+ ActiveMQDestination destination;
+ Message message;
+ int redeliveryCounter;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConsumerId=" + ConsumerId
+ + " Destination=" + Destination
+ + " Message=" + Message
+ + " RedeliveryCounter=" + RedeliveryCounter
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_MessageDispatch;
+ }
+
+
+ // Properties
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public Message Message
+ {
+ get { return message; }
+ set { this.message = value; }
+ }
+
+ public int RedeliveryCounter
+ {
+ get { return redeliveryCounter; }
+ set { this.redeliveryCounter = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatchNotification.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatchNotification.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatchNotification.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageDispatchNotification.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,87 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for MessageDispatchNotification
+ //
+ //
+ // 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
+ //
+ public class MessageDispatchNotification : BaseCommand
+ {
+ public const byte ID_MessageDispatchNotification = 90;
+
+ ConsumerId consumerId;
+ ActiveMQDestination destination;
+ long deliverySequenceId;
+ MessageId messageId;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConsumerId=" + ConsumerId
+ + " Destination=" + Destination
+ + " DeliverySequenceId=" + DeliverySequenceId
+ + " MessageId=" + MessageId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_MessageDispatchNotification;
+ }
+
+
+ // Properties
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public long DeliverySequenceId
+ {
+ get { return deliverySequenceId; }
+ set { this.deliverySequenceId = value; }
+ }
+
+ public MessageId MessageId
+ {
+ get { return messageId; }
+ set { this.messageId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MessageId.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,105 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for MessageId
+ //
+ //
+ // 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
+ //
+ public class MessageId : AbstractCommand
+ {
+ public const byte ID_MessageId = 110;
+
+ ProducerId producerId;
+ long producerSequenceId;
+ long brokerSequenceId;
+
+ public override int GetHashCode() {
+ int answer = 0;
+ answer = (answer * 37) + HashCode(ProducerId);
+ answer = (answer * 37) + HashCode(ProducerSequenceId);
+ answer = (answer * 37) + HashCode(BrokerSequenceId);
+ return answer;
+
+ }
+
+
+ public override bool Equals(object that) {
+ if (that is MessageId) {
+ return Equals((MessageId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(MessageId that) {
+ if (! Equals(this.ProducerId, that.ProducerId)) return false;
+ if (! Equals(this.ProducerSequenceId, that.ProducerSequenceId)) return false;
+ if (! Equals(this.BrokerSequenceId, that.BrokerSequenceId)) return false;
+ return true;
+
+ }
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ProducerId=" + ProducerId
+ + " ProducerSequenceId=" + ProducerSequenceId
+ + " BrokerSequenceId=" + BrokerSequenceId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_MessageId;
+ }
+
+
+ // Properties
+
+ public ProducerId ProducerId
+ {
+ get { return producerId; }
+ set { this.producerId = value; }
+ }
+
+ public long ProducerSequenceId
+ {
+ get { return producerSequenceId; }
+ set { this.producerSequenceId = value; }
+ }
+
+ public long BrokerSequenceId
+ {
+ get { return brokerSequenceId; }
+ set { this.brokerSequenceId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerId.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,105 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for ProducerId
+ //
+ //
+ // 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
+ //
+ public class ProducerId : AbstractCommand
+ {
+ public const byte ID_ProducerId = 123;
+
+ string connectionId;
+ long value;
+ long sessionId;
+
+ public override int GetHashCode() {
+ int answer = 0;
+ answer = (answer * 37) + HashCode(ConnectionId);
+ answer = (answer * 37) + HashCode(Value);
+ answer = (answer * 37) + HashCode(SessionId);
+ return answer;
+
+ }
+
+
+ public override bool Equals(object that) {
+ if (that is ProducerId) {
+ return Equals((ProducerId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(ProducerId that) {
+ if (! Equals(this.ConnectionId, that.ConnectionId)) return false;
+ if (! Equals(this.Value, that.Value)) return false;
+ if (! Equals(this.SessionId, that.SessionId)) return false;
+ return true;
+
+ }
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConnectionId=" + ConnectionId
+ + " Value=" + Value
+ + " SessionId=" + SessionId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ProducerId;
+ }
+
+
+ // Properties
+
+ public string ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public long Value
+ {
+ get { return value; }
+ set { this.value = value; }
+ }
+
+ public long SessionId
+ {
+ get { return sessionId; }
+ set { this.sessionId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ProducerInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,79 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for ProducerInfo
+ //
+ //
+ // 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
+ //
+ public class ProducerInfo : BaseCommand
+ {
+ public const byte ID_ProducerInfo = 6;
+
+ ProducerId producerId;
+ ActiveMQDestination destination;
+ BrokerId[] brokerPath;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ProducerId=" + ProducerId
+ + " Destination=" + Destination
+ + " BrokerPath=" + BrokerPath
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ProducerInfo;
+ }
+
+
+ // Properties
+
+ public ProducerId ProducerId
+ {
+ get { return producerId; }
+ set { this.producerId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get { return brokerPath; }
+ set { this.brokerPath = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for RemoveInfo
+ //
+ //
+ // 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
+ //
+ public class RemoveInfo : BaseCommand
+ {
+ public const byte ID_RemoveInfo = 12;
+
+ DataStructure objectId;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ObjectId=" + ObjectId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_RemoveInfo;
+ }
+
+
+ // Properties
+
+ public DataStructure ObjectId
+ {
+ get { return objectId; }
+ set { this.objectId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveSubscriptionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveSubscriptionInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveSubscriptionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/RemoveSubscriptionInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,79 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+ //
+ //
+ // 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
+ //
+ public class RemoveSubscriptionInfo : BaseCommand
+ {
+ public const byte ID_RemoveSubscriptionInfo = 0;
+
+ ConnectionId connectionId;
+ string subcriptionName;
+ string clientId;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConnectionId=" + ConnectionId
+ + " SubcriptionName=" + SubcriptionName
+ + " ClientId=" + ClientId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_RemoveSubscriptionInfo;
+ }
+
+
+ // Properties
+
+ public ConnectionId ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public string SubcriptionName
+ {
+ get { return subcriptionName; }
+ set { this.subcriptionName = value; }
+ }
+
+ public string ClientId
+ {
+ get { return clientId; }
+ set { this.clientId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Response.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Response.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Response.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Response.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for Response
+ //
+ //
+ // 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
+ //
+ public class Response : BaseCommand
+ {
+ public const byte ID_Response = 30;
+
+ short correlationId;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " CorrelationId=" + CorrelationId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_Response;
+ }
+
+
+ // Properties
+
+ public short CorrelationId
+ {
+ get { return correlationId; }
+ set { this.correlationId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionId.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,95 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for SessionId
+ //
+ //
+ // 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
+ //
+ public class SessionId : AbstractCommand
+ {
+ public const byte ID_SessionId = 121;
+
+ string connectionId;
+ long value;
+
+ public override int GetHashCode() {
+ int answer = 0;
+ answer = (answer * 37) + HashCode(ConnectionId);
+ answer = (answer * 37) + HashCode(Value);
+ return answer;
+
+ }
+
+
+ public override bool Equals(object that) {
+ if (that is SessionId) {
+ return Equals((SessionId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(SessionId that) {
+ if (! Equals(this.ConnectionId, that.ConnectionId)) return false;
+ if (! Equals(this.Value, that.Value)) return false;
+ return true;
+
+ }
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ConnectionId=" + ConnectionId
+ + " Value=" + Value
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_SessionId;
+ }
+
+
+ // Properties
+
+ public string ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public long Value
+ {
+ get { return value; }
+ set { this.value = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SessionInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,63 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for SessionInfo
+ //
+ //
+ // 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
+ //
+ public class SessionInfo : BaseCommand
+ {
+ public const byte ID_SessionInfo = 4;
+
+ SessionId sessionId;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " SessionId=" + SessionId
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_SessionInfo;
+ }
+
+
+ // Properties
+
+ public SessionId SessionId
+ {
+ get { return sessionId; }
+ set { this.sessionId = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ShutdownInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ShutdownInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ShutdownInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ShutdownInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,55 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for ShutdownInfo
+ //
+ //
+ // 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
+ //
+ public class ShutdownInfo : BaseCommand
+ {
+ public const byte ID_ShutdownInfo = 11;
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_ShutdownInfo;
+ }
+
+
+ // Properties
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SubscriptionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SubscriptionInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SubscriptionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/SubscriptionInfo.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,87 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for SubscriptionInfo
+ //
+ //
+ // 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
+ //
+ public class SubscriptionInfo : AbstractCommand
+ {
+ public const byte ID_SubscriptionInfo = 55;
+
+ string clientId;
+ ActiveMQDestination destination;
+ string selector;
+ string subcriptionName;
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ClientId=" + ClientId
+ + " Destination=" + Destination
+ + " Selector=" + Selector
+ + " SubcriptionName=" + SubcriptionName
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_SubscriptionInfo;
+ }
+
+
+ // Properties
+
+ public string ClientId
+ {
+ get { return clientId; }
+ set { this.clientId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public string Selector
+ {
+ get { return selector; }
+ set { this.selector = value; }
+ }
+
+ public string SubcriptionName
+ {
+ get { return subcriptionName; }
+ set { this.subcriptionName = value; }
+ }
+
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionId.cs Sun Mar 5 00:28:53 2006
@@ -0,0 +1,75 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+ //
+ // Marshalling code for Open Wire Format for TransactionId
+ //
+ //
+ // 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
+ //
+ public class TransactionId : AbstractCommand
+ {
+ public const byte ID_TransactionId = 0;
+
+
+ public override int GetHashCode() {
+ int answer = 0;
+ return answer;
+
+ }
+
+
+ public override bool Equals(object that) {
+ if (that is TransactionId) {
+ return Equals((TransactionId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(TransactionId that) {
+ return true;
+
+ }
+
+
+ public override string ToString() {
+ return GetType().Name + "["
+ + " ]";
+
+ }
+
+
+
+ public override byte GetDataStructureType() {
+ return ID_TransactionId;
+ }
+
+
+ // Properties
+
+ }
+}