Fix for bigger retry interval

This commit is contained in:
romanman 2014-07-14 21:47:13 +03:00
parent ffef5a8bb9
commit 178f3ae7b0
2 changed files with 2 additions and 1 deletions

View File

@ -74,6 +74,7 @@ public class MessageQueue {
if (msg.getClass() == waitingMessage.getAnswerMessage()){ if (msg.getClass() == waitingMessage.getAnswerMessage()){
messageRoundtrip.answer(); messageRoundtrip.answer();
logger.debug("Message round trip covered: [ {} ] ", messageRoundtrip.getMsg().getMessageName());
} }
} }
} }

View File

@ -39,7 +39,7 @@ public class MessageRoundtrip {
public void saveTime(){lastTimestamp = System.currentTimeMillis();} public void saveTime(){lastTimestamp = System.currentTimeMillis();}
public boolean hasToRetry(){ public boolean hasToRetry(){
return 5000 < System.currentTimeMillis() - lastTimestamp; return 20000 < System.currentTimeMillis() - lastTimestamp;
} }
public Message getMsg() { public Message getMsg() {