Skip to content

Commit

Permalink
Increase timeouts
Browse files Browse the repository at this point in the history
  • Loading branch information
purplegen committed Feb 6, 2025
1 parent 855e190 commit 8cdea85
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/main/java/com/exactpro/th2/FixHandler.java
Original file line number Diff line number Diff line change
Expand Up @@ -1772,7 +1772,7 @@ private Map<String, String> negativeStructureOtgoingProcessor(ByteBuf message, M
metadata.put(ENCODE_MODE_PROPERTY_NAME, DIRTY_ENCODE_MODE_NAME);

long start = System.currentTimeMillis();
while(!enabled.get() && (System.currentTimeMillis() - start) < 1000 ) {
while(!enabled.get() && (System.currentTimeMillis() - start) < 1100 ) {
try {
Thread.sleep(10);
} catch (InterruptedException ignored) { }
Expand Down Expand Up @@ -2294,7 +2294,7 @@ private void cleanupTransformMessageStrategy() {

private void corruptAndSendMessage(ByteBuf buf, Function1<ByteBuf, Map<String, String>> corruption) {
long start = System.currentTimeMillis();
while(!enabled.get() && (System.currentTimeMillis() - start) < 500 ) {
while(!enabled.get() && (System.currentTimeMillis() - start) < 1100 ) {
try {
Thread.sleep(10);
} catch (InterruptedException ignored) { }
Expand Down

0 comments on commit 8cdea85

Please sign in to comment.