Skip to content
Snippets Groups Projects

Drop delivered messages

2 files
+ 71
8
Compare changes
  • Side-by-side
  • Inline

Files

+ 6
0
@@ -274,6 +274,12 @@ public class DisasterRouter extends ActiveRouter {
protected void transferDone(Connection con) {
super.transferDone(con);
addMessageAndHostToHistory(con.getMessage(), con.getOtherNode(getHost()));
/* was the message delivered to the final recipient? */
Message ownCopy = this.getMessage(con.getMessage().getId());
if (ownCopy != null && ownCopy.completesDelivery(con.getOtherNode(getHost()))) {
this.deleteMessage(ownCopy.getId(), false);
}
}
/**
Loading