Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

almost compiling OpenWire.Net :) 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@366543 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2006-01-06 17:56:09 +00:00
parent d51d772352
commit 23bec283f0
104 changed files with 225 additions and 310 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs
View File

@ -5,14 +5,14 @@ namespace OpenWire.Core
/// <summary>
/// Summary description for AbstractCommand.
/// </summary>
public abstract class AbstractCommand {
public abstract class AbstractCommand : Command {
public const int NON_PERSISTENT = 1;
public const int PERSISTENT = 2;
//public const int NON_PERSISTENT = 1;
//public const int PERSISTENT = 2;
/**
* Message flag indexes (used for writing/reading to/from a Stream
*/
/**
* Message flag indexes (used for writing/reading to/from a Stream
*/
public const int RECEIPT_REQUIRED_INDEX = 0;
public const int BROKERS_VISITED_INDEX =1;
private short id = 0;
@ -28,54 +28,49 @@ namespace OpenWire.Core
return 0;
}
public short getId()
public short GetId()
{
return this.id;
}
public virtual void setId(short newId)
public virtual void SetId(short newId)
{
this.id = newId;
}
public virtual bool isReceiptRequired()
public virtual bool IsReceiptRequired()
{
return this.receiptRequired;
}
public virtual bool isReceipt()
public virtual bool IsReceipt()
{
return false;
}
public void setReceiptRequired(bool value)
public void SetReceiptRequired(bool value)
{
this.receiptRequired = value;
}
public virtual bool isJMSMessage()
public virtual bool IsJMSMessage()
{
return false;
}
public int hashCode()
public override int GetHashCode()
{
return this.id;
}
public virtual short getCommandType()
public override String ToString()
{
return id;
}
public String toString()
{
return getCommandTypeAsString(getCommandType()) + ": id = " + getId();
return GetCommandTypeAsString(GetCommandType()) + ": id = " + GetId();
}
public static String getCommandTypeAsString(int type)
public static String GetCommandTypeAsString(int type)
{
String packetTypeStr = "";
switch (type)
@ -155,12 +150,6 @@ namespace OpenWire.Core
}
return packetTypeStr;
}
protected virtual bool equals(Object left, Object right)
{
return left == right || (left != null && left.Equals(right));
}
}
}

9
openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs
View File

@ -1,4 +1,5 @@
using System;
using System.IO;
namespace OpenWire.Core
{
@ -10,9 +11,13 @@ namespace OpenWire.Core
public abstract Command CreateCommand();
public abstract void BuildCommand(Command command, BinaryReader dataIn);
public virtual void BuildCommand(Command command, BinaryReader dataIn)
{
}
public abstract void WriteCommand(Command command, BinaryWriter dataOut);
public virtual void WriteCommand(Command command, BinaryWriter dataOut)
{
}
}
}

120
openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs
View File

@ -81,7 +81,7 @@ namespace OpenWire.Core
protected ActiveMQDestination(String name) {
this.physicalName = name;
this.advisory = name != null && name.startsWith(ADVISORY_PREFIX);
this.advisory = name != null && name.StartsWith(ADVISORY_PREFIX);
}
@ -89,71 +89,71 @@ namespace OpenWire.Core
/**
* @return Returns the advisory.
*/
public bool isAdvisory() {
public bool IsAdvisory() {
return advisory;
}
/**
* @param advisory The advisory to set.
*/
public void setAdvisory(bool advisory) {
public void SetAdvisory(bool advisory) {
this.advisory = advisory;
}
/**
* @return true if this is a destination for Consumer advisories
*/
public bool isConsumerAdvisory(){
return isAdvisory() && physicalName.startsWith(ActiveMQDestination.CONSUMER_ADVISORY_PREFIX);
public bool IsConsumerAdvisory(){
return IsAdvisory() && physicalName.StartsWith(ActiveMQDestination.CONSUMER_ADVISORY_PREFIX);
}
/**
* @return true if this is a destination for Producer advisories
*/
public bool isProducerAdvisory(){
return isAdvisory() && physicalName.startsWith(ActiveMQDestination.PRODUCER_ADVISORY_PREFIX);
public bool IsProducerAdvisory(){
return IsAdvisory() && physicalName.StartsWith(ActiveMQDestination.PRODUCER_ADVISORY_PREFIX);
}
/**
* @return true if this is a destination for Connection advisories
*/
public bool isConnectionAdvisory(){
return isAdvisory() && physicalName.startsWith(ActiveMQDestination.CONNECTION_ADVISORY_PREFIX);
public bool IsConnectionAdvisory(){
return IsAdvisory() && physicalName.StartsWith(ActiveMQDestination.CONNECTION_ADVISORY_PREFIX);
}
/**
* @return Returns the exclusive.
*/
public bool isExclusive() {
public bool IsExclusive() {
return exclusive;
}
/**
* @param exclusive The exclusive to set.
*/
public void setExclusive(bool exclusive) {
public void SetExclusive(bool exclusive) {
this.exclusive = exclusive;
}
/**
* @return Returns the ordered.
*/
public bool isOrdered() {
public bool IsOrdered() {
return ordered;
}
/**
* @param ordered The ordered to set.
*/
public void setOrdered(bool ordered) {
public void SetOrdered(bool ordered) {
this.ordered = ordered;
}
/**
* @return Returns the orderedTarget.
*/
public String getOrderedTarget() {
public String GetOrderedTarget() {
return orderedTarget;
}
/**
* @param orderedTarget The orderedTarget to set.
*/
public void setOrderedTarget(String orderedTarget) {
public void SetOrderedTarget(String orderedTarget) {
this.orderedTarget = orderedTarget;
}
/**
@ -200,37 +200,13 @@ namespace OpenWire.Core
return result;
}
/**
* Write an ActiveMQDestination to a Stream
*
* @param destination
* @param dataOut
* @throws IOException
*/
public static void writeToStream(ActiveMQDestination destination, Object dataOut) {
//TODO SERILIZATION
}
/**
* Read an ActiveMQDestination from a Stream
*
* @param dataIn
* @return the ActiveMQDestination
* @throws IOException
*/
public static ActiveMQDestination readFromStream(Object dataIn) {
//TODO Serilization
}
/**
* Create a Destination
* @param type
* @param pyhsicalName
* @return
*/
public static ActiveMQDestination createDestination(int type,String pyhsicalName){
public static ActiveMQDestination CreateDestination(int type,String pyhsicalName){
ActiveMQDestination result = null;
if (type == ACTIVEMQ_TOPIC) {
result = new ActiveMQTopic(pyhsicalName);
@ -253,7 +229,7 @@ namespace OpenWire.Core
* @param clientId
* @return
*/
public static String createTemporaryName(String clientId) {
public static String CreateTemporaryName(String clientId) {
return TEMP_PREFIX + clientId + TEMP_POSTFIX;
}
@ -263,7 +239,7 @@ namespace OpenWire.Core
* @param destination
* @return the clientId or null if not a temporary destination
*/
public static String getClientId(ActiveMQDestination destination) {
public static String GetClientId(ActiveMQDestination destination) {
String answer = null;
if (destination != null && destination.isTemporary()) {
String name = destination.getPhysicalName();
@ -284,7 +260,7 @@ namespace OpenWire.Core
* @param o object to compare
* @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
*/
public int compareTo(Object o) {
public int CompareTo(Object o) {
if (o is ActiveMQDestination) {
return compareTo((ActiveMQDestination) o);
}
@ -297,7 +273,7 @@ namespace OpenWire.Core
* @param that another destination to compare against
* @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
*/
public int compareTo(ActiveMQDestination that) {
public int CompareTo(ActiveMQDestination that) {
int answer = 0;
if (physicalName != that.physicalName) {
if (physicalName == null) {
@ -328,20 +304,20 @@ namespace OpenWire.Core
* @return Returns the Destination type
*/
public abstract int getDestinationType();
public abstract int GetDestinationType();
/**
* @return Returns the physicalName.
*/
public String getPhysicalName() {
public String GetPhysicalName() {
return this.physicalName;
}
/**
* @param newPhysicalName The physicalName to set.
*/
public void setPhysicalName(String newPhysicalName) {
public void SetPhysicalName(String newPhysicalName) {
this.physicalName = newPhysicalName;
}
@ -351,9 +327,9 @@ namespace OpenWire.Core
* @return true/false
*/
public bool isTemporary() {
return getDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC ||
getDestinationType() == ACTIVEMQ_TEMPORARY_QUEUE;
public bool IsTemporary() {
return GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC ||
GetDestinationType() == ACTIVEMQ_TEMPORARY_QUEUE;
}
/**
@ -362,9 +338,9 @@ namespace OpenWire.Core
* @return true/false
*/
public bool isTopic() {
return getDestinationType() == ACTIVEMQ_TOPIC ||
getDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC;
public bool IsTopic() {
return GetDestinationType() == ACTIVEMQ_TOPIC ||
GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC;
}
/**
@ -372,7 +348,7 @@ namespace OpenWire.Core
*
* @return true/false
*/
public bool isQueue() {
public bool IsQueue() {
return !isTopic();
}
@ -386,7 +362,7 @@ namespace OpenWire.Core
*
* @return true if this destination represents a collection of child destinations.
*/
public bool isComposite() {
public bool IsComposite() {
return physicalName.indexOf(COMPOSITE_SEPARATOR) > 0;
}
@ -396,16 +372,16 @@ namespace OpenWire.Core
*
* @return
*/
/*public List getChildDestinations() {
/*public List GetChildDestinations() {
List answer = new ArrayList();
StringTokenizer iter = new StringTokenizer(physicalName, COMPOSITE_SEPARATOR);
while (iter.hasMoreTokens()) {
String name = iter.nextToken();
Destination child = null;
if (name.startsWith(QUEUE_PREFIX)) {
if (name.StartsWith(QUEUE_PREFIX)) {
child = new ActiveMQQueue(name.substring(QUEUE_PREFIX.length()));
}
else if (name.startsWith(TOPIC_PREFIX)) {
else if (name.StartsWith(TOPIC_PREFIX)) {
child = new ActiveMQTopic(name.substring(TOPIC_PREFIX.length()));
}
else {
@ -425,7 +401,7 @@ namespace OpenWire.Core
* @return string representation of this instance
*/
public String toString() {
public override String ToString() {
return this.physicalName;
}
@ -433,7 +409,7 @@ namespace OpenWire.Core
* @return hashCode for this instance
*/
public int hashCode() {
public override int GetHashCode() {
int answer = 0xcafebabe;
if (this.physicalName != null) {
@ -452,7 +428,7 @@ namespace OpenWire.Core
* @return true if this instance and obj are equivalent
*/
public bool equals(Object obj) {
public override bool Equals(Object obj) {
bool result = this == obj;
if (!result && obj != null && obj is ActiveMQDestination) {
ActiveMQDestination other = (ActiveMQDestination) obj;
@ -466,7 +442,7 @@ namespace OpenWire.Core
/**
* @return true if the destination matches multiple possible destinations
*/
public bool isWildcard() {
public bool IsWildcard() {
if (physicalName != null) {
return physicalName.indexOf(DestinationFilter.ANY_CHILD) >= 0
|| physicalName.indexOf(DestinationFilter.ANY_DESCENDENT) >= 0;
@ -478,9 +454,9 @@ namespace OpenWire.Core
* @param destination
* @return true if the given destination matches this destination; including wildcards
*/
public bool matches(ActiveMQDestination destination) {
public bool Matches(ActiveMQDestination destination) {
if (isWildcard()) {
return getDestinationFilter().matches(destination);
return GetDestinationFilter().matches(destination);
}
else {
return equals(destination);
@ -491,7 +467,7 @@ namespace OpenWire.Core
/**
* @return the DestinationFilter
*/
public DestinationFilter getDestinationFilter() {
public DestinationFilter GetDestinationFilter() {
if (filter == null) {
filter = DestinationFilter.parseFilter(this);
}
@ -501,29 +477,19 @@ namespace OpenWire.Core
/**
* @return the associated paths associated with this Destination
*/
public String[] getDestinationPaths() {
public String[] GetDestinationPaths() {
if (paths == null) {
paths = DestinationPath.getDestinationPaths(physicalName);
}
return paths;
}
// Implementation methods
//-------------------------------------------------------------------------
/**
* Factory method to create a child destination if this destination is a composite
* @param name
* @return the created Destination
*/
public abstract ActiveMQDestination createDestination(String name);
public abstract ActiveMQDestination CreateDestination(String name);
}

10
openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs
View File

@ -8,14 +8,16 @@ namespace OpenWire.Core
public class ActiveMQQueue : ActiveMQDestination {
public ActiveMQQueue() : base(){}
public ActiveMQQueue(String name) : base(name){}
public String getQueueName() {
return base.getPhysicalName();
public String GetQueueName() {
return base.GetPhysicalName();
}
public override int getDestinationType() {
public override int GetDestinationType() {
return ACTIVEMQ_QUEUE;
}
public override ActiveMQDestination createDestination(String name) {
public override ActiveMQDestination CreateDestination(String name) {
return new ActiveMQQueue(name);
}
}

9
openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs
View File

@ -9,17 +9,18 @@ namespace OpenWire.Core
{
public ActiveMQTopic(): base() {}
public ActiveMQTopic(String name):base(name){}
public String getTopicName()
public String GetTopicName()
{
return super.getPhysicalName();
return super.GetPhysicalName();
}
public override int getDestinationType()
public override int GetDestinationType()
{
return ACTIVEMQ_TOPIC;
}
public override ActiveMQDestination createDestination(String name)
public override ActiveMQDestination CreateDestination(String name)
{
return new ActiveMQTopic(name);
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public string PhysicalName
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs
View File

@ -22,7 +22,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -33,7 +33,6 @@ namespace OpenWire.Core.Commands
// Properties
public short CommandId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public string BrokerIdValue
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs
View File

@ -24,7 +24,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -35,7 +35,6 @@ namespace OpenWire.Core.Commands
// Properties
public BrokerId BrokerId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public string ConnectionIdValue
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -36,7 +36,6 @@ namespace OpenWire.Core.Commands
// Properties
public ConnectionId ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public string ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs
View File

@ -33,7 +33,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -44,7 +44,6 @@ namespace OpenWire.Core.Commands
// Properties
public ConsumerId ConsumerId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public string Command
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public Command[] Data
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public Command Data
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -36,7 +36,6 @@ namespace OpenWire.Core.Commands
// Properties
public ConnectionId ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public string Exception
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public int Result
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs
View File

@ -22,7 +22,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -33,7 +33,6 @@ namespace OpenWire.Core.Commands
// Properties
public ActiveMQDestination Destination
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs
View File

@ -26,7 +26,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -37,7 +37,6 @@ namespace OpenWire.Core.Commands
// Properties
public ActiveMQDestination Destination
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public string Message
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public TransactionId TransactionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs
View File

@ -22,7 +22,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -33,7 +33,6 @@ namespace OpenWire.Core.Commands
// Properties
public long TransactionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/Message.cs
View File

@ -45,7 +45,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -56,7 +56,6 @@ namespace OpenWire.Core.Commands
// Properties
public ProducerId ProducerId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs
View File

@ -27,7 +27,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -38,7 +38,6 @@ namespace OpenWire.Core.Commands
// Properties
public ActiveMQDestination Destination
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs
View File

@ -24,7 +24,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -35,7 +35,6 @@ namespace OpenWire.Core.Commands
// Properties
public ConsumerId ConsumerId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public ProducerId ProducerId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public string ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public ProducerId ProducerId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public Command ObjectId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public ConnectionId ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/Response.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public short CorrelationId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs
View File

@ -22,7 +22,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -33,7 +33,6 @@ namespace OpenWire.Core.Commands
// Properties
public string ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs
View File

@ -21,7 +21,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -32,7 +32,6 @@ namespace OpenWire.Core.Commands
// Properties
public SessionId SessionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs
View File

@ -24,7 +24,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -35,7 +35,6 @@ namespace OpenWire.Core.Commands
// Properties
public string ClientId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs
View File

@ -20,7 +20,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -31,6 +31,5 @@ namespace OpenWire.Core.Commands
// Properties
}
}

3
openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public ConnectionId ConnectionId
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public byte[] Magic
{
get

3
openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs
View File

@ -23,7 +23,7 @@ namespace OpenWire.Core.Commands
// TODO generate Equals method
// TODO generate HashCode method
// TODO generate GetHashCode method
// TODO generate ToString method
@ -34,7 +34,6 @@ namespace OpenWire.Core.Commands
// Properties
public int FormatId
{
get

1
openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs
View File

@ -1,4 +1,5 @@
using System;
using OpenWire.Core.Commands;
namespace OpenWire.Core
{

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQBytesMessageMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQBytesMessage info = (ActiveMQBytesMessage) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQBytesMessage info = (ActiveMQBytesMessage) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQDestinationMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQDestination info = (ActiveMQDestination) command;
info.setPhysicalName(dataIn.readUTF());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQDestination info = (ActiveMQDestination) command;
writeUTF(info.getPhysicalName(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMapMessageMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQMapMessage info = (ActiveMQMapMessage) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQMapMessage info = (ActiveMQMapMessage) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMessageMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQMessage info = (ActiveMQMessage) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQMessage info = (ActiveMQMessage) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQObjectMessageMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQObjectMessage info = (ActiveMQObjectMessage) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQObjectMessage info = (ActiveMQObjectMessage) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQQueueMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQQueue info = (ActiveMQQueue) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQQueue info = (ActiveMQQueue) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQStreamMessageMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQStreamMessage info = (ActiveMQStreamMessage) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQStreamMessage info = (ActiveMQStreamMessage) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQTempDestination info = (ActiveMQTempDestination) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQTempDestination info = (ActiveMQTempDestination) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempQueueMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQTempQueue info = (ActiveMQTempQueue) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQTempQueue info = (ActiveMQTempQueue) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempTopicMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQTempTopic info = (ActiveMQTempTopic) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQTempTopic info = (ActiveMQTempTopic) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTextMessageMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQTextMessage info = (ActiveMQTextMessage) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQTextMessage info = (ActiveMQTextMessage) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTopicMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ActiveMQTopic info = (ActiveMQTopic) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ActiveMQTopic info = (ActiveMQTopic) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
BaseCommand info = (BaseCommand) command;
info.setCommandId(dataIn.readShort());
info.setResponseRequired(dataIn.readBoolean());
@ -33,7 +33,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
BaseCommand info = (BaseCommand) command;
dataOut.writeShort(info.getCommandId());
dataOut.writeBoolean(info.isResponseRequired());

4
openwire-dotnet/src/OpenWire.Core/IO/BrokerIdMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
BrokerId info = (BrokerId) command;
info.setBrokerId(dataIn.readUTF());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
BrokerId info = (BrokerId) command;
writeUTF(info.getBrokerId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/BrokerInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
BrokerInfo info = (BrokerInfo) command;
info.setBrokerId((org.apache.activemq.command.BrokerId) readObject(dataIn));
info.setBrokerURL(dataIn.readUTF());
@ -35,7 +35,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
BrokerInfo info = (BrokerInfo) command;
writeObject(info.getBrokerId(), dataOut);
writeUTF(info.getBrokerURL(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ConnectionIdMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ConnectionId info = (ConnectionId) command;
info.setConnectionId(dataIn.readUTF());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ConnectionId info = (ConnectionId) command;
writeUTF(info.getConnectionId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ConnectionInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ConnectionInfo info = (ConnectionInfo) command;
info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
info.setClientId(dataIn.readUTF());
@ -36,7 +36,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ConnectionInfo info = (ConnectionInfo) command;
writeObject(info.getConnectionId(), dataOut);
writeUTF(info.getClientId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ConsumerId info = (ConsumerId) command;
info.setConnectionId(dataIn.readUTF());
info.setSessionId(dataIn.readLong());
@ -34,7 +34,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ConsumerId info = (ConsumerId) command;
writeUTF(info.getConnectionId(), dataOut);
dataOut.writeLong(info.getSessionId());

4
openwire-dotnet/src/OpenWire.Core/IO/ConsumerInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ConsumerInfo info = (ConsumerInfo) command;
info.setConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
info.setBrowser(dataIn.readBoolean());
@ -44,7 +44,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ConsumerInfo info = (ConsumerInfo) command;
writeObject(info.getConsumerId(), dataOut);
dataOut.writeBoolean(info.isBrowser());

4
openwire-dotnet/src/OpenWire.Core/IO/ControlCommandMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ControlCommand info = (ControlCommand) command;
info.setCommand(dataIn.readUTF());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ControlCommand info = (ControlCommand) command;
writeUTF(info.getCommand(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/DataArrayResponseMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
DataArrayResponse info = (DataArrayResponse) command;
info.setData((org.apache.activemq.command.DataStructure[]) readObject(dataIn));
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
DataArrayResponse info = (DataArrayResponse) command;
writeObject(info.getData(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
DataResponse info = (DataResponse) command;
info.setData((org.apache.activemq.command.DataStructure) readObject(dataIn));
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
DataResponse info = (DataResponse) command;
writeObject(info.getData(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/DestinationInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
DestinationInfo info = (DestinationInfo) command;
info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
@ -36,7 +36,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
DestinationInfo info = (DestinationInfo) command;
writeObject(info.getConnectionId(), dataOut);
writeObject(info.getDestination(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ExceptionResponse info = (ExceptionResponse) command;
info.setException((java.lang.Throwable) readObject(dataIn));
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ExceptionResponse info = (ExceptionResponse) command;
writeObject(info.getException(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/FlushCommandMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
FlushCommand info = (FlushCommand) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
FlushCommand info = (FlushCommand) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/IntegerResponseMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
IntegerResponse info = (IntegerResponse) command;
info.setResult(dataIn.readInt());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
IntegerResponse info = (IntegerResponse) command;
dataOut.writeInt(info.getResult());

4
openwire-dotnet/src/OpenWire.Core/IO/JournalQueueAckMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
JournalQueueAck info = (JournalQueueAck) command;
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
info.setMessageAck((org.apache.activemq.command.MessageAck) readObject(dataIn));
@ -33,7 +33,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
JournalQueueAck info = (JournalQueueAck) command;
writeObject(info.getDestination(), dataOut);
writeObject(info.getMessageAck(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
JournalTopicAck info = (JournalTopicAck) command;
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
info.setMessageId((org.apache.activemq.command.MessageId) readObject(dataIn));
@ -37,7 +37,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
JournalTopicAck info = (JournalTopicAck) command;
writeObject(info.getDestination(), dataOut);
writeObject(info.getMessageId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/JournalTraceMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
JournalTrace info = (JournalTrace) command;
info.setMessage(dataIn.readUTF());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
JournalTrace info = (JournalTrace) command;
writeUTF(info.getMessage(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
JournalTransaction info = (JournalTransaction) command;
info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
info.setType(dataIn.readByte());
@ -34,7 +34,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
JournalTransaction info = (JournalTransaction) command;
writeObject(info.getTransactionId(), dataOut);
dataOut.writeByte(info.getType());

4
openwire-dotnet/src/OpenWire.Core/IO/KeepAliveInfoMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
KeepAliveInfo info = (KeepAliveInfo) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
KeepAliveInfo info = (KeepAliveInfo) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/LocalTransactionIdMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
LocalTransactionId info = (LocalTransactionId) command;
info.setTransactionId(dataIn.readLong());
info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
@ -33,7 +33,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
LocalTransactionId info = (LocalTransactionId) command;
dataOut.writeLong(info.getTransactionId());
writeObject(info.getConnectionId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
MessageAck info = (MessageAck) command;
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
info.setTransactionId((org.apache.activemq.command.TransactionId) readObject(dataIn));
@ -38,7 +38,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
MessageAck info = (MessageAck) command;
writeObject(info.getDestination(), dataOut);
writeObject(info.getTransactionId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
MessageDispatch info = (MessageDispatch) command;
info.setConsumerId((org.apache.activemq.command.ConsumerId) readObject(dataIn));
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
@ -35,7 +35,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
MessageDispatch info = (MessageDispatch) command;
writeObject(info.getConsumerId(), dataOut);
writeObject(info.getDestination(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/MessageIdMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
MessageId info = (MessageId) command;
info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
info.setProducerSequenceId(dataIn.readLong());
@ -34,7 +34,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
MessageId info = (MessageId) command;
writeObject(info.getProducerId(), dataOut);
dataOut.writeLong(info.getProducerSequenceId());

4
openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
Message info = (Message) command;
info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
@ -56,7 +56,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
Message info = (Message) command;
writeObject(info.getProducerId(), dataOut);
writeObject(info.getDestination(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ProducerId info = (ProducerId) command;
info.setConnectionId(dataIn.readUTF());
info.setProducerId(dataIn.readLong());
@ -34,7 +34,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ProducerId info = (ProducerId) command;
writeUTF(info.getConnectionId(), dataOut);
dataOut.writeLong(info.getProducerId());

4
openwire-dotnet/src/OpenWire.Core/IO/ProducerInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ProducerInfo info = (ProducerInfo) command;
info.setProducerId((org.apache.activemq.command.ProducerId) readObject(dataIn));
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
@ -34,7 +34,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ProducerInfo info = (ProducerInfo) command;
writeObject(info.getProducerId(), dataOut);
writeObject(info.getDestination(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
RemoveInfo info = (RemoveInfo) command;
info.setObjectId((org.apache.activemq.command.DataStructure) readObject(dataIn));
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
RemoveInfo info = (RemoveInfo) command;
writeObject(info.getObjectId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/RemoveSubscriptionInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
RemoveSubscriptionInfo info = (RemoveSubscriptionInfo) command;
info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
info.setSubcriptionName(dataIn.readUTF());
@ -34,7 +34,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
RemoveSubscriptionInfo info = (RemoveSubscriptionInfo) command;
writeObject(info.getConnectionId(), dataOut);
writeUTF(info.getSubcriptionName(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ResponseMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
Response info = (Response) command;
info.setCorrelationId(dataIn.readShort());
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
Response info = (Response) command;
dataOut.writeShort(info.getCorrelationId());

4
openwire-dotnet/src/OpenWire.Core/IO/SessionIdMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
SessionId info = (SessionId) command;
info.setConnectionId(dataIn.readUTF());
info.setSessionId(dataIn.readLong());
@ -33,7 +33,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
SessionId info = (SessionId) command;
writeUTF(info.getConnectionId(), dataOut);
dataOut.writeLong(info.getSessionId());

4
openwire-dotnet/src/OpenWire.Core/IO/SessionInfoMarshaller.cs
View File

@ -25,14 +25,14 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
SessionInfo info = (SessionInfo) command;
info.setSessionId((org.apache.activemq.command.SessionId) readObject(dataIn));
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
SessionInfo info = (SessionInfo) command;
writeObject(info.getSessionId(), dataOut);

4
openwire-dotnet/src/OpenWire.Core/IO/ShutdownInfoMarshaller.cs
View File

@ -25,13 +25,13 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
ShutdownInfo info = (ShutdownInfo) command;
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
ShutdownInfo info = (ShutdownInfo) command;
}

4
openwire-dotnet/src/OpenWire.Core/IO/SubscriptionInfoMarshaller.cs
View File

@ -25,7 +25,7 @@ namespace OpenWire.Core.IO
}
public override void BuildCommand(Command command, BinaryReader dataIn) {
super.buildCommand(command, dataIn);
base.BuildCommand(command, dataIn);
SubscriptionInfo info = (SubscriptionInfo) command;
info.setClientId(dataIn.readUTF());
info.setDestination((org.apache.activemq.command.ActiveMQDestination) readObject(dataIn));
@ -35,7 +35,7 @@ namespace OpenWire.Core.IO
}
public override void WriteCommand(Command command, BinaryWriter dataOut) {
super.writeCommand(command, dataOut);
base.WriteCommand(command, dataOut);
SubscriptionInfo info = (SubscriptionInfo) command;
writeUTF(info.getClientId(), dataOut);
writeObject(info.getDestination(), dataOut);

Some files were not shown because too many files have changed in this diff Show More