Intermittent failure of ReactorIntegrationTest

[jamesnetherton]

A frequent offender on the stability build:

java.lang.AssertionError
	at org.wildfly.camel.test.reactor.ReactorIntegrationTest.testToFunction(ReactorIntegrationTest.java:405)

�[0m�[0m00:18:14,769 INFO  [org.wildfly.extension.camel.WildFlyCamelContext] (pool-2-thread-4) Route: route702 started and consuming from: reactive-streams://ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-1
�[0m�[32m00:18:14,771 DEBUG [org.apache.camel.processor.SendProcessor] (Camel (camel-384) thread #565 - reactive-streams://ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-1) >>>> bean://hello Exchange[ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-2]
�[0m�[32m00:18:14,776 DEBUG [org.apache.camel.processor.SendProcessor] (Camel (camel-384) thread #565 - reactive-streams://ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-1) >>>> bean://hello Exchange[ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-3]
�[0m�[32m00:18:14,776 DEBUG [org.apache.camel.processor.SendProcessor] (Camel (camel-384) thread #565 - reactive-streams://ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-1) >>>> bean://hello Exchange[ID-fabric8-slave02-dmz-b-mwc-hst-phx2-redhat-com-1511067149304-383-4]
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) Exception in thread "Camel (camel-384) thread #566 - CamelReactiveStreamsWorker" reactor.core.Exceptions$ErrorCallbackNotImplemented: org.junit.ComparisonFailure: expected:<Hello [1]> but was:<Hello [3]>
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) Caused by: org.junit.ComparisonFailure: expected:<Hello [1]> but was:<Hello [3]>
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.junit.Assert.assertEquals(Assert.java:115)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.junit.Assert.assertEquals(Assert.java:144)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.wildfly.camel.test.reactor.ReactorIntegrationTest.lambda$testToFunction$22(ReactorIntegrationTest.java:401)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:165)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at reactor.core.publisher.FluxFlatMap$FlatMapMain.innerNext(FluxFlatMap.java:778)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:919)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.apache.camel.component.reactive.streams.util.ConvertingPublisher$1.onNext(ConvertingPublisher.java:94)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.apache.camel.component.reactive.streams.util.ConvertingPublisher$1.onNext(ConvertingPublisher.java:53)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.apache.camel.component.reactive.streams.engine.DelayedMonoPublisher$MonoSubscription.flush(DelayedMonoPublisher.java:172)
�[0m�[31m00:18:14,790 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at org.apache.camel.component.reactive.streams.engine.DelayedMonoPublisher.lambda$flushCycle$0(DelayedMonoPublisher.java:102)
�[0m�[31m00:18:14,791 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
�[0m�[31m00:18:14,791 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
�[0m�[31m00:18:14,791 ERROR [stderr] (Camel (camel-384) thread #566 - CamelReactiveStreamsWorker) 	at java.lang.Thread.run(Thread.java:745)