Regression

org.eclipse.ditto.client.streaming.ThingSearchPublisherVerificationTest.stochastic_spec103_mustSignalOnMethodsSequentially

Error Message

Illegal concurrent access detected (entering critical section)! Thread[pool-88-thread-1,5,main] emited onNext(SubscriptionHasNextPage [type=thing-search.subscription.events:next, subscriptionId=4ceb25dc-0151-45ed-b271-40f36d1537a5, dittoHeaders=ImmutableDittoHeaders [{correlation-id=efa917cd-dbcf-47cc-a3cc-a24b3768be37, content-type=application/json}], items=[{"thingId":"x:0"}]]) signal, before Thread[mock-provider-1,5,main] finished its onSubscribe() signal.

Stacktrace

      java.lang.AssertionError: Illegal concurrent access detected (entering critical section)! Thread[pool-88-thread-1,5,main] emited onNext(SubscriptionHasNextPage [type=thing-search.subscription.events:next, subscriptionId=4ceb25dc-0151-45ed-b271-40f36d1537a5, dittoHeaders=ImmutableDittoHeaders [{correlation-id=efa917cd-dbcf-47cc-a3cc-a24b3768be37, content-type=application/json}], items=[{"thingId":"x:0"}]]) signal, before Thread[mock-provider-1,5,main] finished its onSubscribe() signal.
at org.testng.Assert.fail(Assert.java:110)
at org.reactivestreams.tck.TestEnvironment.flop(TestEnvironment.java:229)
at org.reactivestreams.tck.PublisherVerification$5$1$1$ConcurrentAccessBarrier.enterSignal(PublisherVerification.java:284)
at org.reactivestreams.tck.PublisherVerification$5$1$1.onNext(PublisherVerification.java:317)
at org.eclipse.ditto.client.streaming.ThingSearchSubscription.handleAdaptable(ThingSearchSubscription.java:186)
at org.eclipse.ditto.client.streaming.ThingSearchSubscription.lambda$onNext$2(ThingSearchSubscription.java:158)
at org.eclipse.ditto.client.streaming.ThingSearchSubscription.singleThreaded(ThingSearchSubscription.java:132)
at org.eclipse.ditto.client.streaming.ThingSearchSubscription.onNext(ThingSearchSubscription.java:156)
at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.lambda$withTermination$4(DefaultAdaptableBus.java:214)
at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.runConsumerAsync(DefaultAdaptableBus.java:258)
at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.publishToPersistentAdaptableSubscribers(DefaultAdaptableBus.java:283)
at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.doPublish(DefaultAdaptableBus.java:191)
at org.eclipse.ditto.client.internal.bus.DefaultAdaptableBus.publish(DefaultAdaptableBus.java:161)
at org.eclipse.ditto.client.streaming.ThingSearchPublisherVerificationTest.reply(ThingSearchPublisherVerificationTest.java:154)
at org.eclipse.ditto.client.streaming.ThingSearchPublisherVerificationTest.lambda$mockSearchBackEnd$0(ThingSearchPublisherVerificationTest.java:100)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)