You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2009/07/30 21:06:44 UTC
svn commit: r799407 [3/29] - in
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: ./
Commands/ OpenWire/ OpenWire/V1/ OpenWire/V2/ OpenWire/V3/ OpenWire/V4/
OpenWire/V5/ State/ Transport/
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DiscoveryEvent.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DiscoveryEvent.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DiscoveryEvent.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DiscoveryEvent.cs Thu Jul 30 19:06:34 2009
@@ -14,56 +14,65 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ DiscoveryEvent Command
- /// </summary>
- public class DiscoveryEvent : BaseDataStructure, DataStructure
+ /*
+ *
+ * Command code for OpenWire format for DiscoveryEvent
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class DiscoveryEvent : BaseDataStructure
{
- public const byte ID_DiscoveryEvent = 40;
-
+ 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;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_DISCOVERYEVENT;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "ServiceName=" + ServiceName +
+ "BrokerName=" + BrokerName +
+ "]";
+ }
public string ServiceName
{
get { return serviceName; }
- set { this.serviceName = value; }
+ set { this.serviceName = value; }
}
public string BrokerName
{
get { return brokerName; }
- set { this.brokerName = value; }
+ set { this.brokerName = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ExceptionResponse.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ExceptionResponse.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ExceptionResponse.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ExceptionResponse.cs Thu Jul 30 19:06:34 2009
@@ -14,48 +14,57 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ ExceptionResponse Command
- /// </summary>
+ /*
+ *
+ * Command code for OpenWire format for ExceptionResponse
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
public class ExceptionResponse : Response
{
- public const byte ID_ExceptionResponse = 31;
-
- BrokerError exception;
-
- public override string ToString() {
- return GetType().Name + "["
- + " Exception=" + Exception
- + " ]";
+ public const byte ID_EXCEPTIONRESPONSE = 31;
- }
+ BrokerError exception;
- public override byte GetDataStructureType() {
- return ID_ExceptionResponse;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_EXCEPTIONRESPONSE;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Exception=" + Exception +
+ "]";
+ }
public BrokerError Exception
{
get { return exception; }
- set { this.exception = value; }
+ set { this.exception = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/FlushCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/FlushCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/FlushCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/FlushCommand.cs Thu Jul 30 19:06:34 2009
@@ -14,43 +14,75 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ FlushCommand Command
- /// </summary>
- public class FlushCommand : BaseCommand
- {
- public const byte ID_FlushCommand = 15;
-
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_FlushCommand;
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processFlush(this);
- }
+ /*
+ *
+ * Command code for OpenWire format for FlushCommand
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class FlushCommand : BaseCommand
+ {
+ public const byte ID_FLUSHCOMMAND = 15;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_FLUSHCOMMAND;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "]";
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isFlushCommand() query.
+ /// </summery>
+ ///
+ public override bool IsFlushCommand
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processFlushCommand( this );
+ }
- // Properties
-
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/IntegerResponse.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/IntegerResponse.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/IntegerResponse.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/IntegerResponse.cs Thu Jul 30 19:06:34 2009
@@ -14,48 +14,57 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ IntegerResponse Command
- /// </summary>
+ /*
+ *
+ * Command code for OpenWire format for IntegerResponse
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
public class IntegerResponse : Response
{
- public const byte ID_IntegerResponse = 34;
-
- int result;
-
- public override string ToString() {
- return GetType().Name + "["
- + " Result=" + Result
- + " ]";
+ public const byte ID_INTEGERRESPONSE = 34;
- }
+ int result;
- public override byte GetDataStructureType() {
- return ID_IntegerResponse;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_INTEGERRESPONSE;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Result=" + Result +
+ "]";
+ }
public int Result
{
get { return result; }
- set { this.result = value; }
+ set { this.result = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalQueueAck.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalQueueAck.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalQueueAck.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalQueueAck.cs Thu Jul 30 19:06:34 2009
@@ -14,56 +14,65 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ JournalQueueAck Command
- /// </summary>
- public class JournalQueueAck : BaseDataStructure, DataStructure
+ /*
+ *
+ * Command code for OpenWire format for JournalQueueAck
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class JournalQueueAck : BaseDataStructure
{
- public const byte ID_JournalQueueAck = 52;
-
+ 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;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_JOURNALQUEUEACK;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Destination=" + Destination +
+ "MessageAck=" + MessageAck +
+ "]";
+ }
public ActiveMQDestination Destination
{
get { return destination; }
- set { this.destination = value; }
+ set { this.destination = value; }
}
public MessageAck MessageAck
{
get { return messageAck; }
- set { this.messageAck = value; }
+ set { this.messageAck = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTopicAck.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTopicAck.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTopicAck.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTopicAck.cs Thu Jul 30 19:06:34 2009
@@ -14,27 +14,25 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ JournalTopicAck Command
- /// </summary>
- public class JournalTopicAck : BaseDataStructure, DataStructure
+ /*
+ *
+ * Command code for OpenWire format for JournalTopicAck
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class JournalTopicAck : BaseDataStructure
{
- public const byte ID_JournalTopicAck = 50;
-
+ public const byte ID_JOURNALTOPICACK = 50;
+
ActiveMQDestination destination;
MessageId messageId;
long messageSequenceId;
@@ -42,60 +40,71 @@
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;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_JOURNALTOPICACK;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Destination=" + Destination +
+ "MessageId=" + MessageId +
+ "MessageSequenceId=" + MessageSequenceId +
+ "SubscritionName=" + SubscritionName +
+ "ClientId=" + ClientId +
+ "TransactionId=" + TransactionId +
+ "]";
}
-
- // Properties
-
public ActiveMQDestination Destination
{
get { return destination; }
- set { this.destination = value; }
+ set { this.destination = value; }
}
public MessageId MessageId
{
get { return messageId; }
- set { this.messageId = value; }
+ set { this.messageId = value; }
}
public long MessageSequenceId
{
get { return messageSequenceId; }
- set { this.messageSequenceId = value; }
+ set { this.messageSequenceId = value; }
}
public string SubscritionName
{
get { return subscritionName; }
- set { this.subscritionName = value; }
+ set { this.subscritionName = value; }
}
public string ClientId
{
get { return clientId; }
- set { this.clientId = value; }
+ set { this.clientId = value; }
}
public TransactionId TransactionId
{
get { return transactionId; }
- set { this.transactionId = value; }
+ set { this.transactionId = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTrace.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTrace.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTrace.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTrace.cs Thu Jul 30 19:06:34 2009
@@ -14,48 +14,57 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ JournalTrace Command
- /// </summary>
- public class JournalTrace : BaseDataStructure, DataStructure
+ /*
+ *
+ * Command code for OpenWire format for JournalTrace
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class JournalTrace : BaseDataStructure
{
- public const byte ID_JournalTrace = 53;
-
- string message;
-
- public override string ToString() {
- return GetType().Name + "["
- + " Message=" + Message
- + " ]";
+ public const byte ID_JOURNALTRACE = 53;
- }
+ string message;
- public override byte GetDataStructureType() {
- return ID_JournalTrace;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_JOURNALTRACE;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Message=" + Message +
+ "]";
+ }
public string Message
{
get { return message; }
- set { this.message = value; }
+ set { this.message = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTransaction.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTransaction.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTransaction.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/JournalTransaction.cs Thu Jul 30 19:06:34 2009
@@ -14,64 +14,73 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ JournalTransaction Command
- /// </summary>
- public class JournalTransaction : BaseDataStructure, DataStructure
+ /*
+ *
+ * Command code for OpenWire format for JournalTransaction
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class JournalTransaction : BaseDataStructure
{
- public const byte ID_JournalTransaction = 54;
-
+ 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;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_JOURNALTRANSACTION;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "TransactionId=" + TransactionId +
+ "Type=" + Type +
+ "WasPrepared=" + WasPrepared +
+ "]";
+ }
public TransactionId TransactionId
{
get { return transactionId; }
- set { this.transactionId = value; }
+ set { this.transactionId = value; }
}
public byte Type
{
get { return type; }
- set { this.type = value; }
+ set { this.type = value; }
}
public bool WasPrepared
{
get { return wasPrepared; }
- set { this.wasPrepared = value; }
+ set { this.wasPrepared = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/KeepAliveInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/KeepAliveInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/KeepAliveInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/KeepAliveInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,44 +14,75 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ KeepAliveInfo Command
- /// </summary>
- public class KeepAliveInfo : BaseCommand
- {
- public const byte ID_KeepAliveInfo = 10;
+ /*
+ *
+ * Command code for OpenWire format for KeepAliveInfo
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class KeepAliveInfo : BaseCommand
+ {
+ public const byte ID_KEEPALIVEINFO = 10;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_KEEPALIVEINFO;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "]";
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isKeepAliveInfo() query.
+ /// </summery>
+ ///
+ public override bool IsKeepAliveInfo
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processKeepAliveInfo( this );
+ }
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_KeepAliveInfo;
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processKeepAlive(this);
- }
-
-
- // Properties
-
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LastPartialCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LastPartialCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LastPartialCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LastPartialCommand.cs Thu Jul 30 19:06:34 2009
@@ -14,43 +14,48 @@
* 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 Apache.NMS.ActiveMQ.State;
+using System.Collections;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ LastPartialCommand Command
- /// </summary>
- public class LastPartialCommand : PartialCommand
- {
- public const byte ID_LastPartialCommand = 61;
-
-
- public override string ToString()
- {
- return GetType().Name + "[" + " ]";
-
- }
+ /*
+ *
+ * Command code for OpenWire format for LastPartialCommand
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class LastPartialCommand : PartialCommand
+ {
+ public const byte ID_LASTPARTIALCOMMAND = 61;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_LASTPARTIALCOMMAND;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "]";
+ }
- public override byte GetDataStructureType()
- {
- return ID_LastPartialCommand;
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- throw new ApplicationException("The transport layer should filter out LastPartialCommand instances but received: " + this);
- }
-
- // Properties
-
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LocalTransactionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LocalTransactionId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LocalTransactionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/LocalTransactionId.cs Thu Jul 30 19:06:34 2009
@@ -14,78 +14,97 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ LocalTransactionId Command
- /// </summary>
+ /*
+ *
+ * Command code for OpenWire format for LocalTransactionId
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
public class LocalTransactionId : TransactionId
{
- public const byte ID_LocalTransactionId = 111;
-
+ 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;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_LOCALTRANSACTIONID;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Value=" + Value +
+ "ConnectionId=" + ConnectionId +
+ "]";
+ }
public long Value
{
get { return value; }
- set { this.value = value; }
+ set { this.value = value; }
}
public ConnectionId ConnectionId
{
get { return connectionId; }
- set { this.connectionId = value; }
+ set { this.connectionId = value; }
}
- }
+ 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;
+ }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Message.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Message.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Message.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Message.cs Thu Jul 30 19:06:34 2009
@@ -14,335 +14,329 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ Message Command
- /// </summary>
- public class Message : BaseCommand, MarshallAware, MessageReference, ICloneable
- {
- 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 receivedByDFBridge;
- bool droppable;
-
- 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
- + " Droppable=" + Droppable
- + " ]";
-
- }
-
- 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 receivedByDFBridge; }
- set { this.receivedByDFBridge = value; }
- }
-
- public bool Droppable
- {
- get { return droppable; }
- set { this.droppable = value; }
- }
-
- public override bool IsMessage
- {
- get
- {
- return true;
- }
- }
-
- public override Object Clone()
- {
- // Since we are a derived class use the base's Clone()
- // to perform the shallow copy. Since it is shallow it
- // will include our derived class. Since we are derived,
- // this method is an override.
- Message o = (Message) base.Clone();
-
- // Now do the deep work required
- // If any new variables are added then this routine will
- // likely need updating
- if(o.producerId != null)
- {
- o.producerId = (ProducerId) o.producerId.Clone();
- }
-
- if(o.destination != null)
- {
- o.destination = (ActiveMQDestination) o.destination.Clone();
- }
-
- if(o.transactionId != null)
- {
- o.transactionId = (TransactionId) o.transactionId.Clone();
- }
-
- if(o.originalDestination != null)
- {
- o.originalDestination = (ActiveMQDestination) o.originalDestination.Clone();
- }
-
- if(o.messageId != null)
- {
- o.messageId = (MessageId) o.messageId.Clone();
- }
-
- if(o.originalTransactionId != null)
- {
- o.originalTransactionId = (TransactionId) o.originalTransactionId.Clone();
- }
-
- if(o.replyTo != null)
- {
- o.replyTo = (ActiveMQDestination) o.replyTo.Clone();
- }
-
- if(o.content != null)
- {
- o.content = (byte[]) o.content.Clone();
- }
-
- if(o.marshalledProperties != null)
- {
- o.marshalledProperties = (byte[]) o.marshalledProperties.Clone();
- }
-
- if(o.dataStructure != null)
- {
- o.dataStructure = (DataStructure) o.dataStructure.Clone();
- }
-
- if(o.targetConsumerId != null)
- {
- o.targetConsumerId = (ConsumerId) o.targetConsumerId.Clone();
- }
-
- if(o.brokerPath != null)
- {
- o.brokerPath = (BrokerId[]) o.brokerPath.Clone();
- for(int i = 0; i < o.brokerPath.Length; i++)
- {
- if(o.brokerPath[i] != null)
- {
- o.brokerPath[i] = (BrokerId) (o.brokerPath[i].Clone());
- }
- }
- }
-
- return o;
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for Message
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class Message : BaseCommand, MessageReference, MarshallAware, ICloneable
+ {
+ 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;
+ bool droppable;
+ BrokerId[] cluster;
+ long brokerInTime;
+ long brokerOutTime;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_MESSAGE;
+ }
+
+ ///
+ /// <summery>
+ /// Clone this object and return a new instance that the caller now owns.
+ /// </summery>
+ ///
+ public override Object Clone()
+ {
+ // Since we are a derived class use the base's Clone()
+ // to perform the shallow copy. Since it is shallow it
+ // will include our derived class. Since we are derived,
+ // this method is an override.
+ Message o = (Message) base.Clone();
+
+ if( this.messageId != null )
+ {
+ o.MessageId = (MessageId) this.messageId.Clone();
+ }
+
+ return o;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ 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 +
+ "Droppable=" + Droppable +
+ "Cluster=" + Cluster +
+ "BrokerInTime=" + BrokerInTime +
+ "BrokerOutTime=" + BrokerOutTime +
+ "]";
+ }
+
+ 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; }
+ }
+
+ public bool Droppable
+ {
+ get { return droppable; }
+ set { this.droppable = value; }
+ }
+
+ public BrokerId[] Cluster
+ {
+ get { return cluster; }
+ set { this.cluster = value; }
+ }
+
+ public long BrokerInTime
+ {
+ get { return brokerInTime; }
+ set { this.brokerInTime = value; }
+ }
+
+ public long BrokerOutTime
+ {
+ get { return brokerOutTime; }
+ set { this.brokerOutTime = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isMessage() query.
+ /// </summery>
+ ///
+ public override bool IsMessage
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processMessage( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageAck.cs Thu Jul 30 19:06:34 2009
@@ -14,99 +14,132 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ MessageAck Command
- /// </summary>
- 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; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processMessageAck(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for MessageAck
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator 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;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_MESSAGEACK;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "Destination=" + Destination +
+ "TransactionId=" + TransactionId +
+ "ConsumerId=" + ConsumerId +
+ "AckType=" + AckType +
+ "FirstMessageId=" + FirstMessageId +
+ "LastMessageId=" + LastMessageId +
+ "MessageCount=" + MessageCount +
+ "]";
+ }
+
+ 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; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isMessageAck() query.
+ /// </summery>
+ ///
+ public override bool IsMessageAck
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processMessageAck( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatch.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatch.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatch.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatch.cs Thu Jul 30 19:06:34 2009
@@ -14,75 +14,108 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ MessageDispatch Command
- /// </summary>
- 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; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processMessageDispatch(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for MessageDispatch
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class MessageDispatch : BaseCommand
+ {
+ public const byte ID_MESSAGEDISPATCH = 21;
+
+ ConsumerId consumerId;
+ ActiveMQDestination destination;
+ Message message;
+ int redeliveryCounter;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_MESSAGEDISPATCH;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "ConsumerId=" + ConsumerId +
+ "Destination=" + Destination +
+ "Message=" + Message +
+ "RedeliveryCounter=" + RedeliveryCounter +
+ "]";
+ }
+
+ 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; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isMessageDispatch() query.
+ /// </summery>
+ ///
+ public override bool IsMessageDispatch
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processMessageDispatch( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatchNotification.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatchNotification.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatchNotification.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageDispatchNotification.cs Thu Jul 30 19:06:34 2009
@@ -14,76 +14,108 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ MessageDispatchNotification Command
- /// </summary>
- 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; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processMessageDispatchNotification(this);
- }
+ /*
+ *
+ * Command code for OpenWire format for MessageDispatchNotification
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class MessageDispatchNotification : BaseCommand
+ {
+ public const byte ID_MESSAGEDISPATCHNOTIFICATION = 90;
+
+ ConsumerId consumerId;
+ ActiveMQDestination destination;
+ long deliverySequenceId;
+ MessageId messageId;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_MESSAGEDISPATCHNOTIFICATION;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "ConsumerId=" + ConsumerId +
+ "Destination=" + Destination +
+ "DeliverySequenceId=" + DeliverySequenceId +
+ "MessageId=" + MessageId +
+ "]";
+ }
+
+ 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; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isMessageDispatchNotification() query.
+ /// </summery>
+ ///
+ public override bool IsMessageDispatchNotification
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processMessageDispatchNotification( this );
+ }
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessageId.cs Thu Jul 30 19:06:34 2009
@@ -14,88 +14,110 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ MessageId Command
- /// </summary>
- public class MessageId : BaseDataStructure, DataStructure
+ /*
+ *
+ * Command code for OpenWire format for MessageId
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class MessageId : BaseDataStructure
{
- public const byte ID_MessageId = 110;
-
+ 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;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_MESSAGEID;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "ProducerId=" + ProducerId +
+ "ProducerSequenceId=" + ProducerSequenceId +
+ "BrokerSequenceId=" + BrokerSequenceId +
+ "]";
+ }
public ProducerId ProducerId
{
get { return producerId; }
- set { this.producerId = value; }
+ set { this.producerId = value; }
}
public long ProducerSequenceId
{
get { return producerSequenceId; }
- set { this.producerSequenceId = value; }
+ set { this.producerSequenceId = value; }
}
public long BrokerSequenceId
{
get { return brokerSequenceId; }
- set { this.brokerSequenceId = value; }
+ set { this.brokerSequenceId = value; }
}
- }
+ 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;
+ }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessagePull.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessagePull.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessagePull.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/MessagePull.cs Thu Jul 30 19:06:34 2009
@@ -14,68 +14,116 @@
* 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 Apache.NMS.ActiveMQ.State;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ MessagePull Command
- /// </summary>
- public class MessagePull : BaseCommand
- {
- public const byte ID_MessagePull = 20;
-
- ConsumerId consumerId;
- ActiveMQDestination destination;
- long timeout;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " ConsumerId=" + ConsumerId
- + " Destination=" + Destination
- + " Timeout=" + Timeout
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_MessagePull;
- }
-
-
- // Properties
-
- public ConsumerId ConsumerId
- {
- get { return consumerId; }
- set { this.consumerId = value; }
- }
-
- public ActiveMQDestination Destination
- {
- get { return destination; }
- set { this.destination = value; }
- }
-
- public long Timeout
- {
- get { return timeout; }
- set { this.timeout = value; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processMessagePull(this);
- }
+ /*
+ *
+ * Command code for OpenWire format for MessagePull
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class MessagePull : BaseCommand
+ {
+ public const byte ID_MESSAGEPULL = 20;
+
+ ConsumerId consumerId;
+ ActiveMQDestination destination;
+ long timeout;
+ string correlationId;
+ MessageId messageId;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_MESSAGEPULL;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "ConsumerId=" + ConsumerId +
+ "Destination=" + Destination +
+ "Timeout=" + Timeout +
+ "CorrelationId=" + CorrelationId +
+ "MessageId=" + MessageId +
+ "]";
+ }
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get { return destination; }
+ set { this.destination = value; }
+ }
+
+ public long Timeout
+ {
+ get { return timeout; }
+ set { this.timeout = value; }
+ }
+
+ public string CorrelationId
+ {
+ get { return correlationId; }
+ set { this.correlationId = value; }
+ }
+
+ public MessageId MessageId
+ {
+ get { return messageId; }
+ set { this.messageId = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isMessagePull() query.
+ /// </summery>
+ ///
+ public override bool IsMessagePull
+ {
+ get
+ {
+ return true;
+ }
+ }
+
+ ///
+ /// <summery>
+ /// Allows a Visitor to visit this command and return a response to the
+ /// command based on the command type being visited. The command will call
+ /// the proper processXXX method in the visitor.
+ /// </summery>
+ ///
+ public override Response visit(ICommandVisitor visitor)
+ {
+ return visitor.processMessagePull( this );
+ }
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/NetworkBridgeFilter.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/NetworkBridgeFilter.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/NetworkBridgeFilter.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/NetworkBridgeFilter.cs Thu Jul 30 19:06:34 2009
@@ -14,56 +14,65 @@
* 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 Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ NetworkBridgeFilter Command
- /// </summary>
- public class NetworkBridgeFilter : BaseDataStructure, DataStructure, BooleanExpression
+ /*
+ *
+ * Command code for OpenWire format for NetworkBridgeFilter
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class NetworkBridgeFilter : BaseDataStructure
{
- public const byte ID_NetworkBridgeFilter = 91;
-
+ public const byte ID_NETWORKBRIDGEFILTER = 91;
+
int networkTTL;
BrokerId networkBrokerId;
- public override string ToString() {
- return GetType().Name + "["
- + " NetworkTTL=" + NetworkTTL
- + " NetworkBrokerId=" + NetworkBrokerId
- + " ]";
-
- }
-
- public override byte GetDataStructureType() {
- return ID_NetworkBridgeFilter;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_NETWORKBRIDGEFILTER;
}
-
- // Properties
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "NetworkTTL=" + NetworkTTL +
+ "NetworkBrokerId=" + NetworkBrokerId +
+ "]";
+ }
public int NetworkTTL
{
get { return networkTTL; }
- set { this.networkTTL = value; }
+ set { this.networkTTL = value; }
}
public BrokerId NetworkBrokerId
{
get { return networkBrokerId; }
- set { this.networkBrokerId = value; }
+ set { this.networkBrokerId = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/PartialCommand.cs Thu Jul 30 19:06:34 2009
@@ -14,104 +14,65 @@
* 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 Apache.NMS.ActiveMQ.State;
+using System.Collections;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ PartialCommand Command
- /// </summary>
- public class PartialCommand : BaseDataStructure, Command
- {
- public const byte ID_PartialCommand = 60;
-
- int commandId;
- byte[] data;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " CommandId=" + CommandId
- + " Data=" + Data
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_PartialCommand;
- }
-
-
- // Properties
-
- public int CommandId
- {
- get { return commandId; }
- set { this.commandId = value; }
- }
-
- public byte[] Data
- {
- get { return data; }
- set { this.data = value; }
- }
-
- public bool IsMessage
- {
- get
- {
- return false;
- }
- }
-
- public bool IsShutdownInfo
- {
- get
- {
- return false;
- }
- }
-
- public bool IsBrokerInfo
- {
- get
- {
- return false;
- }
- }
-
- public bool IsResponse
- {
- get
- {
- return false;
- }
- }
-
- public virtual bool ResponseRequired
- {
- get
- {
- return false;
- }
- set
- {
- throw new ApplicationException("PartialCommand should not set ResponseRequired");
- }
- }
-
- public virtual Response visit(ICommandVisitor visitor)
- {
- throw new ApplicationException("The transport layer should filter out PartialCommand instances but received: " + this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for PartialCommand
+ *
+ * NOTE!: This file is auto generated - do not modify!
+ * if you need to make a change, please see the Java Classes
+ * in the nms-activemq-openwire-generator module
+ *
+ */
+ public class PartialCommand : BaseDataStructure
+ {
+ public const byte ID_PARTIALCOMMAND = 60;
+
+ int commandId;
+ byte[] data;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_PARTIALCOMMAND;
+ }
+
+ ///
+ /// <summery>
+ /// Returns a string containing the information for this DataStructure
+ /// such as its type and value of its elements.
+ /// </summery>
+ ///
+ public override string ToString()
+ {
+ return GetType().Name + "[" +
+ "CommandId=" + CommandId +
+ "Data=" + Data +
+ "]";
+ }
+
+ public int CommandId
+ {
+ get { return commandId; }
+ set { this.commandId = value; }
+ }
+
+ public byte[] Data
+ {
+ get { return data; }
+ set { this.data = value; }
+ }
+
+ };
}
+