|
1 | 1 | /*
|
2 |
| - * Copyright (c) 2020 Oracle and/or its affiliates. |
| 2 | + * Copyright (c) 2020, 2023 Oracle and/or its affiliates. |
3 | 3 | *
|
4 | 4 | * Licensed under the Apache License, Version 2.0 (the "License");
|
5 | 5 | * you may not use this file except in compliance with the License.
|
@@ -255,7 +255,7 @@ public static class ChannelBytes extends AbstractSampleBean {
|
255 | 255 |
|
256 | 256 | public void await(long timeout) {
|
257 | 257 | try {
|
258 |
| - assertTrue(countDownLatch.await(timeout, TimeUnit.MILLISECONDS)); |
| 258 | + assertThat(countDownLatch.await(timeout, TimeUnit.MILLISECONDS), is(true)); |
259 | 259 | } catch (InterruptedException e) {
|
260 | 260 | throw new RuntimeException(e);
|
261 | 261 | }
|
@@ -292,7 +292,7 @@ public static class ChannelProperties extends AbstractSampleBean {
|
292 | 292 |
|
293 | 293 | public void await(long timeout) {
|
294 | 294 | try {
|
295 |
| - assertTrue(countDownLatch.await(timeout, TimeUnit.MILLISECONDS)); |
| 295 | + assertThat(countDownLatch.await(timeout, TimeUnit.MILLISECONDS), is(true)); |
296 | 296 | } catch (InterruptedException e) {
|
297 | 297 | throw new RuntimeException(e);
|
298 | 298 | }
|
@@ -337,7 +337,7 @@ public static class ChannelCustomMapper extends AbstractSampleBean {
|
337 | 337 |
|
338 | 338 | public void await(long timeout) {
|
339 | 339 | try {
|
340 |
| - assertTrue(countDownLatch.await(timeout, TimeUnit.MILLISECONDS)); |
| 340 | + assertThat(countDownLatch.await(timeout, TimeUnit.MILLISECONDS), is(true)); |
341 | 341 | } catch (InterruptedException e) {
|
342 | 342 | throw new RuntimeException(e);
|
343 | 343 | }
|
@@ -381,7 +381,7 @@ public static class ChannelDerivedMessage extends AbstractSampleBean {
|
381 | 381 |
|
382 | 382 | public void await(long timeout) {
|
383 | 383 | try {
|
384 |
| - assertTrue(countDownLatch.await(timeout, TimeUnit.MILLISECONDS)); |
| 384 | + assertThat(countDownLatch.await(timeout, TimeUnit.MILLISECONDS), is(true)); |
385 | 385 | } catch (InterruptedException e) {
|
386 | 386 | throw new RuntimeException(e);
|
387 | 387 | }
|
|
0 commit comments