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 [2/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/BaseCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs Thu Jul 30 19:06:34 2009
@@ -30,168 +30,337 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- public abstract class BaseCommand : BaseDataStructure, Command, ICloneable
- {
- private int commandId;
- private bool responseRequired;
-
- public int CommandId
- {
- get { return commandId; }
- set { this.commandId = value; }
- }
-
- public override int GetHashCode()
- {
- return (CommandId * 37) + GetDataStructureType();
- }
-
- public override bool Equals(Object that)
- {
- if(that is BaseCommand)
- {
- BaseCommand thatCommand = (BaseCommand) that;
- return this.GetDataStructureType() == thatCommand.GetDataStructureType()
- && this.CommandId == thatCommand.CommandId;
- }
- return false;
- }
-
- public override String ToString()
- {
- string answer = GetDataStructureTypeAsString(GetDataStructureType());
- if(answer.Length == 0)
- {
- answer = base.ToString();
- }
- return answer + ": id = " + CommandId;
- }
-
- public static String GetDataStructureTypeAsString(int type)
- {
- String packetTypeStr = "";
- switch(type)
- {
- case ActiveMQMessage.ID_ActiveMQMessage:
- packetTypeStr = "ACTIVEMQ_MESSAGE";
- break;
- case ActiveMQTextMessage.ID_ActiveMQTextMessage:
- packetTypeStr = "ACTIVEMQ_TEXT_MESSAGE";
- break;
- case ActiveMQObjectMessage.ID_ActiveMQObjectMessage:
- packetTypeStr = "ACTIVEMQ_OBJECT_MESSAGE";
- break;
- case ActiveMQBytesMessage.ID_ActiveMQBytesMessage:
- packetTypeStr = "ACTIVEMQ_BYTES_MESSAGE";
- break;
- case ActiveMQStreamMessage.ID_ActiveMQStreamMessage:
- packetTypeStr = "ACTIVEMQ_STREAM_MESSAGE";
- break;
- case ActiveMQMapMessage.ID_ActiveMQMapMessage:
- packetTypeStr = "ACTIVEMQ_MAP_MESSAGE";
- break;
- case MessageAck.ID_MessageAck:
- packetTypeStr = "ACTIVEMQ_MSG_ACK";
- break;
- case Response.ID_Response:
- packetTypeStr = "RESPONSE";
- break;
- case ConsumerInfo.ID_ConsumerInfo:
- packetTypeStr = "CONSUMER_INFO";
- break;
- case ProducerInfo.ID_ProducerInfo:
- packetTypeStr = "PRODUCER_INFO";
- break;
- case TransactionInfo.ID_TransactionInfo:
- packetTypeStr = "TRANSACTION_INFO";
- break;
- case BrokerInfo.ID_BrokerInfo:
- packetTypeStr = "BROKER_INFO";
- break;
- case ConnectionInfo.ID_ConnectionInfo:
- packetTypeStr = "CONNECTION_INFO";
- break;
- case SessionInfo.ID_SessionInfo:
- packetTypeStr = "SESSION_INFO";
- break;
- case RemoveSubscriptionInfo.ID_RemoveSubscriptionInfo:
- packetTypeStr = "DURABLE_UNSUBSCRIBE";
- break;
- case IntegerResponse.ID_IntegerResponse:
- packetTypeStr = "INT_RESPONSE_RECEIPT_INFO";
- break;
- case WireFormatInfo.ID_WireFormatInfo:
- packetTypeStr = "WIRE_FORMAT_INFO";
- break;
- case RemoveInfo.ID_RemoveInfo:
- packetTypeStr = "REMOVE_INFO";
- break;
- case KeepAliveInfo.ID_KeepAliveInfo:
- packetTypeStr = "KEEP_ALIVE";
- break;
- }
- return packetTypeStr;
- }
-
- public virtual Response visit(ICommandVisitor visitor)
- {
- throw new ApplicationException("BaseCommand.Visit() not implemented");
- }
-
- public virtual bool IsMessage
- {
- get
- {
- return false;
- }
- }
-
- public virtual bool IsShutdownInfo
- {
- get
- {
- return false;
- }
- }
-
- public virtual bool IsBrokerInfo
- {
- get
- {
- return false;
- }
- }
-
- public virtual bool IsResponse
- {
- get
- {
- return false;
- }
- }
-
- public virtual bool ResponseRequired
- {
- get
- {
- return responseRequired;
- }
- set
- {
- responseRequired = value;
- }
- }
-
- 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.
- BaseCommand o = (BaseCommand) base.Clone();
-
- return o;
- }
- }
+ public abstract class BaseCommand : BaseDataStructure, Command, ICloneable
+ {
+ private int commandId;
+ private bool responseRequired;
+
+ public int CommandId
+ {
+ get { return commandId; }
+ set { this.commandId = value; }
+ }
+
+ public override int GetHashCode()
+ {
+ return (CommandId * 37) + GetDataStructureType();
+ }
+
+ public override bool Equals(Object that)
+ {
+ if(that is BaseCommand)
+ {
+ BaseCommand thatCommand = (BaseCommand) that;
+ return this.GetDataStructureType() == thatCommand.GetDataStructureType()
+ && this.CommandId == thatCommand.CommandId;
+ }
+ return false;
+ }
+
+ public override String ToString()
+ {
+ string answer = GetDataStructureTypeAsString(GetDataStructureType());
+ if(answer.Length == 0)
+ {
+ answer = base.ToString();
+ }
+ return answer + ": id = " + CommandId;
+ }
+
+ public static String GetDataStructureTypeAsString(int type)
+ {
+ String packetTypeStr = "";
+ switch(type)
+ {
+ case ActiveMQMessage.ID_ACTIVEMQMESSAGE:
+ packetTypeStr = "ACTIVEMQ_MESSAGE";
+ break;
+ case ActiveMQTextMessage.ID_ACTIVEMQTEXTMESSAGE:
+ packetTypeStr = "ACTIVEMQ_TEXT_MESSAGE";
+ break;
+ case ActiveMQObjectMessage.ID_ACTIVEMQOBJECTMESSAGE:
+ packetTypeStr = "ACTIVEMQ_OBJECT_MESSAGE";
+ break;
+ case ActiveMQBytesMessage.ID_ACTIVEMQBYTESMESSAGE:
+ packetTypeStr = "ACTIVEMQ_BYTES_MESSAGE";
+ break;
+ case ActiveMQStreamMessage.ID_ACTIVEMQSTREAMMESSAGE:
+ packetTypeStr = "ACTIVEMQ_STREAM_MESSAGE";
+ break;
+ case ActiveMQMapMessage.ID_ACTIVEMQMAPMESSAGE:
+ packetTypeStr = "ACTIVEMQ_MAP_MESSAGE";
+ break;
+ case MessageAck.ID_MESSAGEACK:
+ packetTypeStr = "ACTIVEMQ_MSG_ACK";
+ break;
+ case Response.ID_RESPONSE:
+ packetTypeStr = "RESPONSE";
+ break;
+ case ConsumerInfo.ID_CONSUMERINFO:
+ packetTypeStr = "CONSUMER_INFO";
+ break;
+ case ProducerInfo.ID_PRODUCERINFO:
+ packetTypeStr = "PRODUCER_INFO";
+ break;
+ case TransactionInfo.ID_TRANSACTIONINFO:
+ packetTypeStr = "TRANSACTION_INFO";
+ break;
+ case BrokerInfo.ID_BROKERINFO:
+ packetTypeStr = "BROKER_INFO";
+ break;
+ case ConnectionInfo.ID_CONNECTIONINFO:
+ packetTypeStr = "CONNECTION_INFO";
+ break;
+ case SessionInfo.ID_SESSIONINFO:
+ packetTypeStr = "SESSION_INFO";
+ break;
+ case RemoveSubscriptionInfo.ID_REMOVESUBSCRIPTIONINFO:
+ packetTypeStr = "DURABLE_UNSUBSCRIBE";
+ break;
+ case IntegerResponse.ID_INTEGERRESPONSE:
+ packetTypeStr = "INT_RESPONSE_RECEIPT_INFO";
+ break;
+ case WireFormatInfo.ID_WIREFORMATINFO:
+ packetTypeStr = "WIRE_FORMAT_INFO";
+ break;
+ case RemoveInfo.ID_REMOVEINFO:
+ packetTypeStr = "REMOVE_INFO";
+ break;
+ case KeepAliveInfo.ID_KEEPALIVEINFO:
+ packetTypeStr = "KEEP_ALIVE";
+ break;
+ }
+ return packetTypeStr;
+ }
+
+ public virtual Response visit(ICommandVisitor visitor)
+ {
+ throw new ApplicationException("BaseCommand.Visit() not implemented");
+ }
+
+
+ public virtual bool IsBrokerInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsConnectionControl
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsConnectionInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsConnectionError
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsConsumerControl
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsConsumerInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsControlCommand
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsDestinationInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsFlushCommand
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsKeepAliveInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsMessage
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsMessageAck
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsMessageDispatch
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsMessageDispatchNotification
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsMessagePull
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsProducerAck
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsProducerInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsRemoveInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsRemoveSubscriptionInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsReplayCommand
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsResponse
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsSessionInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsShutdownInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsTransactionInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool IsWireFormatInfo
+ {
+ get
+ {
+ return false;
+ }
+ }
+
+ public virtual bool ResponseRequired
+ {
+ get
+ {
+ return responseRequired;
+ }
+ set
+ {
+ responseRequired = value;
+ }
+ }
+
+ 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.
+ BaseCommand o = (BaseCommand) base.Clone();
+
+ return o;
+ }
+ }
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs Thu Jul 30 19:06:34 2009
@@ -14,86 +14,84 @@
* 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;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ BrokerId Command
- /// </summary>
- public class BrokerId : BaseDataStructure, DataStructure
- {
- public const byte ID_BrokerId = 124;
-
- string value;
-
- public override int GetHashCode()
- {
- int answer = 0;
- answer = (answer * 37) + HashCode(Value);
- return answer;
-
- }
-
- public override bool Equals(object that)
- {
- if(that is BrokerId)
- {
- return Equals((BrokerId) that);
- }
- return false;
- }
-
- public virtual bool Equals(BrokerId that)
- {
- if(!Equals(this.Value, that.Value))
- return false;
- return true;
-
- }
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " Value=" + Value
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_BrokerId;
- }
-
-
- // Properties
-
- public string Value
- {
- get { return value; }
- set { this.value = value; }
- }
-
- 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.
- BrokerId o = (BrokerId) base.Clone();
-
- // Now do the deep work required
- // If any new variables are added then this routine will
- // likely need updating
-
- return o;
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for BrokerId
+ *
+ * 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 BrokerId : BaseDataStructure
+ {
+ public const byte ID_BROKERID = 124;
+
+ string value;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_BROKERID;
+ }
+
+ ///
+ /// <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 +
+ "]";
+ }
+
+ public string Value
+ {
+ get { return value; }
+ set { this.value = value; }
+ }
+
+ public override int GetHashCode()
+ {
+ int answer = 0;
+
+ answer = (answer * 37) + HashCode(Value);
+
+ return answer;
+ }
+
+ public override bool Equals(object that)
+ {
+ if(that is BrokerId)
+ {
+ return Equals((BrokerId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(BrokerId that)
+ {
+ if(!Equals(this.Value, that.Value))
+ {
+ return false;
+ }
+
+ return true;
+ }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,131 +14,172 @@
* 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 BrokerInfo Command
- /// </summary>
- public class BrokerInfo : BaseCommand
- {
- public const byte ID_BrokerInfo = 2;
-
- BrokerId brokerId;
- string brokerURL;
- BrokerInfo[] peerBrokerInfos;
- string brokerName;
- bool slaveBroker;
- bool masterBroker;
- bool faultTolerantConfiguration;
- bool duplexConnection;
- bool networkConnection;
- long connectionId;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " BrokerId=" + BrokerId
- + " BrokerURL=" + BrokerURL
- + " PeerBrokerInfos=" + PeerBrokerInfos
- + " BrokerName=" + BrokerName
- + " SlaveBroker=" + SlaveBroker
- + " MasterBroker=" + MasterBroker
- + " FaultTolerantConfiguration=" + FaultTolerantConfiguration
- + " DuplexConnection=" + DuplexConnection
- + " NetworkConnection=" + NetworkConnection
- + " ConnectionId=" + ConnectionId
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_BrokerInfo;
- }
-
-
- // Properties
-
- public BrokerId BrokerId
- {
- get { return brokerId; }
- set { this.brokerId = value; }
- }
-
- public string BrokerURL
- {
- get { return brokerURL; }
- set { this.brokerURL = value; }
- }
-
- public BrokerInfo[] PeerBrokerInfos
- {
- get { return peerBrokerInfos; }
- set { this.peerBrokerInfos = value; }
- }
-
- public string BrokerName
- {
- get { return brokerName; }
- set { this.brokerName = value; }
- }
-
- public bool SlaveBroker
- {
- get { return slaveBroker; }
- set { this.slaveBroker = value; }
- }
-
- public bool MasterBroker
- {
- get { return masterBroker; }
- set { this.masterBroker = value; }
- }
-
- public bool FaultTolerantConfiguration
- {
- get { return faultTolerantConfiguration; }
- set { this.faultTolerantConfiguration = value; }
- }
-
- public bool DuplexConnection
- {
- get { return duplexConnection; }
- set { this.duplexConnection = value; }
- }
-
- public bool NetworkConnection
- {
- get { return networkConnection; }
- set { this.networkConnection = value; }
- }
-
- public long ConnectionId
- {
- get { return connectionId; }
- set { this.connectionId = value; }
- }
-
- public override bool IsBrokerInfo
- {
- get
- {
- return true;
- }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processBrokerInfo(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for BrokerInfo
+ *
+ * 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 BrokerInfo : BaseCommand
+ {
+ public const byte ID_BROKERINFO = 2;
+
+ BrokerId brokerId;
+ string brokerURL;
+ BrokerInfo[] peerBrokerInfos;
+ string brokerName;
+ bool slaveBroker;
+ bool masterBroker;
+ bool faultTolerantConfiguration;
+ bool duplexConnection;
+ bool networkConnection;
+ long connectionId;
+ string brokerUploadUrl;
+ string networkProperties;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_BROKERINFO;
+ }
+
+ ///
+ /// <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 + "[" +
+ "BrokerId=" + BrokerId +
+ "BrokerURL=" + BrokerURL +
+ "PeerBrokerInfos=" + PeerBrokerInfos +
+ "BrokerName=" + BrokerName +
+ "SlaveBroker=" + SlaveBroker +
+ "MasterBroker=" + MasterBroker +
+ "FaultTolerantConfiguration=" + FaultTolerantConfiguration +
+ "DuplexConnection=" + DuplexConnection +
+ "NetworkConnection=" + NetworkConnection +
+ "ConnectionId=" + ConnectionId +
+ "BrokerUploadUrl=" + BrokerUploadUrl +
+ "NetworkProperties=" + NetworkProperties +
+ "]";
+ }
+
+ public BrokerId BrokerId
+ {
+ get { return brokerId; }
+ set { this.brokerId = value; }
+ }
+
+ public string BrokerURL
+ {
+ get { return brokerURL; }
+ set { this.brokerURL = value; }
+ }
+
+ public BrokerInfo[] PeerBrokerInfos
+ {
+ get { return peerBrokerInfos; }
+ set { this.peerBrokerInfos = value; }
+ }
+
+ public string BrokerName
+ {
+ get { return brokerName; }
+ set { this.brokerName = value; }
+ }
+
+ public bool SlaveBroker
+ {
+ get { return slaveBroker; }
+ set { this.slaveBroker = value; }
+ }
+
+ public bool MasterBroker
+ {
+ get { return masterBroker; }
+ set { this.masterBroker = value; }
+ }
+
+ public bool FaultTolerantConfiguration
+ {
+ get { return faultTolerantConfiguration; }
+ set { this.faultTolerantConfiguration = value; }
+ }
+
+ public bool DuplexConnection
+ {
+ get { return duplexConnection; }
+ set { this.duplexConnection = value; }
+ }
+
+ public bool NetworkConnection
+ {
+ get { return networkConnection; }
+ set { this.networkConnection = value; }
+ }
+
+ public long ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public string BrokerUploadUrl
+ {
+ get { return brokerUploadUrl; }
+ set { this.brokerUploadUrl = value; }
+ }
+
+ public string NetworkProperties
+ {
+ get { return networkProperties; }
+ set { this.networkProperties = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isBrokerInfo() query.
+ /// </summery>
+ ///
+ public override bool IsBrokerInfo
+ {
+ 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.processBrokerInfo( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs Thu Jul 30 19:06:34 2009
@@ -22,44 +22,149 @@
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// An OpenWire command
- /// </summary>
- public interface Command : DataStructure, ICloneable
- {
- int CommandId
- {
- get;
- set;
- }
-
- bool ResponseRequired
- {
- get;
- set;
- }
-
- bool IsResponse
- {
- get;
- }
-
- bool IsBrokerInfo
- {
- get;
- }
-
- bool IsMessage
- {
- get;
- }
-
- bool IsShutdownInfo
- {
- get;
- }
+ /// <summary>
+ /// An OpenWire command
+ /// </summary>
+ public interface Command : DataStructure, ICloneable
+ {
+ int CommandId
+ {
+ get;
+ set;
+ }
+
+ bool ResponseRequired
+ {
+ get;
+ set;
+ }
+
+ bool IsBrokerInfo
+ {
+ get;
+ }
+
+ bool IsConnectionControl
+ {
+ get;
+ }
+
+ bool IsConnectionInfo
+ {
+ get;
+ }
+
+ bool IsConnectionError
+ {
+ get;
+ }
+
+ bool IsConsumerControl
+ {
+ get;
+ }
+
+ bool IsConsumerInfo
+ {
+ get;
+ }
+
+ bool IsControlCommand
+ {
+ get;
+ }
+
+ bool IsDestinationInfo
+ {
+ get;
+ }
+
+ bool IsFlushCommand
+ {
+ get;
+ }
+
+ bool IsKeepAliveInfo
+ {
+ get;
+ }
+
+ bool IsMessage
+ {
+ get;
+ }
+
+ bool IsMessageAck
+ {
+ get;
+ }
+
+ bool IsMessageDispatch
+ {
+ get;
+ }
+
+ bool IsMessageDispatchNotification
+ {
+ get;
+ }
+
+ bool IsMessagePull
+ {
+ get;
+ }
+
+ bool IsProducerAck
+ {
+ get;
+ }
+
+ bool IsProducerInfo
+ {
+ get;
+ }
+
+ bool IsRemoveInfo
+ {
+ get;
+ }
+
+ bool IsRemoveSubscriptionInfo
+ {
+ get;
+ }
+
+ bool IsReplayCommand
+ {
+ get;
+ }
+
+ bool IsResponse
+ {
+ get;
+ }
+
+ bool IsSessionInfo
+ {
+ get;
+ }
+
+ bool IsShutdownInfo
+ {
+ get;
+ }
+
+ bool IsTransactionInfo
+ {
+ get;
+ }
+
+ bool IsWireFormatInfo
+ {
+ get;
+ }
- Response visit(ICommandVisitor visitor);
- }
+ Response visit(ICommandVisitor visitor);
+ }
}
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs Thu Jul 30 19:06:34 2009
@@ -14,83 +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 ConnectionControl Command
- /// </summary>
- public class ConnectionControl : BaseCommand
- {
- public const byte ID_ConnectionControl = 18;
-
- bool close;
- bool exit;
- bool faultTolerant;
- bool resume;
- bool suspend;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " Close=" + Close
- + " Exit=" + Exit
- + " FaultTolerant=" + FaultTolerant
- + " Resume=" + Resume
- + " Suspend=" + Suspend
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ConnectionControl;
- }
-
-
- // Properties
-
- public bool Close
- {
- get { return close; }
- set { this.close = value; }
- }
-
- public bool Exit
- {
- get { return exit; }
- set { this.exit = value; }
- }
-
- public bool FaultTolerant
- {
- get { return faultTolerant; }
- set { this.faultTolerant = value; }
- }
-
- public bool Resume
- {
- get { return resume; }
- set { this.resume = value; }
- }
-
- public bool Suspend
- {
- get { return suspend; }
- set { this.suspend = value; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processConnectionControl(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConnectionControl
+ *
+ * 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 ConnectionControl : BaseCommand
+ {
+ public const byte ID_CONNECTIONCONTROL = 18;
+
+ bool close;
+ bool exit;
+ bool faultTolerant;
+ bool resume;
+ bool suspend;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONNECTIONCONTROL;
+ }
+
+ ///
+ /// <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 + "[" +
+ "Close=" + Close +
+ "Exit=" + Exit +
+ "FaultTolerant=" + FaultTolerant +
+ "Resume=" + Resume +
+ "Suspend=" + Suspend +
+ "]";
+ }
+
+ public bool Close
+ {
+ get { return close; }
+ set { this.close = value; }
+ }
+
+ public bool Exit
+ {
+ get { return exit; }
+ set { this.exit = value; }
+ }
+
+ public bool FaultTolerant
+ {
+ get { return faultTolerant; }
+ set { this.faultTolerant = value; }
+ }
+
+ public bool Resume
+ {
+ get { return resume; }
+ set { this.resume = value; }
+ }
+
+ public bool Suspend
+ {
+ get { return suspend; }
+ set { this.suspend = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isConnectionControl() query.
+ /// </summery>
+ ///
+ public override bool IsConnectionControl
+ {
+ 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.processConnectionControl( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs Thu Jul 30 19:06:34 2009
@@ -14,59 +14,92 @@
* 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 ConnectionError Command
- /// </summary>
- public class ConnectionError : BaseCommand
- {
- public const byte ID_ConnectionError = 16;
-
- BrokerError exception;
- ConnectionId connectionId;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " Exception=" + Exception
- + " ConnectionId=" + ConnectionId
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ConnectionError;
- }
-
-
- // Properties
-
- public BrokerError Exception
- {
- get { return exception; }
- set { this.exception = value; }
- }
-
- public ConnectionId ConnectionId
- {
- get { return connectionId; }
- set { this.connectionId = value; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processConnectionError(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConnectionError
+ *
+ * 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 ConnectionError : BaseCommand
+ {
+ public const byte ID_CONNECTIONERROR = 16;
+
+ BrokerError exception;
+ ConnectionId connectionId;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONNECTIONERROR;
+ }
+
+ ///
+ /// <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 +
+ "ConnectionId=" + ConnectionId +
+ "]";
+ }
+
+ public BrokerError Exception
+ {
+ get { return exception; }
+ set { this.exception = value; }
+ }
+
+ public ConnectionId ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isConnectionError() query.
+ /// </summery>
+ ///
+ public override bool IsConnectionError
+ {
+ 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.processConnectionError( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs Thu Jul 30 19:06:34 2009
@@ -14,79 +14,103 @@
* 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;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ ConnectionId Command
- /// </summary>
- public class ConnectionId : BaseDataStructure, DataStructure
- {
- public const byte ID_ConnectionId = 120;
-
- string value;
-
- public override int GetHashCode()
- {
- int answer = 0;
- answer = (answer * 37) + HashCode(Value);
- return answer;
-
- }
-
- public override bool Equals(object that)
- {
- if(that is ConnectionId)
- {
- return Equals((ConnectionId) that);
- }
- return false;
- }
-
- public virtual bool Equals(ConnectionId that)
- {
- if(!Equals(this.Value, that.Value))
- return false;
- return true;
-
- }
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " Value=" + Value
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ConnectionId;
- }
-
-
- // Properties
-
- public string Value
- {
- get { return value; }
- set { this.value = value; }
- }
-
- public ConnectionId(SessionId id)
- {
- this.value = id.ConnectionId;
- }
-
- public ConnectionId()
- {
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConnectionId
+ *
+ * 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 ConnectionId : BaseDataStructure
+ {
+ public const byte ID_CONNECTIONID = 120;
+
+ string value;
+
+ public ConnectionId()
+ {
+ }
+
+ public ConnectionId( SessionId sessionId )
+ {
+ this.value = sessionId.ConnectionId;
+ }
+
+ public ConnectionId( ProducerId producerId )
+ {
+ this.value = producerId.ConnectionId;
+ }
+
+ public ConnectionId( ConsumerId consumerId )
+ {
+ this.value = consumerId.ConnectionId;
+ }
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONNECTIONID;
+ }
+
+ ///
+ /// <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 +
+ "]";
+ }
+
+ public string Value
+ {
+ get { return value; }
+ set { this.value = value; }
+ }
+
+ public override int GetHashCode()
+ {
+ int answer = 0;
+
+ answer = (answer * 37) + HashCode(Value);
+
+ return answer;
+ }
+
+ public override bool Equals(object that)
+ {
+ if(that is ConnectionId)
+ {
+ return Equals((ConnectionId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(ConnectionId that)
+ {
+ if(!Equals(this.Value, that.Value))
+ {
+ return false;
+ }
+
+ return true;
+ }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,107 +14,140 @@
* 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 ConnectionInfo Command
- /// </summary>
- public class ConnectionInfo : BaseCommand
- {
- public const byte ID_ConnectionInfo = 3;
-
- ConnectionId connectionId;
- string clientId;
- string password;
- string userName;
- BrokerId[] brokerPath;
- bool brokerMasterConnector;
- bool manageable;
- bool clientMaster = true;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " ConnectionId=" + ConnectionId
- + " ClientId=" + ClientId
- + " Password=" + Password
- + " UserName=" + UserName
- + " BrokerPath=" + BrokerPath
- + " BrokerMasterConnector=" + BrokerMasterConnector
- + " Manageable=" + Manageable
- + " ClientMaster=" + ClientMaster
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ConnectionInfo;
- }
-
-
- // Properties
-
- public ConnectionId ConnectionId
- {
- get { return connectionId; }
- set { this.connectionId = value; }
- }
-
- public string ClientId
- {
- get { return clientId; }
- set { this.clientId = value; }
- }
-
- public string Password
- {
- get { return password; }
- set { this.password = value; }
- }
-
- public string UserName
- {
- get { return userName; }
- set { this.userName = value; }
- }
-
- public BrokerId[] BrokerPath
- {
- get { return brokerPath; }
- set { this.brokerPath = value; }
- }
-
- public bool BrokerMasterConnector
- {
- get { return brokerMasterConnector; }
- set { this.brokerMasterConnector = value; }
- }
-
- public bool Manageable
- {
- get { return manageable; }
- set { this.manageable = value; }
- }
-
- public bool ClientMaster
- {
- get { return clientMaster; }
- set { this.clientMaster = value; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processAddConnection(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConnectionInfo
+ *
+ * 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 ConnectionInfo : BaseCommand
+ {
+ public const byte ID_CONNECTIONINFO = 3;
+
+ ConnectionId connectionId;
+ string clientId;
+ string password;
+ string userName;
+ BrokerId[] brokerPath;
+ bool brokerMasterConnector;
+ bool manageable;
+ bool clientMaster;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONNECTIONINFO;
+ }
+
+ ///
+ /// <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 + "[" +
+ "ConnectionId=" + ConnectionId +
+ "ClientId=" + ClientId +
+ "Password=" + Password +
+ "UserName=" + UserName +
+ "BrokerPath=" + BrokerPath +
+ "BrokerMasterConnector=" + BrokerMasterConnector +
+ "Manageable=" + Manageable +
+ "ClientMaster=" + ClientMaster +
+ "]";
+ }
+
+ public ConnectionId ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public string ClientId
+ {
+ get { return clientId; }
+ set { this.clientId = value; }
+ }
+
+ public string Password
+ {
+ get { return password; }
+ set { this.password = value; }
+ }
+
+ public string UserName
+ {
+ get { return userName; }
+ set { this.userName = value; }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get { return brokerPath; }
+ set { this.brokerPath = value; }
+ }
+
+ public bool BrokerMasterConnector
+ {
+ get { return brokerMasterConnector; }
+ set { this.brokerMasterConnector = value; }
+ }
+
+ public bool Manageable
+ {
+ get { return manageable; }
+ set { this.manageable = value; }
+ }
+
+ public bool ClientMaster
+ {
+ get { return clientMaster; }
+ set { this.clientMaster = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isConnectionInfo() query.
+ /// </summery>
+ ///
+ public override bool IsConnectionInfo
+ {
+ 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.processAddConnection( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs Thu Jul 30 19:06:34 2009
@@ -14,91 +14,124 @@
* 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 ConsumerControl Command
- /// </summary>
- public class ConsumerControl : BaseCommand
- {
- public const byte ID_ConsumerControl = 17;
-
- bool close;
- ConsumerId consumerId;
- int prefetch;
- bool flush;
- bool start;
- bool stop;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " Close=" + Close
- + " ConsumerId=" + ConsumerId
- + " Prefetch=" + Prefetch
- + " Flush=" + Flush
- + " Start=" + Start
- + " Stop=" + Stop
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ConsumerControl;
- }
-
-
- // Properties
-
- public bool Close
- {
- get { return close; }
- set { this.close = value; }
- }
-
- public ConsumerId ConsumerId
- {
- get { return consumerId; }
- set { this.consumerId = value; }
- }
-
- public int Prefetch
- {
- get { return prefetch; }
- set { this.prefetch = value; }
- }
-
- public bool Flush
- {
- get { return flush; }
- set { this.flush = value; }
- }
-
- public bool Start
- {
- get { return start; }
- set { this.start = value; }
- }
-
- public bool Stop
- {
- get { return stop; }
- set { this.stop = value; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processConsumerControl(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConsumerControl
+ *
+ * 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 ConsumerControl : BaseCommand
+ {
+ public const byte ID_CONSUMERCONTROL = 17;
+
+ bool close;
+ ConsumerId consumerId;
+ int prefetch;
+ bool flush;
+ bool start;
+ bool stop;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONSUMERCONTROL;
+ }
+
+ ///
+ /// <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 + "[" +
+ "Close=" + Close +
+ "ConsumerId=" + ConsumerId +
+ "Prefetch=" + Prefetch +
+ "Flush=" + Flush +
+ "Start=" + Start +
+ "Stop=" + Stop +
+ "]";
+ }
+
+ public bool Close
+ {
+ get { return close; }
+ set { this.close = value; }
+ }
+
+ public ConsumerId ConsumerId
+ {
+ get { return consumerId; }
+ set { this.consumerId = value; }
+ }
+
+ public int Prefetch
+ {
+ get { return prefetch; }
+ set { this.prefetch = value; }
+ }
+
+ public bool Flush
+ {
+ get { return flush; }
+ set { this.flush = value; }
+ }
+
+ public bool Start
+ {
+ get { return start; }
+ set { this.start = value; }
+ }
+
+ public bool Stop
+ {
+ get { return stop; }
+ set { this.stop = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isConsumerControl() query.
+ /// </summery>
+ ///
+ public override bool IsConsumerControl
+ {
+ 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.processConsumerControl( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs Thu Jul 30 19:06:34 2009
@@ -14,103 +14,134 @@
* 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;
namespace Apache.NMS.ActiveMQ.Commands
{
- /// <summary>
- /// The ActiveMQ ConsumerId Command
- /// </summary>
- public class ConsumerId : BaseDataStructure, DataStructure
- {
- public const byte ID_ConsumerId = 122;
-
- string connectionId;
- long sessionId;
- long value;
- private SessionId _parentId;
-
- public override int GetHashCode()
- {
- int answer = 0;
- answer = (answer * 37) + HashCode(ConnectionId);
- answer = (answer * 37) + HashCode(SessionId);
- answer = (answer * 37) + HashCode(Value);
- return answer;
-
- }
-
- public override bool Equals(object that)
- {
- if(that is ConsumerId)
- {
- return Equals((ConsumerId) that);
- }
- return false;
- }
-
- public virtual bool Equals(ConsumerId that)
- {
- if(!Equals(this.ConnectionId, that.ConnectionId))
- return false;
- if(!Equals(this.SessionId, that.SessionId))
- return false;
- if(!Equals(this.Value, that.Value))
- return false;
- return true;
-
- }
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " ConnectionId=" + ConnectionId
- + " SessionId=" + SessionId
- + " Value=" + Value
- + " ]";
-
- }
-
- public override byte GetDataStructureType()
- {
- return ID_ConsumerId;
- }
-
-
- // Properties
-
- public string ConnectionId
- {
- get { return connectionId; }
- set { this.connectionId = value; }
- }
-
- public long SessionId
- {
- get { return sessionId; }
- set { this.sessionId = value; }
- }
-
- public long Value
- {
- get { return value; }
- set { this.value = value; }
- }
-
- public SessionId ParentId
- {
- get
- {
- if(_parentId == null)
- {
- _parentId = new SessionId(this);
- }
- return _parentId;
- }
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConsumerId
+ *
+ * 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 ConsumerId : BaseDataStructure
+ {
+ public const byte ID_CONSUMERID = 122;
+
+ private SessionId parentId = null;
+
+ string connectionId;
+ long sessionId;
+ long value;
+
+ public ConsumerId()
+ {
+ }
+
+ public ConsumerId( SessionId sessionId, long consumerId )
+ {
+ this.connectionId = sessionId.ConnectionId;
+ this.sessionId = sessionId.Value;
+ this.value = consumerId;
+ }
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONSUMERID;
+ }
+
+ ///
+ /// <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 + "[" +
+ "ConnectionId=" + ConnectionId +
+ "SessionId=" + SessionId +
+ "Value=" + Value +
+ "]";
+ }
+
+ public SessionId ParentId
+ {
+ get
+ {
+ if( this.parentId == null ) {
+ this.parentId = new SessionId( this );
+ }
+ return this.parentId;
+ }
+ }
+
+ public string ConnectionId
+ {
+ get { return connectionId; }
+ set { this.connectionId = value; }
+ }
+
+ public long SessionId
+ {
+ get { return sessionId; }
+ set { this.sessionId = value; }
+ }
+
+ public long Value
+ {
+ get { return value; }
+ set { this.value = value; }
+ }
+
+ public override int GetHashCode()
+ {
+ int answer = 0;
+
+ answer = (answer * 37) + HashCode(ConnectionId);
+ answer = (answer * 37) + HashCode(SessionId);
+ answer = (answer * 37) + HashCode(Value);
+
+ return answer;
+ }
+
+ public override bool Equals(object that)
+ {
+ if(that is ConsumerId)
+ {
+ return Equals((ConsumerId) that);
+ }
+ return false;
+ }
+
+ public virtual bool Equals(ConsumerId that)
+ {
+ if(!Equals(this.ConnectionId, that.ConnectionId))
+ {
+ return false;
+ }
+ if(!Equals(this.SessionId, that.SessionId))
+ {
+ return false;
+ }
+ if(!Equals(this.Value, that.Value))
+ {
+ return false;
+ }
+
+ return true;
+ }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,187 +14,220 @@
* 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 ConsumerInfo Command
- /// </summary>
- 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 subscriptionName;
- bool noLocal;
- bool exclusive;
- bool retroactive;
- byte priority;
- BrokerId[] brokerPath;
- BooleanExpression additionalPredicate;
- bool networkSubscription;
- bool optimizedAcknowledge;
- bool noRangeAcks;
- AcknowledgementMode acknowledgementMode = AcknowledgementMode.AutoAcknowledge;
-
- public override string ToString()
- {
- return GetType().Name + "["
- + " ConsumerId=" + ConsumerId
- + " Browser=" + Browser
- + " Destination=" + Destination
- + " PrefetchSize=" + PrefetchSize
- + " MaximumPendingMessageLimit=" + MaximumPendingMessageLimit
- + " DispatchAsync=" + DispatchAsync
- + " Selector=" + Selector
- + " SubscriptionName=" + SubscriptionName
- + " NoLocal=" + NoLocal
- + " Exclusive=" + Exclusive
- + " Retroactive=" + Retroactive
- + " Priority=" + Priority
- + " BrokerPath=" + BrokerPath
- + " AdditionalPredicate=" + AdditionalPredicate
- + " NetworkSubscription=" + NetworkSubscription
- + " OptimizedAcknowledge=" + OptimizedAcknowledge
- + " NoRangeAcks=" + NoRangeAcks
- + " AcknowledgementMode=" + AcknowledgementMode
- + " ]";
-
- }
-
- 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 SubscriptionName
- {
- get { return subscriptionName; }
- set { this.subscriptionName = 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 BooleanExpression AdditionalPredicate
- {
- get { return additionalPredicate; }
- set { this.additionalPredicate = value; }
- }
-
- public bool NetworkSubscription
- {
- get { return networkSubscription; }
- set { this.networkSubscription = value; }
- }
-
- public bool OptimizedAcknowledge
- {
- get { return optimizedAcknowledge; }
- set { this.optimizedAcknowledge = value; }
- }
-
- public bool NoRangeAcks
- {
- get { return noRangeAcks; }
- set { this.noRangeAcks = value; }
- }
-
- public AcknowledgementMode AcknowledgementMode
- {
- get { return acknowledgementMode; }
- set { this.acknowledgementMode = value; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processAddConsumer(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ConsumerInfo
+ *
+ * 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 ConsumerInfo : BaseCommand
+ {
+ public const byte ID_CONSUMERINFO = 5;
+
+ ConsumerId consumerId;
+ bool browser;
+ ActiveMQDestination destination;
+ int prefetchSize;
+ int maximumPendingMessageLimit;
+ bool dispatchAsync;
+ string selector;
+ string subscriptionName;
+ bool noLocal;
+ bool exclusive;
+ bool retroactive;
+ byte priority;
+ BrokerId[] brokerPath;
+ BooleanExpression additionalPredicate;
+ bool networkSubscription;
+ bool optimizedAcknowledge;
+ bool noRangeAcks;
+ ConsumerId[] networkConsumerPath;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONSUMERINFO;
+ }
+
+ ///
+ /// <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 +
+ "Browser=" + Browser +
+ "Destination=" + Destination +
+ "PrefetchSize=" + PrefetchSize +
+ "MaximumPendingMessageLimit=" + MaximumPendingMessageLimit +
+ "DispatchAsync=" + DispatchAsync +
+ "Selector=" + Selector +
+ "SubscriptionName=" + SubscriptionName +
+ "NoLocal=" + NoLocal +
+ "Exclusive=" + Exclusive +
+ "Retroactive=" + Retroactive +
+ "Priority=" + Priority +
+ "BrokerPath=" + BrokerPath +
+ "AdditionalPredicate=" + AdditionalPredicate +
+ "NetworkSubscription=" + NetworkSubscription +
+ "OptimizedAcknowledge=" + OptimizedAcknowledge +
+ "NoRangeAcks=" + NoRangeAcks +
+ "NetworkConsumerPath=" + NetworkConsumerPath +
+ "]";
+ }
+
+ 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 SubscriptionName
+ {
+ get { return subscriptionName; }
+ set { this.subscriptionName = 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 BooleanExpression AdditionalPredicate
+ {
+ get { return additionalPredicate; }
+ set { this.additionalPredicate = value; }
+ }
+
+ public bool NetworkSubscription
+ {
+ get { return networkSubscription; }
+ set { this.networkSubscription = value; }
+ }
+
+ public bool OptimizedAcknowledge
+ {
+ get { return optimizedAcknowledge; }
+ set { this.optimizedAcknowledge = value; }
+ }
+
+ public bool NoRangeAcks
+ {
+ get { return noRangeAcks; }
+ set { this.noRangeAcks = value; }
+ }
+
+ public ConsumerId[] NetworkConsumerPath
+ {
+ get { return networkConsumerPath; }
+ set { this.networkConsumerPath = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isConsumerInfo() query.
+ /// </summery>
+ ///
+ public override bool IsConsumerInfo
+ {
+ 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.processAddConsumer( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs Thu Jul 30 19:06:34 2009
@@ -14,51 +14,84 @@
* 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 ControlCommand Command
- /// </summary>
- 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; }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- return visitor.processControlCommand(this);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for ControlCommand
+ *
+ * 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 ControlCommand : BaseCommand
+ {
+ public const byte ID_CONTROLCOMMAND = 14;
+
+ string command;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_CONTROLCOMMAND;
+ }
+
+ ///
+ /// <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 + "[" +
+ "Command=" + Command +
+ "]";
+ }
+
+ public string Command
+ {
+ get { return command; }
+ set { this.command = value; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isControlCommand() query.
+ /// </summery>
+ ///
+ public override bool IsControlCommand
+ {
+ 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.processControlCommand( this );
+ }
+
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.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 DataArrayResponse Command
- /// </summary>
+ /*
+ *
+ * Command code for OpenWire format for DataArrayResponse
+ *
+ * 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 DataArrayResponse : Response
{
- public const byte ID_DataArrayResponse = 33;
-
- DataStructure[] data;
-
- public override string ToString() {
- return GetType().Name + "["
- + " Data=" + Data
- + " ]";
+ public const byte ID_DATAARRAYRESPONSE = 33;
- }
+ DataStructure[] data;
- public override byte GetDataStructureType() {
- return ID_DataArrayResponse;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_DATAARRAYRESPONSE;
}
-
- // 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 + "[" +
+ "Data=" + Data +
+ "]";
+ }
public DataStructure[] Data
{
get { return data; }
- set { this.data = value; }
+ set { this.data = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.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 DataResponse Command
- /// </summary>
+ /*
+ *
+ * Command code for OpenWire format for DataResponse
+ *
+ * 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 DataResponse : Response
{
- public const byte ID_DataResponse = 32;
-
- DataStructure data;
-
- public override string ToString() {
- return GetType().Name + "["
- + " Data=" + Data
- + " ]";
+ public const byte ID_DATARESPONSE = 32;
- }
+ DataStructure data;
- public override byte GetDataStructureType() {
- return ID_DataResponse;
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_DATARESPONSE;
}
-
- // 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 + "[" +
+ "Data=" + Data +
+ "]";
+ }
public DataStructure Data
{
get { return data; }
- set { this.data = value; }
+ set { this.data = value; }
}
- }
+ };
}
+
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,110 +14,141 @@
* 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 DestinationInfo Command
- /// </summary>
- public class DestinationInfo : BaseCommand
- {
- public const byte ID_DestinationInfo = 8;
-
- public const byte ADD_OPERATION_TYPE = 0;
- public const byte REMOVE_OPERATION_TYPE = 1;
-
- ConnectionId connectionId;
- IDestination 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 IDestination 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; }
- }
-
- public bool IsAddOperation
- {
- get
- {
- return OperationType == ADD_OPERATION_TYPE;
- }
- }
-
- public bool IsRemoveOperation
- {
- get
- {
- return OperationType == REMOVE_OPERATION_TYPE;
- }
- }
-
- public override Response visit(ICommandVisitor visitor)
- {
- if(IsAddOperation)
- {
- return visitor.processAddDestination(this);
- }
- else if(IsRemoveOperation)
- {
- return visitor.processRemoveDestination(this);
- }
- throw new IOException("Unknown operation type: " + OperationType);
- }
- }
+ /*
+ *
+ * Command code for OpenWire format for DestinationInfo
+ *
+ * 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 DestinationInfo : BaseCommand
+ {
+ public const byte ID_DESTINATIONINFO = 8;
+
+ public const byte ADD_OPERATION_TYPE = 0;
+ public const byte REMOVE_OPERATION_TYPE = 1;
+ ConnectionId connectionId;
+ ActiveMQDestination destination;
+ byte operationType;
+ long timeout;
+ BrokerId[] brokerPath;
+
+ ///
+ /// <summery>
+ /// Get the unique identifier that this object and its own
+ /// Marshaler share.
+ /// </summery>
+ ///
+ public override byte GetDataStructureType()
+ {
+ return ID_DESTINATIONINFO;
+ }
+
+ ///
+ /// <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 + "[" +
+ "ConnectionId=" + ConnectionId +
+ "Destination=" + Destination +
+ "OperationType=" + OperationType +
+ "Timeout=" + Timeout +
+ "BrokerPath=" + BrokerPath +
+ "]";
+ }
+
+ public bool IsAddOperation
+ {
+ get
+ {
+ return OperationType == ADD_OPERATION_TYPE;
+ }
+ }
+
+ public bool IsRemoveOperation
+ {
+ get
+ {
+ return OperationType == REMOVE_OPERATION_TYPE;
+ }
+ }
+ 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; }
+ }
+
+ ///
+ /// <summery>
+ /// Return an answer of true to the isDestinationInfo() query.
+ /// </summery>
+ ///
+ public override bool IsDestinationInfo
+ {
+ 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)
+ {
+ if(IsAddOperation)
+ {
+ return visitor.processAddDestination(this);
+ }
+ else if(IsRemoveOperation)
+ {
+ return visitor.processRemoveDestination(this);
+ }
+ throw new IOException("Unknown operation type: " + OperationType);
+ }
+
+ };
}
+