I wish I could have commited this in smaller chunks

- Added support for the openwire loose encoding to the .NET port
- Fixed the InactivityMonitor, it was timing out conections too often and testcase for it would fail intermitently
- Improved the wire format option negociation phase.  
   - We now gaurd to sending the WireformatInfo, so it's only sent once even if the start method is called multiple times.  
   - We now wait for the WireFormatInfo to be sent before reconfiguring the WireFormat with the new negociated options
   - Option negociation is now simpler to understand:
     - The WireFormatInfo is allways sent with all options turned off
     - Once WireFormatInfo's are exchanged, we enable the options on the WireFormat that both sides enabled.
 



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384390 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-03-09 00:41:39 +00:00
parent cbd5960e5a
commit 6583ef1821
252 changed files with 12880 additions and 1182 deletions

View File

@ -39,6 +39,9 @@ public abstract class OpenWireCSharpMarshallingScript extends OpenWireJavaMarsha
return super.run(); return super.run();
} }
//////////////////////////////////////////////////////////////////////////////////////
// This section is for the tight wire format encoding generator
//////////////////////////////////////////////////////////////////////////////////////
protected void generateTightUnmarshalBodyForProperty(PrintWriter out, JProperty property, JAnnotationValue size) { protected void generateTightUnmarshalBodyForProperty(PrintWriter out, JProperty property, JAnnotationValue size) {
@ -242,4 +245,149 @@ public abstract class OpenWireCSharpMarshallingScript extends OpenWireJavaMarsha
} }
} }
} }
//////////////////////////////////////////////////////////////////////////////////////
// This section is for the loose wire format encoding generator
//////////////////////////////////////////////////////////////////////////////////////
protected void generateLooseUnmarshalBodyForProperty(PrintWriter out, JProperty property, JAnnotationValue size) {
String propertyName = property.getSimpleName();
String type = property.getType().getSimpleName();
if (type.equals("boolean")) {
out.println(" info." + propertyName + " = dataIn.ReadBoolean();");
}
else if (type.equals("byte")) {
out.println(" info." + propertyName + " = dataIn.ReadByte();");
}
else if (type.equals("char")) {
out.println(" info." + propertyName + " = dataIn.ReadChar();");
}
else if (type.equals("short")) {
out.println(" info." + propertyName + " = dataIn.ReadInt16();");
}
else if (type.equals("int")) {
out.println(" info." + propertyName + " = dataIn.ReadInt32();");
}
else if (type.equals("long")) {
out.println(" info." + propertyName + " = LooseUnmarshalLong(wireFormat, dataIn);");
}
else if (type.equals("String")) {
out.println(" info." + propertyName + " = LooseUnmarshalString(dataIn);");
}
else if (type.equals("byte[]") || type.equals("ByteSequence")) {
if (size != null) {
out.println(" info." + propertyName + " = ReadBytes(dataIn, " + size.asInt() + ");");
}
else {
out.println(" info." + propertyName + " = ReadBytes(dataIn, dataIn.ReadBoolean());");
}
}
else if (isThrowable(property.getType())) {
out.println(" info." + propertyName + " = LooseUnmarshalBrokerError(wireFormat, dataIn);");
}
else if (isCachedProperty(property)) {
out.println(" info." + propertyName + " = (" + type + ") LooseUnmarshalCachedObject(wireFormat, dataIn);");
}
else {
out.println(" info." + propertyName + " = (" + type + ") LooseUnmarshalNestedObject(wireFormat, dataIn);");
}
}
protected void generateLooseUnmarshalBodyForArrayProperty(PrintWriter out, JProperty property, JAnnotationValue size) {
JClass propertyType = property.getType();
String arrayType = propertyType.getArrayComponentType().getSimpleName();
String propertyName = property.getSimpleName();
out.println();
if (size != null) {
out.println(" {");
out.println(" " + arrayType + "[] value = new " + arrayType + "[" + size.asInt() + "];");
out.println(" " + "for( int i=0; i < " + size.asInt() + "; i++ ) {");
out.println(" value[i] = (" + arrayType + ") LooseUnmarshalNestedObject(wireFormat,dataIn);");
out.println(" }");
out.println(" info." + propertyName + " = value;");
out.println(" }");
}
else {
out.println(" if (dataIn.ReadBoolean()) {");
out.println(" short size = dataIn.ReadInt16();");
out.println(" " + arrayType + "[] value = new " + arrayType + "[size];");
out.println(" for( int i=0; i < size; i++ ) {");
out.println(" value[i] = (" + arrayType + ") LooseUnmarshalNestedObject(wireFormat,dataIn);");
out.println(" }");
out.println(" info." + propertyName + " = value;");
out.println(" }");
out.println(" else {");
out.println(" info." + propertyName + " = null;");
out.println(" }");
}
}
protected void generateLooseMarshalBody(PrintWriter out) {
List properties = getProperties();
for (Iterator iter = properties.iterator(); iter.hasNext();) {
JProperty property = (JProperty) iter.next();
JAnnotation annotation = property.getAnnotation("openwire:property");
JAnnotationValue size = annotation.getValue("size");
JClass propertyType = property.getType();
String type = propertyType.getSimpleName();
String getter = "info." + property.getSimpleName();
if (type.equals("boolean")) {
out.println(" dataOut.Write(" + getter + ");");
}
else if (type.equals("byte")) {
out.println(" dataOut.Write(" + getter + ");");
}
else if (type.equals("char")) {
out.println(" dataOut.Write(" + getter + ");");
}
else if (type.equals("short")) {
out.println(" dataOut.Write(" + getter + ");");
}
else if (type.equals("int")) {
out.println(" dataOut.Write(" + getter + ");");
}
else if (type.equals("long")) {
out.println(" LooseMarshalLong(wireFormat, " + getter + ", dataOut);");
}
else if (type.equals("String")) {
out.println(" LooseMarshalString(" + getter + ", dataOut);");
}
else if (type.equals("byte[]") || type.equals("ByteSequence")) {
if (size != null) {
out.println(" dataOut.Write(" + getter + ", 0, " + size.asInt() + ");");
}
else {
out.println(" dataOut.Write(" + getter + "!=null);");
out.println(" if(" + getter + "!=null) {");
out.println(" dataOut.Write(" + getter + ".Length);");
out.println(" dataOut.Write(" + getter + ");");
out.println(" }");
}
}
else if (propertyType.isArrayType()) {
if (size != null) {
out.println(" LooseMarshalObjectArrayConstSize(wireFormat, " + getter + ", dataOut, " + size.asInt() + ");");
}
else {
out.println(" LooseMarshalObjectArray(wireFormat, " + getter + ", dataOut);");
}
}
else if (isThrowable(propertyType)) {
out.println(" LooseMarshalBrokerError(wireFormat, " + getter + ", dataOut);");
}
else {
if (isCachedProperty(property)) {
out.println(" LooseMarshalCachedObject(wireFormat, (DataStructure)" + getter + ", dataOut);");
}
else {
out.println(" LooseMarshalNestedObject(wireFormat, (DataStructure)" + getter + ", dataOut);");
}
}
}
}
} }

View File

@ -76,6 +76,9 @@ if( !abstractClass ) out << """
} }
""" """
/*
* Generate the tight encoding marshallers
*/
out << """ out << """
// //
// Un-marshal an object instance from the data input stream // Un-marshal an object instance from the data input stream
@ -102,8 +105,9 @@ if( marshallerAware ) out << """
out << """ out << """
} }
"""
out << """
// //
// Write the booleans that this object uses to a BooleanStream // Write the booleans that this object uses to a BooleanStream
// //
@ -144,6 +148,69 @@ if( marshallerAware ) out << """
out << """ out << """
} }
"""
/*
* Generate the loose encoding marshallers
*/
out << """
//
// Un-marshal an object instance from the data input stream
//
public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn)
{
base.LooseUnmarshal(wireFormat, o, dataIn);
"""
if( !properties.isEmpty() || marshallerAware ) out << """
${jclass.simpleName} info = (${jclass.simpleName})o;
"""
if( marshallerAware ) out << """
info.BeforeUnmarshall(wireFormat);
"""
generateLooseUnmarshalBody(out)
if( marshallerAware ) out << """
info.AfterUnmarshall(wireFormat);
"""
out << """
}
"""
out << """
//
// Write a object instance to data output stream
//
public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) {
"""
if( !properties.isEmpty() || marshallerAware ) out << """
${jclass.simpleName} info = (${jclass.simpleName})o;
"""
if( marshallerAware ) out << """
info.BeforeMarshall(wireFormat);
"""
out << """
base.LooseMarshal(wireFormat, o, dataOut);
"""
generateLooseMarshalBody(out)
if( marshallerAware ) out << """
info.AfterMarshall(wireFormat);
"""
out << """
}
"""
out << """
} }
} }
""" """

View File

@ -29,7 +29,6 @@ import org.activeio.ByteArrayOutputStream;
import org.activeio.ByteSequence; import org.activeio.ByteSequence;
import org.activeio.command.WireFormat; import org.activeio.command.WireFormat;
import org.apache.activemq.state.CommandVisitor; import org.apache.activemq.state.CommandVisitor;
import org.apache.activemq.util.IntrospectionSupport;
import org.apache.activemq.util.MarshallingSupport; import org.apache.activemq.util.MarshallingSupport;
/** /**
@ -39,6 +38,7 @@ import org.apache.activemq.util.MarshallingSupport;
*/ */
public class WireFormatInfo implements Command, MarshallAware { public class WireFormatInfo implements Command, MarshallAware {
private static final int MAX_PROPERTY_SIZE = 1024*4;
public static final byte DATA_STRUCTURE_TYPE = CommandTypes.WIREFORMAT_INFO; public static final byte DATA_STRUCTURE_TYPE = CommandTypes.WIREFORMAT_INFO;
static final private byte MAGIC[] = new byte[] { 'A', 'c', 't', 'i', 'v', 'e', 'M', 'Q' }; static final private byte MAGIC[] = new byte[] { 'A', 'c', 't', 'i', 'v', 'e', 'M', 'Q' };
@ -136,7 +136,7 @@ public class WireFormatInfo implements Command, MarshallAware {
} }
private HashMap unmarsallProperties(ByteSequence marshalledProperties) throws IOException { private HashMap unmarsallProperties(ByteSequence marshalledProperties) throws IOException {
return MarshallingSupport.unmarshalPrimitiveMap(new DataInputStream(new ByteArrayInputStream(marshalledProperties))); return MarshallingSupport.unmarshalPrimitiveMap(new DataInputStream(new ByteArrayInputStream(marshalledProperties)), MAX_PROPERTY_SIZE);
} }
public void beforeMarshall(WireFormat wireFormat) throws IOException { public void beforeMarshall(WireFormat wireFormat) throws IOException {
@ -171,50 +171,50 @@ public class WireFormatInfo implements Command, MarshallAware {
* @throws IOException * @throws IOException
*/ */
public boolean isCacheEnabled() throws IOException { public boolean isCacheEnabled() throws IOException {
return Boolean.TRUE == getProperty("cache"); return Boolean.TRUE == getProperty("CacheEnabled");
} }
public void setCacheEnabled(boolean cacheEnabled) throws IOException { public void setCacheEnabled(boolean cacheEnabled) throws IOException {
setProperty("cache", cacheEnabled ? Boolean.TRUE : Boolean.FALSE); setProperty("CacheEnabled", cacheEnabled ? Boolean.TRUE : Boolean.FALSE);
} }
/** /**
* @throws IOException * @throws IOException
*/ */
public boolean isStackTraceEnabled() throws IOException { public boolean isStackTraceEnabled() throws IOException {
return Boolean.TRUE == getProperty("stackTrace"); return Boolean.TRUE == getProperty("StackTraceEnabled");
} }
public void setStackTraceEnabled(boolean stackTraceEnabled) throws IOException { public void setStackTraceEnabled(boolean stackTraceEnabled) throws IOException {
setProperty("stackTrace", stackTraceEnabled ? Boolean.TRUE : Boolean.FALSE); setProperty("StackTraceEnabled", stackTraceEnabled ? Boolean.TRUE : Boolean.FALSE);
} }
/** /**
* @throws IOException * @throws IOException
*/ */
public boolean isTcpNoDelayEnabled() throws IOException { public boolean isTcpNoDelayEnabled() throws IOException {
return Boolean.TRUE == getProperty("tcpNoDelay"); return Boolean.TRUE == getProperty("TcpNoDelayEnabled");
} }
public void setTcpNoDelayEnabled(boolean tcpNoDelayEnabled) throws IOException { public void setTcpNoDelayEnabled(boolean tcpNoDelayEnabled) throws IOException {
setProperty("tcpNoDelay", tcpNoDelayEnabled ? Boolean.TRUE : Boolean.FALSE); setProperty("TcpNoDelayEnabled", tcpNoDelayEnabled ? Boolean.TRUE : Boolean.FALSE);
} }
/** /**
* @throws IOException * @throws IOException
*/ */
public boolean isPrefixPacketSize() throws IOException { public boolean isSizePrefixDisabled() throws IOException {
return Boolean.TRUE == getProperty("prefixPacketSize"); return Boolean.TRUE == getProperty("SizePrefixDisabled");
} }
public void setPrefixPacketSize(boolean prefixPacketSize) throws IOException { public void setSizePrefixDisabled(boolean prefixPacketSize) throws IOException {
setProperty("prefixPacketSize", prefixPacketSize ? Boolean.TRUE : Boolean.FALSE); setProperty("SizePrefixDisabled", prefixPacketSize ? Boolean.TRUE : Boolean.FALSE);
} }
/** /**
* @throws IOException * @throws IOException
*/ */
public boolean isTightEncodingEnabled() throws IOException { public boolean isTightEncodingEnabled() throws IOException {
return Boolean.TRUE == getProperty("tightEncoding"); return Boolean.TRUE == getProperty("TightEncodingEnabled");
} }
public void setTightEncodingEnabled(boolean tightEncodingEnabled) throws IOException { public void setTightEncodingEnabled(boolean tightEncodingEnabled) throws IOException {
setProperty("tightEncoding", tightEncodingEnabled ? Boolean.TRUE : Boolean.FALSE); setProperty("TightEncodingEnabled", tightEncodingEnabled ? Boolean.TRUE : Boolean.FALSE);
} }
public Response visit(CommandVisitor visitor) throws Exception { public Response visit(CommandVisitor visitor) throws Exception {
@ -222,7 +222,12 @@ public class WireFormatInfo implements Command, MarshallAware {
} }
public String toString() { public String toString() {
return IntrospectionSupport.toString(this, WireFormatInfo.class); Map p=null;
try {
p = getProperties();
} catch (IOException e) {
}
return "WireFormatInfo { version="+version+", properties="+p+", magic="+Arrays.toString(magic)+"}";
} }
/////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////

View File

@ -33,6 +33,8 @@ import org.activeio.packet.ByteArrayPacket;
import org.apache.activemq.command.CommandTypes; import org.apache.activemq.command.CommandTypes;
import org.apache.activemq.command.DataStructure; import org.apache.activemq.command.DataStructure;
import org.apache.activemq.command.MarshallAware; import org.apache.activemq.command.MarshallAware;
import org.apache.activemq.command.WireFormatInfo;
import org.apache.activemq.util.IdGenerator;
/** /**
* *
@ -46,11 +48,11 @@ final public class OpenWireFormat implements WireFormat {
private DataStreamMarshaller dataMarshallers[]; private DataStreamMarshaller dataMarshallers[];
private int version; private int version;
private boolean stackTraceEnabled=true; private boolean stackTraceEnabled=false;
private boolean tcpNoDelayEnabled=false; private boolean tcpNoDelayEnabled=false;
private boolean cacheEnabled=true; private boolean cacheEnabled=false;
private boolean tightEncodingEnabled=true; private boolean tightEncodingEnabled=false;
private boolean prefixPacketSize=true; private boolean sizePrefixDisabled=false;
private HashMap marshallCacheMap = new HashMap(); private HashMap marshallCacheMap = new HashMap();
private short nextMarshallCacheIndex=0; private short nextMarshallCacheIndex=0;
@ -58,14 +60,14 @@ final public class OpenWireFormat implements WireFormat {
private DataStructure marshallCache[] = new DataStructure[MARSHAL_CACHE_SIZE]; private DataStructure marshallCache[] = new DataStructure[MARSHAL_CACHE_SIZE];
private DataStructure unmarshallCache[] = new DataStructure[MARSHAL_CACHE_SIZE]; private DataStructure unmarshallCache[] = new DataStructure[MARSHAL_CACHE_SIZE];
private WireFormatInfo preferedWireFormatInfo;
public OpenWireFormat() { public OpenWireFormat() {
this(true); this(1);
} }
public OpenWireFormat(boolean cacheEnabled) { public OpenWireFormat(int i) {
setVersion(1); setVersion(i);
setCacheEnabled(cacheEnabled);
} }
public int hashCode() { public int hashCode() {
@ -73,7 +75,7 @@ final public class OpenWireFormat implements WireFormat {
^ (cacheEnabled ? 0x10000000:0x20000000) ^ (cacheEnabled ? 0x10000000:0x20000000)
^ (stackTraceEnabled ? 0x01000000:0x02000000) ^ (stackTraceEnabled ? 0x01000000:0x02000000)
^ (tightEncodingEnabled ? 0x00100000:0x00200000) ^ (tightEncodingEnabled ? 0x00100000:0x00200000)
^ (prefixPacketSize ? 0x00010000:0x00020000) ^ (sizePrefixDisabled ? 0x00010000:0x00020000)
; ;
} }
@ -85,12 +87,15 @@ final public class OpenWireFormat implements WireFormat {
o.cacheEnabled == cacheEnabled && o.cacheEnabled == cacheEnabled &&
o.version == version && o.version == version &&
o.tightEncodingEnabled == tightEncodingEnabled && o.tightEncodingEnabled == tightEncodingEnabled &&
o.prefixPacketSize == prefixPacketSize o.sizePrefixDisabled == sizePrefixDisabled
; ;
} }
static IdGenerator g = new IdGenerator();
String id = g.generateId();
public String toString() { public String toString() {
return "OpenWireFormat{version="+version+", cacheEnabled="+cacheEnabled+", stackTraceEnabled="+stackTraceEnabled+", tightEncodingEnabled="+tightEncodingEnabled+", prefixPacketSize="+prefixPacketSize+"}"; //return "OpenWireFormat{version="+version+", cacheEnabled="+cacheEnabled+", stackTraceEnabled="+stackTraceEnabled+", tightEncodingEnabled="+tightEncodingEnabled+", sizePrefixDisabled="+sizePrefixDisabled+"}";
return "OpenWireFormat{id="+id+", tightEncodingEnabled="+tightEncodingEnabled+"}";
} }
public int getVersion() { public int getVersion() {
@ -133,7 +138,7 @@ final public class OpenWireFormat implements WireFormat {
ByteArrayOutputStream baos = new ByteArrayOutputStream(size); ByteArrayOutputStream baos = new ByteArrayOutputStream(size);
DataOutputStream ds = new DataOutputStream(baos); DataOutputStream ds = new DataOutputStream(baos);
if( prefixPacketSize ) { if( !sizePrefixDisabled ) {
ds.writeInt(size); ds.writeInt(size);
} }
ds.writeByte(type); ds.writeByte(type);
@ -144,9 +149,9 @@ final public class OpenWireFormat implements WireFormat {
} else { } else {
ByteArrayOutputStream baos = new ByteArrayOutputStream(size); ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream ds = new DataOutputStream(baos); DataOutputStream ds = new DataOutputStream(baos);
if( prefixPacketSize ) { if( !sizePrefixDisabled ) {
ds.writeInt(0); // we don't know the final size yet but write this here for now. ds.writeInt(0); // we don't know the final size yet but write this here for now.
} }
ds.writeByte(type); ds.writeByte(type);
@ -154,7 +159,7 @@ final public class OpenWireFormat implements WireFormat {
ds.close(); ds.close();
sequence = baos.toByteSequence(); sequence = baos.toByteSequence();
if( prefixPacketSize ) { if( !sizePrefixDisabled ) {
size = sequence.getLength()-4; size = sequence.getLength()-4;
ByteArrayPacket packet = new ByteArrayPacket(sequence); ByteArrayPacket packet = new ByteArrayPacket(sequence);
PacketData.writeIntBig(packet, size); PacketData.writeIntBig(packet, size);
@ -183,12 +188,12 @@ final public class OpenWireFormat implements WireFormat {
ByteSequence sequence = packet.asByteSequence(); ByteSequence sequence = packet.asByteSequence();
DataInputStream dis = new DataInputStream(new PacketToInputStream(packet)); DataInputStream dis = new DataInputStream(new PacketToInputStream(packet));
if( prefixPacketSize ) { if( !sizePrefixDisabled ) {
int size = dis.readInt(); int size = dis.readInt();
if( sequence.getLength()-4 != size ) if( sequence.getLength()-4 != size ) {
System.out.println("Packet size does not match marshaled size: "+size+", "+(sequence.getLength()-4));
// throw new IOException("Packet size does not match marshaled size"); // throw new IOException("Packet size does not match marshaled size");
} }
}
Object command = doUnmarshal(dis); Object command = doUnmarshal(dis);
if( !cacheEnabled && ((DataStructure)command).isMarshallAware() ) { if( !cacheEnabled && ((DataStructure)command).isMarshallAware() ) {
@ -197,7 +202,7 @@ final public class OpenWireFormat implements WireFormat {
return command; return command;
} }
public void marshal(Object o, DataOutputStream ds) throws IOException { public void marshal(Object o, DataOutputStream dataOut) throws IOException {
if( cacheEnabled ) { if( cacheEnabled ) {
runMarshallCacheEvictionSweep(); runMarshallCacheEvictionSweep();
@ -205,28 +210,53 @@ final public class OpenWireFormat implements WireFormat {
int size=1; int size=1;
if( o != null) { if( o != null) {
DataStructure c = (DataStructure) o; DataStructure c = (DataStructure) o;
byte type = c.getDataStructureType(); byte type = c.getDataStructureType();
DataStreamMarshaller dsm = (DataStreamMarshaller) dataMarshallers[type & 0xFF]; DataStreamMarshaller dsm = (DataStreamMarshaller) dataMarshallers[type & 0xFF];
if( dsm == null ) if( dsm == null )
throw new IOException("Unknown data type: "+type); throw new IOException("Unknown data type: "+type);
if( tightEncodingEnabled ) {
BooleanStream bs = new BooleanStream(); BooleanStream bs = new BooleanStream();
size += dsm.tightMarshal1(this, c, bs); size += dsm.tightMarshal1(this, c, bs);
size += bs.marshalledSize(); size += bs.marshalledSize();
ds.writeInt(size); dataOut.writeInt(size);
ds.writeByte(type); dataOut.writeByte(type);
bs.marshal(ds); bs.marshal(dataOut);
dsm.tightMarshal2(this, c, ds, bs); dsm.tightMarshal2(this, c, dataOut, bs);
} else { } else {
ds.writeInt(size); DataOutputStream looseOut = dataOut;
ds.writeByte(NULL_TYPE); ByteArrayOutputStream baos=null;
if( !sizePrefixDisabled ) {
baos = new ByteArrayOutputStream();
looseOut = new DataOutputStream(baos);
}
looseOut.writeByte(type);
dsm.looseMarshal(this, c, looseOut);
if( !sizePrefixDisabled ) {
looseOut.close();
ByteSequence sequence = baos.toByteSequence();
dataOut.writeInt(sequence.getLength()-4);
dataOut.write(sequence.getData(), sequence.getOffset(), sequence.getLength());
}
}
} else {
dataOut.writeInt(size);
dataOut.writeByte(NULL_TYPE);
} }
} }
public Object unmarshal(DataInputStream dis) throws IOException { public Object unmarshal(DataInputStream dis) throws IOException {
if( !sizePrefixDisabled ) {
dis.readInt(); dis.readInt();
}
return doUnmarshal(dis); return doUnmarshal(dis);
} }
@ -310,7 +340,10 @@ final public class OpenWireFormat implements WireFormat {
return null; return null;
} }
} }
// public void debug(String msg) {
// String t = (Thread.currentThread().getName()+" ").substring(0, 40);
// System.out.println(t+": "+msg);
// }
public int tightMarshalNestedObject1(DataStructure o, BooleanStream bs) throws IOException { public int tightMarshalNestedObject1(DataStructure o, BooleanStream bs) throws IOException {
bs.writeBoolean(o != null); bs.writeBoolean(o != null);
if( o == null ) if( o == null )
@ -496,12 +529,33 @@ final public class OpenWireFormat implements WireFormat {
this.tightEncodingEnabled = tightEncodingEnabled; this.tightEncodingEnabled = tightEncodingEnabled;
} }
public boolean isPrefixPacketSize() { public boolean isSizePrefixDisabled() {
return prefixPacketSize; return sizePrefixDisabled;
} }
public void setPrefixPacketSize(boolean prefixPacketSize) { public void setSizePrefixDisabled(boolean prefixPacketSize) {
this.prefixPacketSize = prefixPacketSize; this.sizePrefixDisabled = prefixPacketSize;
}
public void setPreferedWireFormatInfo(WireFormatInfo info) {
this.preferedWireFormatInfo = info;
}
public WireFormatInfo getPreferedWireFormatInfo() {
return preferedWireFormatInfo;
}
public void renegociatWireFormat(WireFormatInfo info) throws IOException {
if( preferedWireFormatInfo==null )
throw new IllegalStateException("Wireformat cannot not be renegociated.");
this.setVersion(Math.max(preferedWireFormatInfo.getVersion(), info.getVersion()) );
this.stackTraceEnabled = info.isStackTraceEnabled() && preferedWireFormatInfo.isStackTraceEnabled();
this.tcpNoDelayEnabled = info.isTcpNoDelayEnabled() && preferedWireFormatInfo.isTcpNoDelayEnabled();
this.cacheEnabled = info.isCacheEnabled() && preferedWireFormatInfo.isCacheEnabled();
this.tightEncodingEnabled = info.isTightEncodingEnabled() && preferedWireFormatInfo.isTightEncodingEnabled();
this.sizePrefixDisabled = info.isSizePrefixDisabled() && preferedWireFormatInfo.isSizePrefixDisabled();
} }
} }

View File

@ -18,28 +18,41 @@ package org.apache.activemq.openwire;
import org.activeio.command.WireFormat; import org.activeio.command.WireFormat;
import org.activeio.command.WireFormatFactory; import org.activeio.command.WireFormatFactory;
import org.apache.activemq.command.WireFormatInfo;
/** /**
* @version $Revision$ * @version $Revision$
*/ */
public class OpenWireFormatFactory implements WireFormatFactory { public class OpenWireFormatFactory implements WireFormatFactory {
//
// The default values here are what the wireformat chanages to after a default negociation.
//
private int version=1; private int version=1;
private boolean stackTraceEnabled=true; private boolean stackTraceEnabled=true;
private boolean tcpNoDelayEnabled=false; private boolean tcpNoDelayEnabled=true;
private boolean cacheEnabled=true; private boolean cacheEnabled=true;
private boolean tightEncodingEnabled=true; private boolean tightEncodingEnabled=true;
private boolean prefixPacketSize=true; private boolean sizePrefixDisabled=false;
public WireFormat createWireFormat() { public WireFormat createWireFormat() {
OpenWireFormat format = new OpenWireFormat(); WireFormatInfo info = new WireFormatInfo();
format.setVersion(version); info.setVersion(version);
format.setStackTraceEnabled(stackTraceEnabled);
format.setCacheEnabled(cacheEnabled); try {
format.setTcpNoDelayEnabled(tcpNoDelayEnabled); info.setStackTraceEnabled(stackTraceEnabled);
format.setTightEncodingEnabled(tightEncodingEnabled); info.setCacheEnabled(cacheEnabled);
format.setPrefixPacketSize(prefixPacketSize); info.setTcpNoDelayEnabled(tcpNoDelayEnabled);
return format; info.setTightEncodingEnabled(tightEncodingEnabled);
info.setSizePrefixDisabled(sizePrefixDisabled);
} catch (Exception e) {
throw new IllegalStateException("Could not configure WireFormatInfo", e);
}
OpenWireFormat f = new OpenWireFormat();
f.setPreferedWireFormatInfo(info);
return f;
} }
public boolean isStackTraceEnabled() { public boolean isStackTraceEnabled() {
@ -82,11 +95,11 @@ public class OpenWireFormatFactory implements WireFormatFactory {
this.tightEncodingEnabled = tightEncodingEnabled; this.tightEncodingEnabled = tightEncodingEnabled;
} }
public boolean isPrefixPacketSize() { public boolean isSizePrefixDisabled() {
return prefixPacketSize; return sizePrefixDisabled;
} }
public void setPrefixPacketSize(boolean prefixPacketSize) { public void setSizePrefixDisabled(boolean sizePrefixDisabled) {
this.prefixPacketSize = prefixPacketSize; this.sizePrefixDisabled = sizePrefixDisabled;
} }
} }

View File

@ -1 +1,132 @@
/** * * Copyright 2005-2006 The Apache Software Foundation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.openwire.v1; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import org.apache.activemq.openwire.*; import org.apache.activemq.command.*; /** * Marshalling code for Open Wire Format for NetworkBridgeFilterMarshaller * * * NOTE!: This file is auto generated - do not modify! * if you need to make a change, please see the modify the groovy scripts in the * under src/gram/script and then use maven openwire:generate to regenerate * this file. * * @version $Revision$ */ public class NetworkBridgeFilterMarshaller extends BaseDataStreamMarshaller { /** * Return the type of Data Structure we marshal * @return short representation of the type data structure */ public byte getDataStructureType() { return NetworkBridgeFilter.DATA_STRUCTURE_TYPE; } /** * @return a new object instance */ public DataStructure createObject() { return new NetworkBridgeFilter(); } /** * Un-marshal an object instance from the data input stream * * @param o the object to un-marshal * @param dataIn the data input stream to build the object from * @throws IOException */ public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); NetworkBridgeFilter info = (NetworkBridgeFilter)o; info.setNetworkTTL(dataIn.readInt()); info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); } /** * Write the booleans that this object uses to a BooleanStream */ public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { NetworkBridgeFilter info = (NetworkBridgeFilter)o; int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getNetworkBrokerId(), bs); return rc + 4; } /** * Write a object instance to data output stream * * @param o the instance to be marshaled * @param dataOut the output stream * @throws IOException thrown if an error occurs */ public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); NetworkBridgeFilter info = (NetworkBridgeFilter)o; dataOut.writeInt(info.getNetworkTTL()); tightMarshalCachedObject2(wireFormat, (DataStructure)info.getNetworkBrokerId(), dataOut, bs); } /** * Un-marshal an object instance from the data input stream * * @param o the object to un-marshal * @param dataIn the data input stream to build the object from * @throws IOException */ public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); NetworkBridgeFilter info = (NetworkBridgeFilter)o; info.setNetworkTTL(dataIn.readInt()); info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) looseUnmarsalCachedObject(wireFormat, dataIn)); } /** * Write the booleans that this object uses to a BooleanStream */ public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut) throws IOException { NetworkBridgeFilter info = (NetworkBridgeFilter)o; super.looseMarshal(wireFormat, o, dataOut); dataOut.writeInt(info.getNetworkTTL()); looseMarshalCachedObject(wireFormat, (DataStructure)info.getNetworkBrokerId(), dataOut); } } /**
*
* Copyright 2005-2006 The Apache Software Foundation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.activemq.openwire.v1;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/**
* Marshalling code for Open Wire Format for NetworkBridgeFilterMarshaller
*
*
* NOTE!: This file is auto generated - do not modify!
* if you need to make a change, please see the modify the groovy scripts in the
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
* @version $Revision$
*/
public class NetworkBridgeFilterMarshaller extends BaseDataStreamMarshaller {
/**
* Return the type of Data Structure we marshal
* @return short representation of the type data structure
*/
public byte getDataStructureType() {
return NetworkBridgeFilter.DATA_STRUCTURE_TYPE;
}
/**
* @return a new object instance
*/
public DataStructure createObject() {
return new NetworkBridgeFilter();
}
/**
* Un-marshal an object instance from the data input stream
*
* @param o the object to un-marshal
* @param dataIn the data input stream to build the object from
* @throws IOException
*/
public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn, BooleanStream bs) throws IOException {
super.tightUnmarshal(wireFormat, o, dataIn, bs);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
info.setNetworkTTL(dataIn.readInt());
info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
}
/**
* Write the booleans that this object uses to a BooleanStream
*/
public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException {
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
int rc = super.tightMarshal1(wireFormat, o, bs);
rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getNetworkBrokerId(), bs);
return rc + 4;
}
/**
* Write a object instance to data output stream
*
* @param o the instance to be marshaled
* @param dataOut the output stream
* @throws IOException thrown if an error occurs
*/
public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut, BooleanStream bs) throws IOException {
super.tightMarshal2(wireFormat, o, dataOut, bs);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
dataOut.writeInt(info.getNetworkTTL());
tightMarshalCachedObject2(wireFormat, (DataStructure)info.getNetworkBrokerId(), dataOut, bs);
}
/**
* Un-marshal an object instance from the data input stream
*
* @param o the object to un-marshal
* @param dataIn the data input stream to build the object from
* @throws IOException
*/
public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInputStream dataIn) throws IOException {
super.looseUnmarshal(wireFormat, o, dataIn);
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
info.setNetworkTTL(dataIn.readInt());
info.setNetworkBrokerId((org.apache.activemq.command.BrokerId) looseUnmarsalCachedObject(wireFormat, dataIn));
}
/**
* Write the booleans that this object uses to a BooleanStream
*/
public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutputStream dataOut) throws IOException {
NetworkBridgeFilter info = (NetworkBridgeFilter)o;
super.looseMarshal(wireFormat, o, dataOut);
dataOut.writeInt(info.getNetworkTTL());
looseMarshalCachedObject(wireFormat, (DataStructure)info.getNetworkBrokerId(), dataOut);
}
}

View File

@ -61,7 +61,7 @@ public class JDBCPersistenceAdapter implements PersistenceAdapter {
private static final Log log = LogFactory.getLog(JDBCPersistenceAdapter.class); private static final Log log = LogFactory.getLog(JDBCPersistenceAdapter.class);
private static FactoryFinder factoryFinder = new FactoryFinder("META-INF/services/org/apache/activemq/store/jdbc/"); private static FactoryFinder factoryFinder = new FactoryFinder("META-INF/services/org/apache/activemq/store/jdbc/");
private WireFormat wireFormat = new OpenWireFormat(false); private WireFormat wireFormat = new OpenWireFormat();
private DataSource dataSource; private DataSource dataSource;
private Statements statements; private Statements statements;
private JDBCAdapter adapter; private JDBCAdapter adapter;

View File

@ -82,7 +82,7 @@ public class JournalPersistenceAdapter implements PersistenceAdapter, JournalEve
private final PersistenceAdapter longTermPersistence; private final PersistenceAdapter longTermPersistence;
final UsageManager usageManager; final UsageManager usageManager;
private final WireFormat wireFormat = new OpenWireFormat(false); private final WireFormat wireFormat = new OpenWireFormat();
private final ConcurrentHashMap queues = new ConcurrentHashMap(); private final ConcurrentHashMap queues = new ConcurrentHashMap();
private final ConcurrentHashMap topics = new ConcurrentHashMap(); private final ConcurrentHashMap topics = new ConcurrentHashMap();

View File

@ -82,7 +82,7 @@ public class QuickJournalPersistenceAdapter implements PersistenceAdapter, Journ
private final PersistenceAdapter longTermPersistence; private final PersistenceAdapter longTermPersistence;
final UsageManager usageManager; final UsageManager usageManager;
private final WireFormat wireFormat = new OpenWireFormat(false); private final WireFormat wireFormat = new OpenWireFormat();
private final ConcurrentHashMap queues = new ConcurrentHashMap(); private final ConcurrentHashMap queues = new ConcurrentHashMap();
private final ConcurrentHashMap topics = new ConcurrentHashMap(); private final ConcurrentHashMap topics = new ConcurrentHashMap();

View File

@ -64,6 +64,7 @@ public class InactivityMonitor extends TransportFilter implements Runnable {
case 0: case 0:
writeCheck(); writeCheck();
readCheckIteration++; readCheckIteration++;
break;
case 1: case 1:
readCheck(); readCheck();
writeCheck(); writeCheck();
@ -100,10 +101,10 @@ public class InactivityMonitor extends TransportFilter implements Runnable {
} }
if( !commandReceived.get() ) { if( !commandReceived.get() ) {
log.debug("No message received since last read check!"); log.debug("No message received since last read check! ");
onException(new InactivityIOException("Channel was inactive for too long.")); onException(new InactivityIOException("Channel was inactive for too long."));
} else { } else {
log.debug("Message received since last read check, resetting flag"); log.debug("Message received since last read check, resetting flag: ");
} }
commandReceived.set(false); commandReceived.set(false);

View File

@ -19,7 +19,6 @@ package org.apache.activemq.transport;
import java.io.IOException; import java.io.IOException;
import java.io.InterruptedIOException; import java.io.InterruptedIOException;
import org.activeio.command.WireFormat;
import org.apache.activemq.command.Command; import org.apache.activemq.command.Command;
import org.apache.activemq.command.WireFormatInfo; import org.apache.activemq.command.WireFormatInfo;
import org.apache.activemq.openwire.OpenWireFormat; import org.apache.activemq.openwire.OpenWireFormat;
@ -27,17 +26,19 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch; import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
public class WireFormatNegotiator extends TransportFilter { public class WireFormatNegotiator extends TransportFilter {
private static final Log log = LogFactory.getLog(WireFormatNegotiator.class); private static final Log log = LogFactory.getLog(WireFormatNegotiator.class);
private final WireFormat wireFormat; private OpenWireFormat wireFormat;
private final int minimumVersion; private final int minimumVersion;
private boolean firstStart=true; private final AtomicBoolean firstStart=new AtomicBoolean(true);
private CountDownLatch readyCountDownLatch = new CountDownLatch(1); private final CountDownLatch readyCountDownLatch = new CountDownLatch(1);
private final CountDownLatch wireInfoSentDownLatch = new CountDownLatch(1);
/** /**
* Negotiator * Negotiator
@ -45,7 +46,7 @@ public class WireFormatNegotiator extends TransportFilter {
* @param next * @param next
* @param preferedFormat * @param preferedFormat
*/ */
public WireFormatNegotiator(Transport next, WireFormat wireFormat, int minimumVersion) { public WireFormatNegotiator(Transport next, OpenWireFormat wireFormat, int minimumVersion) {
super(next); super(next);
this.wireFormat = wireFormat; this.wireFormat = wireFormat;
this.minimumVersion = minimumVersion; this.minimumVersion = minimumVersion;
@ -54,9 +55,13 @@ public class WireFormatNegotiator extends TransportFilter {
public void start() throws Exception { public void start() throws Exception {
super.start(); super.start();
if( firstStart ) { if( firstStart.compareAndSet(true, false) ) {
WireFormatInfo info = createWireFormatInfo(); try {
WireFormatInfo info = wireFormat.getPreferedWireFormatInfo();
next.oneway(info); next.oneway(info);
} finally {
wireInfoSentDownLatch.countDown();
}
} }
} }
@ -69,18 +74,6 @@ public class WireFormatNegotiator extends TransportFilter {
super.oneway(command); super.oneway(command);
} }
protected WireFormatInfo createWireFormatInfo() throws IOException {
WireFormatInfo info = new WireFormatInfo();
info.setVersion(wireFormat.getVersion());
if ( wireFormat instanceof OpenWireFormat ) {
info.setStackTraceEnabled(((OpenWireFormat)wireFormat).isStackTraceEnabled());
info.setTcpNoDelayEnabled(((OpenWireFormat)wireFormat).isTcpNoDelayEnabled());
info.setCacheEnabled(((OpenWireFormat)wireFormat).isCacheEnabled());
info.setPrefixPacketSize(((OpenWireFormat)wireFormat).isPrefixPacketSize());
info.setTightEncodingEnabled(((OpenWireFormat)wireFormat).isTightEncodingEnabled());
}
return info;
}
public void onCommand(Command command) { public void onCommand(Command command) {
if( command.isWireFormatInfo() ) { if( command.isWireFormatInfo() ) {
@ -89,42 +82,33 @@ public class WireFormatNegotiator extends TransportFilter {
log.debug("Received WireFormat: " + info); log.debug("Received WireFormat: " + info);
} }
if( !info.isValid() ) {
getTransportListener().onException(new IOException("Remote wire format magic is invalid"));
} else if( info.getVersion() < minimumVersion ) {
getTransportListener().onException(new IOException("Remote wire format ("+info.getVersion()+") is lower the minimum version required ("+minimumVersion+")"));
} else if ( info.getVersion()!=wireFormat.getVersion() ) {
// Match the remote side.
wireFormat.setVersion(info.getVersion());
}
if ( wireFormat instanceof OpenWireFormat ) {
try { try {
if( !info.isStackTraceEnabled() ) { wireInfoSentDownLatch.await();
((OpenWireFormat)wireFormat).setStackTraceEnabled(false);
} if( !info.isValid() ) {
if( info.isTcpNoDelayEnabled() ) { onException(new IOException("Remote wire format magic is invalid"));
((OpenWireFormat)wireFormat).setTcpNoDelayEnabled(true); } else if( info.getVersion() < minimumVersion ) {
} onException(new IOException("Remote wire format ("+info.getVersion()+") is lower the minimum version required ("+minimumVersion+")"));
if( !info.isCacheEnabled() ) {
((OpenWireFormat)wireFormat).setCacheEnabled(false);
}
if( !info.isPrefixPacketSize() ) {
((OpenWireFormat)wireFormat).setPrefixPacketSize(false);
}
if( !info.isTightEncodingEnabled() ) {
((OpenWireFormat)wireFormat).setTightEncodingEnabled(false);
}
} catch (IOException e) {
getTransportListener().onException(e);
}
} }
wireFormat.renegociatWireFormat(info);
} catch (IOException e) {
onException(e);
} catch (InterruptedException e) {
onException((IOException) new InterruptedIOException().initCause(e));
}
readyCountDownLatch.countDown(); readyCountDownLatch.countDown();
} }
getTransportListener().onCommand(command); getTransportListener().onCommand(command);
} }
public void onException(IOException error) {
readyCountDownLatch.countDown();
super.onException(error);
}
public String toString() { public String toString() {
return next.toString(); return next.toString();
} }

View File

@ -29,6 +29,7 @@ import org.activeio.adapter.SyncToAsyncChannel;
import org.activeio.command.AsyncChannelToAsyncCommandChannel; import org.activeio.command.AsyncChannelToAsyncCommandChannel;
import org.activeio.command.WireFormat; import org.activeio.command.WireFormat;
import org.activeio.net.SocketMetadata; import org.activeio.net.SocketMetadata;
import org.apache.activemq.openwire.OpenWireFormat;
import org.apache.activemq.transport.InactivityMonitor; import org.apache.activemq.transport.InactivityMonitor;
import org.apache.activemq.transport.MutexTransport; import org.apache.activemq.transport.MutexTransport;
import org.apache.activemq.transport.ResponseCorrelator; import org.apache.activemq.transport.ResponseCorrelator;
@ -229,7 +230,10 @@ public class ActiveIOTransportFactory extends TransportFactory {
if( activeIOTransport.isTrace() ) { if( activeIOTransport.isTrace() ) {
transport = new TransportLogger(transport); transport = new TransportLogger(transport);
} }
transport = new WireFormatNegotiator(transport,format, activeIOTransport.getMinmumWireFormatVersion()); if( format instanceof OpenWireFormat ) {
transport = new WireFormatNegotiator(transport, (OpenWireFormat) format, activeIOTransport.getMinmumWireFormatVersion());
}
transport = new InactivityMonitor(transport, activeIOTransport.getMaxInactivityDuration()); transport = new InactivityMonitor(transport, activeIOTransport.getMaxInactivityDuration());
transport = new MutexTransport(transport); transport = new MutexTransport(transport);
transport = new ResponseCorrelator(transport); transport = new ResponseCorrelator(transport);
@ -275,7 +279,9 @@ public class ActiveIOTransportFactory extends TransportFactory {
if( activeIOTransport.isTrace() ) { if( activeIOTransport.isTrace() ) {
transport = new TransportLogger(transport); transport = new TransportLogger(transport);
} }
transport = new WireFormatNegotiator(transport,format, activeIOTransport.getMinmumWireFormatVersion()); if( format instanceof OpenWireFormat ) {
transport = new WireFormatNegotiator(transport, (OpenWireFormat) format, activeIOTransport.getMinmumWireFormatVersion());
}
transport = new InactivityMonitor(transport, activeIOTransport.getMaxInactivityDuration()); transport = new InactivityMonitor(transport, activeIOTransport.getMaxInactivityDuration());
return transport; return transport;
} }

View File

@ -64,8 +64,10 @@ public class TcpTransportFactory extends TransportFactory {
transport = new TransportLogger(transport); transport = new TransportLogger(transport);
} }
if( format instanceof OpenWireFormat ) // Only need the OpenWireFormat if using openwire
transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion()); if( format instanceof OpenWireFormat ) {
transport = new WireFormatNegotiator(transport, (OpenWireFormat)format, tcpTransport.getMinmumWireFormatVersion());
}
if( tcpTransport.getMaxInactivityDuration() > 0 ) { if( tcpTransport.getMaxInactivityDuration() > 0 ) {
transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration()); transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration());
@ -83,7 +85,11 @@ public class TcpTransportFactory extends TransportFactory {
transport = new TransportLogger(transport); transport = new TransportLogger(transport);
} }
transport = new WireFormatNegotiator(transport, format, tcpTransport.getMinmumWireFormatVersion()); // Only need the OpenWireFormat if using openwire
if( format instanceof OpenWireFormat ) {
transport = new WireFormatNegotiator(transport, (OpenWireFormat)format, tcpTransport.getMinmumWireFormatVersion());
}
if( tcpTransport.getMaxInactivityDuration() > 0 ) { if( tcpTransport.getMaxInactivityDuration() > 0 ) {
transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration()); transport = new InactivityMonitor(transport, tcpTransport.getMaxInactivityDuration());
} }

View File

@ -83,7 +83,7 @@ public class UdpTransportFactory extends TransportFactory {
protected Transport createTransport(URI location, WireFormat wf) throws UnknownHostException, IOException { protected Transport createTransport(URI location, WireFormat wf) throws UnknownHostException, IOException {
OpenWireFormat wireFormat = (OpenWireFormat) wf; OpenWireFormat wireFormat = (OpenWireFormat) wf;
wireFormat.setPrefixPacketSize(false); wireFormat.setSizePrefixDisabled(true);
return new UdpTransport(wireFormat, location); return new UdpTransport(wireFormat, location);
} }

View File

@ -61,13 +61,21 @@ public class MarshallingSupport {
} }
} }
static public HashMap unmarshalPrimitiveMap(DataInputStream in) throws IOException {
return unmarshalPrimitiveMap(in, Integer.MAX_VALUE);
}
/** /**
* @param in * @param in
* @return * @return
* @throws IOException * @throws IOException
* @throws IOException
*/ */
static public HashMap unmarshalPrimitiveMap(DataInputStream in) throws IOException { public static HashMap unmarshalPrimitiveMap(DataInputStream in, int max_property_size) throws IOException {
int size = in.readInt(); int size = in.readInt();
if( size > max_property_size ) {
throw new IOException("Primitive map is larger than the allowed size: "+size);
}
if( size < 0 ) { if( size < 0 ) {
return null; return null;
} else { } else {
@ -266,4 +274,5 @@ public class MarshallingSupport {
} }
} }
} }

View File

@ -35,9 +35,15 @@ public class MarshallingBrokerTest extends BrokerTest {
public WireFormat wireFormat = new OpenWireFormat(); public WireFormat wireFormat = new OpenWireFormat();
public void initCombos() { public void initCombos() {
OpenWireFormat wf1 = new OpenWireFormat();
wf1.setCacheEnabled(false);
OpenWireFormat wf2 = new OpenWireFormat();
wf2.setCacheEnabled(true);
addCombinationValues( "wireFormat", new Object[]{ addCombinationValues( "wireFormat", new Object[]{
new OpenWireFormat(true), wf1,
new OpenWireFormat(false), wf2,
}); });
} }

View File

@ -22,6 +22,7 @@ import java.io.DataOutputStream;
import java.io.File; import java.io.File;
import java.io.FileInputStream; import java.io.FileInputStream;
import java.io.FileOutputStream; import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.net.URI; import java.net.URI;
import java.net.URL; import java.net.URL;
@ -153,5 +154,5 @@ abstract public class DataFileGenerator extends Assert {
} }
} }
abstract protected Object createObject(); abstract protected Object createObject() throws IOException;
} }

View File

@ -16,13 +16,16 @@
*/ */
package org.apache.activemq.openwire; package org.apache.activemq.openwire;
import java.io.IOException;
import org.apache.activemq.command.WireFormatInfo; import org.apache.activemq.command.WireFormatInfo;
public class WireFormatInfoData extends DataFileGenerator { public class WireFormatInfoData extends DataFileGenerator {
protected Object createObject() { protected Object createObject() throws IOException {
WireFormatInfo rc = new WireFormatInfo(); WireFormatInfo rc = new WireFormatInfo();
rc.setResponseRequired(false); rc.setResponseRequired(false);
rc.setCacheEnabled(true);
rc.setVersion(1); rc.setVersion(1);
return rc; return rc;
} }

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQBytesMessageTest extends ActiveMQMessageTest { public class ActiveMQBytesMessageTest extends ActiveMQMessageTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public abstract class ActiveMQDestinationTestSupport extends DataFileGeneratorTestSupport { public abstract class ActiveMQDestinationTestSupport extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQMapMessageTest extends ActiveMQMessageTest { public class ActiveMQMapMessageTest extends ActiveMQMessageTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQMessageTest extends MessageTestSupport { public class ActiveMQMessageTest extends MessageTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQObjectMessageTest extends ActiveMQMessageTest { public class ActiveMQObjectMessageTest extends ActiveMQMessageTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQQueueTest extends ActiveMQDestinationTestSupport { public class ActiveMQQueueTest extends ActiveMQDestinationTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQStreamMessageTest extends ActiveMQMessageTest { public class ActiveMQStreamMessageTest extends ActiveMQMessageTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public abstract class ActiveMQTempDestinationTestSupport extends ActiveMQDestinationTestSupport { public abstract class ActiveMQTempDestinationTestSupport extends ActiveMQDestinationTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQTempQueueTest extends ActiveMQTempDestinationTestSupport { public class ActiveMQTempQueueTest extends ActiveMQTempDestinationTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQTempTopicTest extends ActiveMQTempDestinationTestSupport { public class ActiveMQTempTopicTest extends ActiveMQTempDestinationTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQTextMessageTest extends ActiveMQMessageTest { public class ActiveMQTextMessageTest extends ActiveMQMessageTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ActiveMQTopicTest extends ActiveMQDestinationTestSupport { public class ActiveMQTopicTest extends ActiveMQDestinationTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public abstract class BaseCommandTestSupport extends DataFileGeneratorTestSupport { public abstract class BaseCommandTestSupport extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class BrokerIdTest extends DataFileGeneratorTestSupport { public class BrokerIdTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class BrokerInfoTest extends BaseCommandTestSupport { public class BrokerInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ConnectionErrorTest extends BaseCommandTestSupport { public class ConnectionErrorTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ConnectionIdTest extends DataFileGeneratorTestSupport { public class ConnectionIdTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ConnectionInfoTest extends BaseCommandTestSupport { public class ConnectionInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ConsumerIdTest extends DataFileGeneratorTestSupport { public class ConsumerIdTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ConsumerInfoTest extends BaseCommandTestSupport { public class ConsumerInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ControlCommandTest extends BaseCommandTestSupport { public class ControlCommandTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class DataArrayResponseTest extends ResponseTest { public class DataArrayResponseTest extends ResponseTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class DataResponseTest extends ResponseTest { public class DataResponseTest extends ResponseTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class DestinationInfoTest extends BaseCommandTestSupport { public class DestinationInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class DiscoveryEventTest extends DataFileGeneratorTestSupport { public class DiscoveryEventTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ExceptionResponseTest extends ResponseTest { public class ExceptionResponseTest extends ResponseTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class FlushCommandTest extends BaseCommandTestSupport { public class FlushCommandTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class IntegerResponseTest extends ResponseTest { public class IntegerResponseTest extends ResponseTest {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class JournalQueueAckTest extends DataFileGeneratorTestSupport { public class JournalQueueAckTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class JournalTopicAckTest extends DataFileGeneratorTestSupport { public class JournalTopicAckTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class JournalTraceTest extends DataFileGeneratorTestSupport { public class JournalTraceTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class JournalTransactionTest extends DataFileGeneratorTestSupport { public class JournalTransactionTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class KeepAliveInfoTest extends DataFileGeneratorTestSupport { public class KeepAliveInfoTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class LocalTransactionIdTest extends TransactionIdTestSupport { public class LocalTransactionIdTest extends TransactionIdTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class MessageAckTest extends BaseCommandTestSupport { public class MessageAckTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class MessageDispatchNotificationTest extends BaseCommandTestSupport { public class MessageDispatchNotificationTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class MessageDispatchTest extends BaseCommandTestSupport { public class MessageDispatchTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class MessageIdTest extends DataFileGeneratorTestSupport { public class MessageIdTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public abstract class MessageTestSupport extends BaseCommandTestSupport { public abstract class MessageTestSupport extends BaseCommandTestSupport {

View File

@ -1 +1,57 @@
/** * * Copyright 2005-2006 The Apache Software Foundation * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activemq.openwire.v1; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import org.apache.activemq.openwire.*; import org.apache.activemq.command.*; /** * Test case for the OpenWire marshalling for NetworkBridgeFilter * * * NOTE!: This file is auto generated - do not modify! * if you need to make a change, please see the modify the groovy scripts in the * under src/gram/script and then use maven openwire:generate to regenerate * this file. * * @version $Revision: $ */ public class NetworkBridgeFilterTest extends DataFileGeneratorTestSupport { public static NetworkBridgeFilterTest SINGLETON = new NetworkBridgeFilterTest(); public Object createObject() throws Exception { NetworkBridgeFilter info = new NetworkBridgeFilter(); populateObject(info); return info; } protected void populateObject(Object object) throws Exception { super.populateObject(object); NetworkBridgeFilter info = (NetworkBridgeFilter) object; info.setNetworkTTL(1); info.setNetworkBrokerId(createBrokerId("NetworkBrokerId:1")); } } /**
*
* Copyright 2005-2006 The Apache Software Foundation
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.activemq.openwire.v1;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import org.apache.activemq.openwire.*;
import org.apache.activemq.command.*;
/**
* Test case for the OpenWire marshalling for NetworkBridgeFilter
*
*
* NOTE!: This file is auto generated - do not modify!
* if you need to make a change, please see the modify the groovy scripts in the
* under src/gram/script and then use maven openwire:generate to regenerate
* this file.
*
* @version $Revision: $
*/
public class NetworkBridgeFilterTest extends DataFileGeneratorTestSupport {
public static NetworkBridgeFilterTest SINGLETON = new NetworkBridgeFilterTest();
public Object createObject() throws Exception {
NetworkBridgeFilter info = new NetworkBridgeFilter();
populateObject(info);
return info;
}
protected void populateObject(Object object) throws Exception {
super.populateObject(object);
NetworkBridgeFilter info = (NetworkBridgeFilter) object;
info.setNetworkTTL(1);
info.setNetworkBrokerId(createBrokerId("NetworkBrokerId:1"));
}
}

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ProducerIdTest extends DataFileGeneratorTestSupport { public class ProducerIdTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ProducerInfoTest extends BaseCommandTestSupport { public class ProducerInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class RemoveInfoTest extends BaseCommandTestSupport { public class RemoveInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class RemoveSubscriptionInfoTest extends BaseCommandTestSupport { public class RemoveSubscriptionInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ReplayCommandTest extends BaseCommandTestSupport { public class ReplayCommandTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ResponseTest extends BaseCommandTestSupport { public class ResponseTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class SessionIdTest extends DataFileGeneratorTestSupport { public class SessionIdTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class SessionInfoTest extends BaseCommandTestSupport { public class SessionInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class ShutdownInfoTest extends BaseCommandTestSupport { public class ShutdownInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class SubscriptionInfoTest extends DataFileGeneratorTestSupport { public class SubscriptionInfoTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public abstract class TransactionIdTestSupport extends DataFileGeneratorTestSupport { public abstract class TransactionIdTestSupport extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class TransactionInfoTest extends BaseCommandTestSupport { public class TransactionInfoTest extends BaseCommandTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class WireFormatInfoTest extends DataFileGeneratorTestSupport { public class WireFormatInfoTest extends DataFileGeneratorTestSupport {

View File

@ -33,7 +33,7 @@ import org.apache.activemq.command.*;
* under src/gram/script and then use maven openwire:generate to regenerate * under src/gram/script and then use maven openwire:generate to regenerate
* this file. * this file.
* *
* @version $Revision: $ * @version $Revision$
*/ */
public class XATransactionIdTest extends TransactionIdTestSupport { public class XATransactionIdTest extends TransactionIdTestSupport {

View File

@ -38,10 +38,10 @@ public class InactivityMonitorTest extends CombinationTestSupport implements Tra
protected void setUp() throws Exception { protected void setUp() throws Exception {
super.setUp(); super.setUp();
server = TransportFactory.bind("localhost", new URI("tcp://localhost:61616?maxInactivityDuration="+serverInactivityLimit)); server = TransportFactory.bind("localhost", new URI("tcp://localhost:61616?trace=true&maxInactivityDuration="+serverInactivityLimit));
server.setAcceptListener(this); server.setAcceptListener(this);
server.start(); server.start();
clientTransport = TransportFactory.connect(new URI("tcp://localhost:61616?maxInactivityDuration="+clientInactivityLimit)); clientTransport = TransportFactory.connect(new URI("tcp://localhost:61616?trace=true&maxInactivityDuration="+clientInactivityLimit));
clientTransport.setTransportListener(new TransportListener() { clientTransport.setTransportListener(new TransportListener() {
public void onCommand(Command command) { public void onCommand(Command command) {
clientReceiveCount.incrementAndGet(); clientReceiveCount.incrementAndGet();
@ -130,7 +130,9 @@ public class InactivityMonitorTest extends CombinationTestSupport implements Tra
Thread.sleep(4000); Thread.sleep(4000);
if( clientErrorCount.get() > 0 )
assertEquals(0, clientErrorCount.get()); assertEquals(0, clientErrorCount.get());
if( serverErrorCount.get() > 0 )
assertEquals(0, serverErrorCount.get()); assertEquals(0, serverErrorCount.get());
} }

View File

@ -87,6 +87,7 @@
<Compile Include="src\main\csharp\ActiveMQ\Commands\ProducerInfo.cs"/> <Compile Include="src\main\csharp\ActiveMQ\Commands\ProducerInfo.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\Commands\RemoveInfo.cs"/> <Compile Include="src\main\csharp\ActiveMQ\Commands\RemoveInfo.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\Commands\RemoveSubscriptionInfo.cs"/> <Compile Include="src\main\csharp\ActiveMQ\Commands\RemoveSubscriptionInfo.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\Commands\ReplayCommand.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\Commands\Response.cs"/> <Compile Include="src\main\csharp\ActiveMQ\Commands\Response.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\Commands\SessionId.cs"/> <Compile Include="src\main\csharp\ActiveMQ\Commands\SessionId.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\Commands\SessionInfo.cs"/> <Compile Include="src\main\csharp\ActiveMQ\Commands\SessionInfo.cs"/>
@ -160,6 +161,7 @@
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ProducerInfoMarshaller.cs"/> <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ProducerInfoMarshaller.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\RemoveInfoMarshaller.cs"/> <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\RemoveInfoMarshaller.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\RemoveSubscriptionInfoMarshaller.cs"/> <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\RemoveSubscriptionInfoMarshaller.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ReplayCommandMarshaller.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ResponseMarshaller.cs"/> <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ResponseMarshaller.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\SessionIdMarshaller.cs"/> <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\SessionIdMarshaller.cs"/>
<Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\SessionInfoMarshaller.cs"/> <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\SessionInfoMarshaller.cs"/>

View File

@ -1 +1,85 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for BrokerId // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class BrokerId : AbstractCommand, 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; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for BrokerId
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class BrokerId : AbstractCommand, 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; }
}
}
}

View File

@ -1 +1,95 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for BrokerInfo // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class BrokerInfo : BaseCommand { public const byte ID_BrokerInfo = 2; BrokerId brokerId; string brokerURL; BrokerInfo[] peerBrokerInfos; string brokerName; bool slaveBroker; public override string ToString() { return GetType().Name + "[" + " BrokerId=" + BrokerId + " BrokerURL=" + BrokerURL + " PeerBrokerInfos=" + PeerBrokerInfos + " BrokerName=" + BrokerName + " SlaveBroker=" + SlaveBroker + " ]"; } 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; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for BrokerInfo
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class BrokerInfo : BaseCommand
{
public const byte ID_BrokerInfo = 2;
BrokerId brokerId;
string brokerURL;
BrokerInfo[] peerBrokerInfos;
string brokerName;
bool slaveBroker;
public override string ToString() {
return GetType().Name + "["
+ " BrokerId=" + BrokerId
+ " BrokerURL=" + BrokerURL
+ " PeerBrokerInfos=" + PeerBrokerInfos
+ " BrokerName=" + BrokerName
+ " SlaveBroker=" + SlaveBroker
+ " ]";
}
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; }
}
}
}

View File

@ -1 +1,71 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ConnectionError // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class 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; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ConnectionError
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class 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; }
}
}
}

View File

@ -1 +1,85 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ConnectionId // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class ConnectionId : AbstractCommand, 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; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ConnectionId
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class ConnectionId : AbstractCommand, 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; }
}
}
}

View File

@ -1 +1,95 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ConnectionInfo // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class ConnectionInfo : BaseCommand { public const byte ID_ConnectionInfo = 3; ConnectionId connectionId; string clientId; string password; string userName; BrokerId[] brokerPath; public override string ToString() { return GetType().Name + "[" + " ConnectionId=" + ConnectionId + " ClientId=" + ClientId + " Password=" + Password + " UserName=" + UserName + " BrokerPath=" + BrokerPath + " ]"; } 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; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ConnectionInfo
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class ConnectionInfo : BaseCommand
{
public const byte ID_ConnectionInfo = 3;
ConnectionId connectionId;
string clientId;
string password;
string userName;
BrokerId[] brokerPath;
public override string ToString() {
return GetType().Name + "["
+ " ConnectionId=" + ConnectionId
+ " ClientId=" + ClientId
+ " Password=" + Password
+ " UserName=" + UserName
+ " BrokerPath=" + BrokerPath
+ " ]";
}
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; }
}
}
}

View File

@ -1 +1,105 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ConsumerId // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class ConsumerId : AbstractCommand, DataStructure { public const byte ID_ConsumerId = 122; string connectionId; long sessionId; long 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; } 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; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ConsumerId
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class ConsumerId : AbstractCommand, DataStructure
{
public const byte ID_ConsumerId = 122;
string connectionId;
long sessionId;
long 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;
}
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; }
}
}
}

View File

@ -1 +1,175 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ConsumerInfo // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class ConsumerInfo : BaseCommand { public const byte ID_ConsumerInfo = 5; ConsumerId consumerId; bool browser; ActiveMQDestination destination; int prefetchSize; int maximumPendingMessageLimit; bool dispatchAsync; string selector; string subcriptionName; bool noLocal; bool exclusive; bool retroactive; byte priority; BrokerId[] brokerPath; BooleanExpression additionalPredicate; bool networkSubscription; public override string ToString() { return GetType().Name + "[" + " ConsumerId=" + ConsumerId + " Browser=" + Browser + " Destination=" + Destination + " PrefetchSize=" + PrefetchSize + " MaximumPendingMessageLimit=" + MaximumPendingMessageLimit + " DispatchAsync=" + DispatchAsync + " Selector=" + Selector + " SubcriptionName=" + SubcriptionName + " NoLocal=" + NoLocal + " Exclusive=" + Exclusive + " Retroactive=" + Retroactive + " Priority=" + Priority + " BrokerPath=" + BrokerPath + " AdditionalPredicate=" + AdditionalPredicate + " NetworkSubscription=" + NetworkSubscription + " ]"; } public override byte GetDataStructureType() { return ID_ConsumerInfo; } // Properties public ConsumerId ConsumerId { get { return consumerId; } set { this.consumerId = value; } } public bool Browser { get { return browser; } set { this.browser = value; } } public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public int PrefetchSize { get { return prefetchSize; } set { this.prefetchSize = value; } } public int MaximumPendingMessageLimit { get { return maximumPendingMessageLimit; } set { this.maximumPendingMessageLimit = value; } } public bool DispatchAsync { get { return dispatchAsync; } set { this.dispatchAsync = value; } } public string Selector { get { return selector; } set { this.selector = value; } } public string SubcriptionName { get { return subcriptionName; } set { this.subcriptionName = value; } } public bool NoLocal { get { return noLocal; } set { this.noLocal = value; } } public bool Exclusive { get { return exclusive; } set { this.exclusive = value; } } public bool Retroactive { get { return retroactive; } set { this.retroactive = value; } } public byte Priority { get { return priority; } set { this.priority = value; } } public BrokerId[] BrokerPath { get { return brokerPath; } set { this.brokerPath = value; } } public BooleanExpression AdditionalPredicate { get { return additionalPredicate; } set { this.additionalPredicate = value; } } public bool NetworkSubscription { get { return networkSubscription; } set { this.networkSubscription = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ConsumerInfo
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class ConsumerInfo : BaseCommand
{
public const byte ID_ConsumerInfo = 5;
ConsumerId consumerId;
bool browser;
ActiveMQDestination destination;
int prefetchSize;
int maximumPendingMessageLimit;
bool dispatchAsync;
string selector;
string subcriptionName;
bool noLocal;
bool exclusive;
bool retroactive;
byte priority;
BrokerId[] brokerPath;
BooleanExpression additionalPredicate;
bool networkSubscription;
public override string ToString() {
return GetType().Name + "["
+ " ConsumerId=" + ConsumerId
+ " Browser=" + Browser
+ " Destination=" + Destination
+ " PrefetchSize=" + PrefetchSize
+ " MaximumPendingMessageLimit=" + MaximumPendingMessageLimit
+ " DispatchAsync=" + DispatchAsync
+ " Selector=" + Selector
+ " SubcriptionName=" + SubcriptionName
+ " NoLocal=" + NoLocal
+ " Exclusive=" + Exclusive
+ " Retroactive=" + Retroactive
+ " Priority=" + Priority
+ " BrokerPath=" + BrokerPath
+ " AdditionalPredicate=" + AdditionalPredicate
+ " NetworkSubscription=" + NetworkSubscription
+ " ]";
}
public override byte GetDataStructureType() {
return ID_ConsumerInfo;
}
// Properties
public ConsumerId ConsumerId
{
get { return consumerId; }
set { this.consumerId = value; }
}
public bool Browser
{
get { return browser; }
set { this.browser = value; }
}
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public int PrefetchSize
{
get { return prefetchSize; }
set { this.prefetchSize = value; }
}
public int MaximumPendingMessageLimit
{
get { return maximumPendingMessageLimit; }
set { this.maximumPendingMessageLimit = value; }
}
public bool DispatchAsync
{
get { return dispatchAsync; }
set { this.dispatchAsync = value; }
}
public string Selector
{
get { return selector; }
set { this.selector = value; }
}
public string SubcriptionName
{
get { return subcriptionName; }
set { this.subcriptionName = value; }
}
public bool NoLocal
{
get { return noLocal; }
set { this.noLocal = value; }
}
public bool Exclusive
{
get { return exclusive; }
set { this.exclusive = value; }
}
public bool Retroactive
{
get { return retroactive; }
set { this.retroactive = value; }
}
public byte Priority
{
get { return priority; }
set { this.priority = value; }
}
public BrokerId[] BrokerPath
{
get { return brokerPath; }
set { this.brokerPath = value; }
}
public BooleanExpression AdditionalPredicate
{
get { return additionalPredicate; }
set { this.additionalPredicate = value; }
}
public bool NetworkSubscription
{
get { return networkSubscription; }
set { this.networkSubscription = value; }
}
}
}

View File

@ -1 +1,63 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ControlCommand // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class ControlCommand : BaseCommand { public const byte ID_ControlCommand = 14; string command; public override string ToString() { return GetType().Name + "[" + " Command=" + Command + " ]"; } public override byte GetDataStructureType() { return ID_ControlCommand; } // Properties public string Command { get { return command; } set { this.command = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ControlCommand
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class ControlCommand : BaseCommand
{
public const byte ID_ControlCommand = 14;
string command;
public override string ToString() {
return GetType().Name + "["
+ " Command=" + Command
+ " ]";
}
public override byte GetDataStructureType() {
return ID_ControlCommand;
}
// Properties
public string Command
{
get { return command; }
set { this.command = value; }
}
}
}

View File

@ -1 +1,63 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for DataArrayResponse // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class DataArrayResponse : Response { public const byte ID_DataArrayResponse = 33; DataStructure[] data; public override string ToString() { return GetType().Name + "[" + " Data=" + Data + " ]"; } public override byte GetDataStructureType() { return ID_DataArrayResponse; } // Properties public DataStructure[] Data { get { return data; } set { this.data = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for DataArrayResponse
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class DataArrayResponse : Response
{
public const byte ID_DataArrayResponse = 33;
DataStructure[] data;
public override string ToString() {
return GetType().Name + "["
+ " Data=" + Data
+ " ]";
}
public override byte GetDataStructureType() {
return ID_DataArrayResponse;
}
// Properties
public DataStructure[] Data
{
get { return data; }
set { this.data = value; }
}
}
}

View File

@ -1 +1,63 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for DataResponse // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class DataResponse : Response { public const byte ID_DataResponse = 32; DataStructure data; public override string ToString() { return GetType().Name + "[" + " Data=" + Data + " ]"; } public override byte GetDataStructureType() { return ID_DataResponse; } // Properties public DataStructure Data { get { return data; } set { this.data = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for DataResponse
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class DataResponse : Response
{
public const byte ID_DataResponse = 32;
DataStructure data;
public override string ToString() {
return GetType().Name + "["
+ " Data=" + Data
+ " ]";
}
public override byte GetDataStructureType() {
return ID_DataResponse;
}
// Properties
public DataStructure Data
{
get { return data; }
set { this.data = value; }
}
}
}

View File

@ -1 +1,95 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for DestinationInfo // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class DestinationInfo : BaseCommand { public const byte ID_DestinationInfo = 8; ConnectionId connectionId; ActiveMQDestination destination; byte operationType; long timeout; BrokerId[] brokerPath; public override string ToString() { return GetType().Name + "[" + " ConnectionId=" + ConnectionId + " Destination=" + Destination + " OperationType=" + OperationType + " Timeout=" + Timeout + " BrokerPath=" + BrokerPath + " ]"; } public override byte GetDataStructureType() { return ID_DestinationInfo; } // Properties public ConnectionId ConnectionId { get { return connectionId; } set { this.connectionId = value; } } public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public byte OperationType { get { return operationType; } set { this.operationType = value; } } public long Timeout { get { return timeout; } set { this.timeout = value; } } public BrokerId[] BrokerPath { get { return brokerPath; } set { this.brokerPath = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for DestinationInfo
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class DestinationInfo : BaseCommand
{
public const byte ID_DestinationInfo = 8;
ConnectionId connectionId;
ActiveMQDestination destination;
byte operationType;
long timeout;
BrokerId[] brokerPath;
public override string ToString() {
return GetType().Name + "["
+ " ConnectionId=" + ConnectionId
+ " Destination=" + Destination
+ " OperationType=" + OperationType
+ " Timeout=" + Timeout
+ " BrokerPath=" + BrokerPath
+ " ]";
}
public override byte GetDataStructureType() {
return ID_DestinationInfo;
}
// Properties
public ConnectionId ConnectionId
{
get { return connectionId; }
set { this.connectionId = value; }
}
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public byte OperationType
{
get { return operationType; }
set { this.operationType = value; }
}
public long Timeout
{
get { return timeout; }
set { this.timeout = value; }
}
public BrokerId[] BrokerPath
{
get { return brokerPath; }
set { this.brokerPath = value; }
}
}
}

View File

@ -1 +1,71 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for DiscoveryEvent // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class DiscoveryEvent : AbstractCommand, DataStructure { public const byte ID_DiscoveryEvent = 40; string serviceName; string brokerName; public override string ToString() { return GetType().Name + "[" + " ServiceName=" + ServiceName + " BrokerName=" + BrokerName + " ]"; } public override byte GetDataStructureType() { return ID_DiscoveryEvent; } // Properties public string ServiceName { get { return serviceName; } set { this.serviceName = value; } } public string BrokerName { get { return brokerName; } set { this.brokerName = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for DiscoveryEvent
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class DiscoveryEvent : AbstractCommand, DataStructure
{
public const byte ID_DiscoveryEvent = 40;
string serviceName;
string brokerName;
public override string ToString() {
return GetType().Name + "["
+ " ServiceName=" + ServiceName
+ " BrokerName=" + BrokerName
+ " ]";
}
public override byte GetDataStructureType() {
return ID_DiscoveryEvent;
}
// Properties
public string ServiceName
{
get { return serviceName; }
set { this.serviceName = value; }
}
public string BrokerName
{
get { return brokerName; }
set { this.brokerName = value; }
}
}
}

View File

@ -1 +1,63 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for ExceptionResponse // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class ExceptionResponse : Response { public const byte ID_ExceptionResponse = 31; BrokerError exception; public override string ToString() { return GetType().Name + "[" + " Exception=" + Exception + " ]"; } public override byte GetDataStructureType() { return ID_ExceptionResponse; } // Properties public BrokerError Exception { get { return exception; } set { this.exception = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for ExceptionResponse
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class ExceptionResponse : Response
{
public const byte ID_ExceptionResponse = 31;
BrokerError exception;
public override string ToString() {
return GetType().Name + "["
+ " Exception=" + Exception
+ " ]";
}
public override byte GetDataStructureType() {
return ID_ExceptionResponse;
}
// Properties
public BrokerError Exception
{
get { return exception; }
set { this.exception = value; }
}
}
}

View File

@ -1 +1,55 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for FlushCommand // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class FlushCommand : BaseCommand { public const byte ID_FlushCommand = 15; public override string ToString() { return GetType().Name + "[" + " ]"; } public override byte GetDataStructureType() { return ID_FlushCommand; } // Properties } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for FlushCommand
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class FlushCommand : BaseCommand
{
public const byte ID_FlushCommand = 15;
public override string ToString() {
return GetType().Name + "["
+ " ]";
}
public override byte GetDataStructureType() {
return ID_FlushCommand;
}
// Properties
}
}

View File

@ -1 +1,63 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for IntegerResponse // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class IntegerResponse : Response { public const byte ID_IntegerResponse = 34; int result; public override string ToString() { return GetType().Name + "[" + " Result=" + Result + " ]"; } public override byte GetDataStructureType() { return ID_IntegerResponse; } // Properties public int Result { get { return result; } set { this.result = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for IntegerResponse
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class IntegerResponse : Response
{
public const byte ID_IntegerResponse = 34;
int result;
public override string ToString() {
return GetType().Name + "["
+ " Result=" + Result
+ " ]";
}
public override byte GetDataStructureType() {
return ID_IntegerResponse;
}
// Properties
public int Result
{
get { return result; }
set { this.result = value; }
}
}
}

View File

@ -1 +1,71 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for JournalQueueAck // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class JournalQueueAck : AbstractCommand, DataStructure { public const byte ID_JournalQueueAck = 52; ActiveMQDestination destination; MessageAck messageAck; public override string ToString() { return GetType().Name + "[" + " Destination=" + Destination + " MessageAck=" + MessageAck + " ]"; } public override byte GetDataStructureType() { return ID_JournalQueueAck; } // Properties public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public MessageAck MessageAck { get { return messageAck; } set { this.messageAck = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for JournalQueueAck
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class JournalQueueAck : AbstractCommand, DataStructure
{
public const byte ID_JournalQueueAck = 52;
ActiveMQDestination destination;
MessageAck messageAck;
public override string ToString() {
return GetType().Name + "["
+ " Destination=" + Destination
+ " MessageAck=" + MessageAck
+ " ]";
}
public override byte GetDataStructureType() {
return ID_JournalQueueAck;
}
// Properties
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public MessageAck MessageAck
{
get { return messageAck; }
set { this.messageAck = value; }
}
}
}

View File

@ -1 +1,103 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for JournalTopicAck // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class JournalTopicAck : AbstractCommand, DataStructure { public const byte ID_JournalTopicAck = 50; ActiveMQDestination destination; MessageId messageId; long messageSequenceId; string subscritionName; string clientId; TransactionId transactionId; public override string ToString() { return GetType().Name + "[" + " Destination=" + Destination + " MessageId=" + MessageId + " MessageSequenceId=" + MessageSequenceId + " SubscritionName=" + SubscritionName + " ClientId=" + ClientId + " TransactionId=" + TransactionId + " ]"; } public override byte GetDataStructureType() { return ID_JournalTopicAck; } // Properties public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public MessageId MessageId { get { return messageId; } set { this.messageId = value; } } public long MessageSequenceId { get { return messageSequenceId; } set { this.messageSequenceId = value; } } public string SubscritionName { get { return subscritionName; } set { this.subscritionName = value; } } public string ClientId { get { return clientId; } set { this.clientId = value; } } public TransactionId TransactionId { get { return transactionId; } set { this.transactionId = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for JournalTopicAck
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class JournalTopicAck : AbstractCommand, DataStructure
{
public const byte ID_JournalTopicAck = 50;
ActiveMQDestination destination;
MessageId messageId;
long messageSequenceId;
string subscritionName;
string clientId;
TransactionId transactionId;
public override string ToString() {
return GetType().Name + "["
+ " Destination=" + Destination
+ " MessageId=" + MessageId
+ " MessageSequenceId=" + MessageSequenceId
+ " SubscritionName=" + SubscritionName
+ " ClientId=" + ClientId
+ " TransactionId=" + TransactionId
+ " ]";
}
public override byte GetDataStructureType() {
return ID_JournalTopicAck;
}
// Properties
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public MessageId MessageId
{
get { return messageId; }
set { this.messageId = value; }
}
public long MessageSequenceId
{
get { return messageSequenceId; }
set { this.messageSequenceId = value; }
}
public string SubscritionName
{
get { return subscritionName; }
set { this.subscritionName = value; }
}
public string ClientId
{
get { return clientId; }
set { this.clientId = value; }
}
public TransactionId TransactionId
{
get { return transactionId; }
set { this.transactionId = value; }
}
}
}

View File

@ -1 +1,63 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for JournalTrace // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class JournalTrace : AbstractCommand, DataStructure { public const byte ID_JournalTrace = 53; string message; public override string ToString() { return GetType().Name + "[" + " Message=" + Message + " ]"; } public override byte GetDataStructureType() { return ID_JournalTrace; } // Properties public string Message { get { return message; } set { this.message = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for JournalTrace
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class JournalTrace : AbstractCommand, DataStructure
{
public const byte ID_JournalTrace = 53;
string message;
public override string ToString() {
return GetType().Name + "["
+ " Message=" + Message
+ " ]";
}
public override byte GetDataStructureType() {
return ID_JournalTrace;
}
// Properties
public string Message
{
get { return message; }
set { this.message = value; }
}
}
}

View File

@ -1 +1,79 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for JournalTransaction // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class JournalTransaction : AbstractCommand, DataStructure { public const byte ID_JournalTransaction = 54; TransactionId transactionId; byte type; bool wasPrepared; public override string ToString() { return GetType().Name + "[" + " TransactionId=" + TransactionId + " Type=" + Type + " WasPrepared=" + WasPrepared + " ]"; } public override byte GetDataStructureType() { return ID_JournalTransaction; } // Properties public TransactionId TransactionId { get { return transactionId; } set { this.transactionId = value; } } public byte Type { get { return type; } set { this.type = value; } } public bool WasPrepared { get { return wasPrepared; } set { this.wasPrepared = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for JournalTransaction
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class JournalTransaction : AbstractCommand, DataStructure
{
public const byte ID_JournalTransaction = 54;
TransactionId transactionId;
byte type;
bool wasPrepared;
public override string ToString() {
return GetType().Name + "["
+ " TransactionId=" + TransactionId
+ " Type=" + Type
+ " WasPrepared=" + WasPrepared
+ " ]";
}
public override byte GetDataStructureType() {
return ID_JournalTransaction;
}
// Properties
public TransactionId TransactionId
{
get { return transactionId; }
set { this.transactionId = value; }
}
public byte Type
{
get { return type; }
set { this.type = value; }
}
public bool WasPrepared
{
get { return wasPrepared; }
set { this.wasPrepared = value; }
}
}
}

View File

@ -1 +1,55 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for KeepAliveInfo // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class KeepAliveInfo : AbstractCommand, Command { public const byte ID_KeepAliveInfo = 10; public override string ToString() { return GetType().Name + "[" + " ]"; } public override byte GetDataStructureType() { return ID_KeepAliveInfo; } // Properties } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for KeepAliveInfo
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class KeepAliveInfo : AbstractCommand, Command
{
public const byte ID_KeepAliveInfo = 10;
public override string ToString() {
return GetType().Name + "["
+ " ]";
}
public override byte GetDataStructureType() {
return ID_KeepAliveInfo;
}
// Properties
}
}

View File

@ -1 +1,95 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for LocalTransactionId // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class LocalTransactionId : TransactionId { public const byte ID_LocalTransactionId = 111; long value; ConnectionId connectionId; public override int GetHashCode() { int answer = 0; answer = (answer * 37) + HashCode(Value); answer = (answer * 37) + HashCode(ConnectionId); return answer; } public override bool Equals(object that) { if (that is LocalTransactionId) { return Equals((LocalTransactionId) that); } return false; } public virtual bool Equals(LocalTransactionId that) { if (! Equals(this.Value, that.Value)) return false; if (! Equals(this.ConnectionId, that.ConnectionId)) return false; return true; } public override string ToString() { return GetType().Name + "[" + " Value=" + Value + " ConnectionId=" + ConnectionId + " ]"; } public override byte GetDataStructureType() { return ID_LocalTransactionId; } // Properties public long Value { get { return value; } set { this.value = value; } } public ConnectionId ConnectionId { get { return connectionId; } set { this.connectionId = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for LocalTransactionId
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class LocalTransactionId : TransactionId
{
public const byte ID_LocalTransactionId = 111;
long value;
ConnectionId connectionId;
public override int GetHashCode() {
int answer = 0;
answer = (answer * 37) + HashCode(Value);
answer = (answer * 37) + HashCode(ConnectionId);
return answer;
}
public override bool Equals(object that) {
if (that is LocalTransactionId) {
return Equals((LocalTransactionId) that);
}
return false;
}
public virtual bool Equals(LocalTransactionId that) {
if (! Equals(this.Value, that.Value)) return false;
if (! Equals(this.ConnectionId, that.ConnectionId)) return false;
return true;
}
public override string ToString() {
return GetType().Name + "["
+ " Value=" + Value
+ " ConnectionId=" + ConnectionId
+ " ]";
}
public override byte GetDataStructureType() {
return ID_LocalTransactionId;
}
// Properties
public long Value
{
get { return value; }
set { this.value = value; }
}
public ConnectionId ConnectionId
{
get { return connectionId; }
set { this.connectionId = value; }
}
}
}

File diff suppressed because one or more lines are too long

View File

@ -1 +1,111 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for MessageAck // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class MessageAck : BaseCommand { public const byte ID_MessageAck = 22; ActiveMQDestination destination; TransactionId transactionId; ConsumerId consumerId; byte ackType; MessageId firstMessageId; MessageId lastMessageId; int messageCount; public override string ToString() { return GetType().Name + "[" + " Destination=" + Destination + " TransactionId=" + TransactionId + " ConsumerId=" + ConsumerId + " AckType=" + AckType + " FirstMessageId=" + FirstMessageId + " LastMessageId=" + LastMessageId + " MessageCount=" + MessageCount + " ]"; } public override byte GetDataStructureType() { return ID_MessageAck; } // Properties public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public TransactionId TransactionId { get { return transactionId; } set { this.transactionId = value; } } public ConsumerId ConsumerId { get { return consumerId; } set { this.consumerId = value; } } public byte AckType { get { return ackType; } set { this.ackType = value; } } public MessageId FirstMessageId { get { return firstMessageId; } set { this.firstMessageId = value; } } public MessageId LastMessageId { get { return lastMessageId; } set { this.lastMessageId = value; } } public int MessageCount { get { return messageCount; } set { this.messageCount = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for MessageAck
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class MessageAck : BaseCommand
{
public const byte ID_MessageAck = 22;
ActiveMQDestination destination;
TransactionId transactionId;
ConsumerId consumerId;
byte ackType;
MessageId firstMessageId;
MessageId lastMessageId;
int messageCount;
public override string ToString() {
return GetType().Name + "["
+ " Destination=" + Destination
+ " TransactionId=" + TransactionId
+ " ConsumerId=" + ConsumerId
+ " AckType=" + AckType
+ " FirstMessageId=" + FirstMessageId
+ " LastMessageId=" + LastMessageId
+ " MessageCount=" + MessageCount
+ " ]";
}
public override byte GetDataStructureType() {
return ID_MessageAck;
}
// Properties
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public TransactionId TransactionId
{
get { return transactionId; }
set { this.transactionId = value; }
}
public ConsumerId ConsumerId
{
get { return consumerId; }
set { this.consumerId = value; }
}
public byte AckType
{
get { return ackType; }
set { this.ackType = value; }
}
public MessageId FirstMessageId
{
get { return firstMessageId; }
set { this.firstMessageId = value; }
}
public MessageId LastMessageId
{
get { return lastMessageId; }
set { this.lastMessageId = value; }
}
public int MessageCount
{
get { return messageCount; }
set { this.messageCount = value; }
}
}
}

View File

@ -1 +1,87 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for MessageDispatch // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class MessageDispatch : BaseCommand { public const byte ID_MessageDispatch = 21; ConsumerId consumerId; ActiveMQDestination destination; Message message; int redeliveryCounter; public override string ToString() { return GetType().Name + "[" + " ConsumerId=" + ConsumerId + " Destination=" + Destination + " Message=" + Message + " RedeliveryCounter=" + RedeliveryCounter + " ]"; } public override byte GetDataStructureType() { return ID_MessageDispatch; } // Properties public ConsumerId ConsumerId { get { return consumerId; } set { this.consumerId = value; } } public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public Message Message { get { return message; } set { this.message = value; } } public int RedeliveryCounter { get { return redeliveryCounter; } set { this.redeliveryCounter = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for MessageDispatch
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class MessageDispatch : BaseCommand
{
public const byte ID_MessageDispatch = 21;
ConsumerId consumerId;
ActiveMQDestination destination;
Message message;
int redeliveryCounter;
public override string ToString() {
return GetType().Name + "["
+ " ConsumerId=" + ConsumerId
+ " Destination=" + Destination
+ " Message=" + Message
+ " RedeliveryCounter=" + RedeliveryCounter
+ " ]";
}
public override byte GetDataStructureType() {
return ID_MessageDispatch;
}
// Properties
public ConsumerId ConsumerId
{
get { return consumerId; }
set { this.consumerId = value; }
}
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public Message Message
{
get { return message; }
set { this.message = value; }
}
public int RedeliveryCounter
{
get { return redeliveryCounter; }
set { this.redeliveryCounter = value; }
}
}
}

View File

@ -1 +1,87 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for MessageDispatchNotification // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class MessageDispatchNotification : BaseCommand { public const byte ID_MessageDispatchNotification = 90; ConsumerId consumerId; ActiveMQDestination destination; long deliverySequenceId; MessageId messageId; public override string ToString() { return GetType().Name + "[" + " ConsumerId=" + ConsumerId + " Destination=" + Destination + " DeliverySequenceId=" + DeliverySequenceId + " MessageId=" + MessageId + " ]"; } public override byte GetDataStructureType() { return ID_MessageDispatchNotification; } // Properties public ConsumerId ConsumerId { get { return consumerId; } set { this.consumerId = value; } } public ActiveMQDestination Destination { get { return destination; } set { this.destination = value; } } public long DeliverySequenceId { get { return deliverySequenceId; } set { this.deliverySequenceId = value; } } public MessageId MessageId { get { return messageId; } set { this.messageId = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for MessageDispatchNotification
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class MessageDispatchNotification : BaseCommand
{
public const byte ID_MessageDispatchNotification = 90;
ConsumerId consumerId;
ActiveMQDestination destination;
long deliverySequenceId;
MessageId messageId;
public override string ToString() {
return GetType().Name + "["
+ " ConsumerId=" + ConsumerId
+ " Destination=" + Destination
+ " DeliverySequenceId=" + DeliverySequenceId
+ " MessageId=" + MessageId
+ " ]";
}
public override byte GetDataStructureType() {
return ID_MessageDispatchNotification;
}
// Properties
public ConsumerId ConsumerId
{
get { return consumerId; }
set { this.consumerId = value; }
}
public ActiveMQDestination Destination
{
get { return destination; }
set { this.destination = value; }
}
public long DeliverySequenceId
{
get { return deliverySequenceId; }
set { this.deliverySequenceId = value; }
}
public MessageId MessageId
{
get { return messageId; }
set { this.messageId = value; }
}
}
}

View File

@ -1 +1,105 @@
/* * Copyright 2006 The Apache Software Foundation or its licensors, as * applicable. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ using System; using System.Collections; using ActiveMQ.OpenWire; using ActiveMQ.Commands; namespace ActiveMQ.Commands { // // Marshalling code for Open Wire Format for MessageId // // // NOTE!: This file is autogenerated - do not modify! // if you need to make a change, please see the Groovy scripts in the // activemq-core module // public class MessageId : AbstractCommand, DataStructure { public const byte ID_MessageId = 110; ProducerId producerId; long producerSequenceId; long brokerSequenceId; public override int GetHashCode() { int answer = 0; answer = (answer * 37) + HashCode(ProducerId); answer = (answer * 37) + HashCode(ProducerSequenceId); answer = (answer * 37) + HashCode(BrokerSequenceId); return answer; } public override bool Equals(object that) { if (that is MessageId) { return Equals((MessageId) that); } return false; } public virtual bool Equals(MessageId that) { if (! Equals(this.ProducerId, that.ProducerId)) return false; if (! Equals(this.ProducerSequenceId, that.ProducerSequenceId)) return false; if (! Equals(this.BrokerSequenceId, that.BrokerSequenceId)) return false; return true; } public override string ToString() { return GetType().Name + "[" + " ProducerId=" + ProducerId + " ProducerSequenceId=" + ProducerSequenceId + " BrokerSequenceId=" + BrokerSequenceId + " ]"; } public override byte GetDataStructureType() { return ID_MessageId; } // Properties public ProducerId ProducerId { get { return producerId; } set { this.producerId = value; } } public long ProducerSequenceId { get { return producerSequenceId; } set { this.producerSequenceId = value; } } public long BrokerSequenceId { get { return brokerSequenceId; } set { this.brokerSequenceId = value; } } } } /*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System;
using System.Collections;
using ActiveMQ.OpenWire;
using ActiveMQ.Commands;
namespace ActiveMQ.Commands
{
//
// Marshalling code for Open Wire Format for MessageId
//
//
// NOTE!: This file is autogenerated - do not modify!
// if you need to make a change, please see the Groovy scripts in the
// activemq-core module
//
public class MessageId : AbstractCommand, DataStructure
{
public const byte ID_MessageId = 110;
ProducerId producerId;
long producerSequenceId;
long brokerSequenceId;
public override int GetHashCode() {
int answer = 0;
answer = (answer * 37) + HashCode(ProducerId);
answer = (answer * 37) + HashCode(ProducerSequenceId);
answer = (answer * 37) + HashCode(BrokerSequenceId);
return answer;
}
public override bool Equals(object that) {
if (that is MessageId) {
return Equals((MessageId) that);
}
return false;
}
public virtual bool Equals(MessageId that) {
if (! Equals(this.ProducerId, that.ProducerId)) return false;
if (! Equals(this.ProducerSequenceId, that.ProducerSequenceId)) return false;
if (! Equals(this.BrokerSequenceId, that.BrokerSequenceId)) return false;
return true;
}
public override string ToString() {
return GetType().Name + "["
+ " ProducerId=" + ProducerId
+ " ProducerSequenceId=" + ProducerSequenceId
+ " BrokerSequenceId=" + BrokerSequenceId
+ " ]";
}
public override byte GetDataStructureType() {
return ID_MessageId;
}
// Properties
public ProducerId ProducerId
{
get { return producerId; }
set { this.producerId = value; }
}
public long ProducerSequenceId
{
get { return producerSequenceId; }
set { this.producerSequenceId = value; }
}
public long BrokerSequenceId
{
get { return brokerSequenceId; }
set { this.brokerSequenceId = value; }
}
}
}

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