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

added support for properties brokerInTime and brokerOutTime 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561028 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-07-30 16:07:17 +00:00
parent a401575569
commit b3eb9a5e5b
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-core/src/main/java/org/apache/activemq/openwire/v3/MessageMarshaller.java
View File

@ -103,6 +103,8 @@ public abstract class MessageMarshaller extends BaseCommandMarshaller {
else { else {
info.setCluster(null); info.setCluster(null);
} }
info.setBrokerInTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.setBrokerOutTime(tightUnmarshalLong(wireFormat, dataIn, bs));
info.afterUnmarshall(wireFormat); info.afterUnmarshall(wireFormat);
@ -143,6 +145,8 @@ public abstract class MessageMarshaller extends BaseCommandMarshaller {
bs.writeBoolean(info.isRecievedByDFBridge()); bs.writeBoolean(info.isRecievedByDFBridge());
bs.writeBoolean(info.isDroppable()); bs.writeBoolean(info.isDroppable());
rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs);
rc+=tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs);
rc+=tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs);
return rc + 9; return rc + 9;
} }
@ -185,6 +189,8 @@ public abstract class MessageMarshaller extends BaseCommandMarshaller {
bs.readBoolean(); bs.readBoolean();
bs.readBoolean(); bs.readBoolean();
tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs);
tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs);
tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs);
info.afterMarshall(wireFormat); info.afterMarshall(wireFormat);
@ -253,6 +259,8 @@ public abstract class MessageMarshaller extends BaseCommandMarshaller {
else { else {
info.setCluster(null); info.setCluster(null);
} }
info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));
info.afterUnmarshall(wireFormat); info.afterUnmarshall(wireFormat);
@ -296,6 +304,8 @@ public abstract class MessageMarshaller extends BaseCommandMarshaller {
dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isRecievedByDFBridge());
dataOut.writeBoolean(info.isDroppable()); dataOut.writeBoolean(info.isDroppable());
looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut);
looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut);
looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut);
} }
} }

2
activemq-core/src/test/java/org/apache/activemq/openwire/v3/MessageTestSupport.java
View File

@ -88,5 +88,7 @@ public abstract class MessageTestSupport extends BaseCommandTestSupport {
} }
info.setCluster(value); info.setCluster(value);
} }
info.setBrokerInTime(4);
info.setBrokerOutTime(5);
} }
} }