Skip to content

Commit 95a9548

Browse files
fix(tests): don't use a queue type to prevent consumers of other tests to steal messages
1 parent a57dafb commit 95a9548

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/test/java/io/kestra/plugin/aws/s3/TriggerTest.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ void deleteAction() throws Exception {
6161
AtomicReference<Execution> last = new AtomicReference<>();
6262

6363
// wait for execution
64-
executionQueue.receive(TriggerTest.class, executionWithError -> {
64+
executionQueue.receive(executionWithError -> {
6565
Execution execution = executionWithError.getLeft();
6666

6767
if (execution.getFlowId().equals("s3-listen")) {
@@ -106,7 +106,7 @@ void noneAction() throws Exception {
106106
// wait for execution
107107
CountDownLatch queueCount = new CountDownLatch(1);
108108
AtomicReference<Execution> last = new AtomicReference<>();
109-
executionQueue.receive(TriggerTest.class, executionWithError -> {
109+
executionQueue.receive(executionWithError -> {
110110
Execution execution = executionWithError.getLeft();
111111

112112
if (execution.getFlowId().equals("s3-listen-none-action")) {

0 commit comments

Comments
 (0)