Commit 553c863a authored by afreyssin's avatar afreyssin
Browse files

No longer define nbMsgsReceiveSinceCreation in Destination as it is only...

No longer define nbMsgsReceiveSinceCreation in Destination as it is only needed in Topic class hierarchy (JORAM-230).
parent 8be91125
......@@ -340,7 +340,6 @@ public abstract class Destination extends Agent implements DestinationMBean, TxD
*/
public long creationDate = System.currentTimeMillis();
protected long nbMsgsReceiveSinceCreation = 0;
protected long nbMsgsDeliverSinceCreation = 0;
protected long nbMsgsSentToDMQSinceCreation = 0;
......@@ -875,7 +874,6 @@ public abstract class Destination extends Agent implements DestinationMBean, TxD
out.writeObject(clients);
out.writeObject(dmqId);
out.writeLong(creationDate);
out.writeLong(nbMsgsReceiveSinceCreation);
out.writeLong(nbMsgsDeliverSinceCreation);
out.writeLong(nbMsgsSentToDMQSinceCreation);
out.writeLong(period);
......@@ -892,7 +890,6 @@ public abstract class Destination extends Agent implements DestinationMBean, TxD
dmqId = (AgentId)in.readObject();
strbuf = new StringBuffer();
creationDate = in.readLong();
nbMsgsReceiveSinceCreation = in.readLong();
nbMsgsDeliverSinceCreation = in.readLong();
nbMsgsSentToDMQSinceCreation = in.readLong();
period = in.readLong();
......@@ -1366,7 +1363,6 @@ public abstract class Destination extends Agent implements DestinationMBean, TxD
dmqId.encode(encoder);
}
encoder.encodeUnsignedLong(creationDate);
encoder.encodeUnsignedLong(nbMsgsReceiveSinceCreation);
encoder.encodeUnsignedLong(nbMsgsDeliverSinceCreation);
encoder.encodeUnsignedLong(nbMsgsSentToDMQSinceCreation);
encoder.encodeUnsignedLong(period);
......@@ -1405,7 +1401,6 @@ public abstract class Destination extends Agent implements DestinationMBean, TxD
dmqId.decode(decoder);
}
creationDate = decoder.decodeUnsignedLong();
nbMsgsReceiveSinceCreation = decoder.decodeUnsignedLong();
nbMsgsDeliverSinceCreation = decoder.decodeUnsignedLong();
nbMsgsSentToDMQSinceCreation = decoder.decodeUnsignedLong();
period = decoder.decodeUnsignedLong();
......
......@@ -114,6 +114,8 @@ public class Topic extends Destination implements TopicMBean {
/** Internal boolean used for tagging local sendings. */
protected transient boolean alreadySentLocally;
protected long nbMsgsReceiveSinceCreation = 0;
public Topic() {
}
......@@ -639,7 +641,7 @@ public class Topic extends Destination implements TopicMBean {
List deliverables;
Message message;
nbMsgsReceiveSinceCreation = nbMsgsReceiveSinceCreation + messages.size();
nbMsgsReceiveSinceCreation += messages.size();
// interceptors process
if (interceptorsAvailable()) {
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment