diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java index 21bfc4717..6fb3d09e9 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java @@ -175,13 +175,18 @@ class ClearingMemberCategoryServiceTest { String listenerID = iMap.addEntryListener((EntryRemovedListener) entryEvent -> { System.out.println("Checking If removed.."); + try { + waiter.wait(100); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } synchronized (waiter) { waiter.notify(); } }, false); synchronized (waiter) { - waiter.wait(1000); + waiter.wait(100); } //ASSERT diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java index 20e96420e..83c3e92e7 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyInfoServiceTest.java @@ -135,13 +135,18 @@ class CompanyInfoServiceTest { String listenerID = iMap.addEntryListener((EntryUpdatedListener) entryEvent -> { System.out.println("Checking If removed.."); + try { + waiter.wait(100); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } synchronized (waiter) { waiter.notify(); } }, false); synchronized (waiter) { - waiter.wait(1000); + waiter.wait(100); } //ASSERT diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java index f9b714d8a..f9b9f73aa 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java @@ -99,6 +99,11 @@ class CompanyServiceTest { String listenerID = iMap.addEntryListener((EntryRemovedListener) entryEvent -> { System.out.println("Checking If removed.."); + try { + waiter.wait(100); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } synchronized (waiter) { waiter.notify(); } diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java index bdee7706b..15654ba28 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanySymbolServiceTest.java @@ -109,13 +109,18 @@ class CompanySymbolServiceTest { String listenerID = iMap.addEntryListener((EntryUpdatedListener) entryEvent -> { System.out.println("Checking If removed.."); + try { + waiter.wait(100); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } synchronized (waiter) { waiter.notify(); } }, false); synchronized (waiter) { - waiter.wait(1000); + waiter.wait(100); } //ASSERT diff --git a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java index 4d1e3b397..bc7d93160 100644 --- a/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java +++ b/clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ContactServiceTest.java @@ -107,13 +107,18 @@ class ContactServiceTest { String listenerID = iMap.addEntryListener((EntryUpdatedListener) entryEvent -> { System.out.println("Checking If removed.."); + try { + waiter.wait(100); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } synchronized (waiter) { waiter.notify(); } }, false); synchronized (waiter) { - waiter.wait(1000); + waiter.wait(100); } //ASSERT