chibenwa opened a new pull request, #2550:
URL: https://github.com/apache/james-project/pull/2550
Otherwize:
```
{
"timestamp": "2024-12-06T07:45:29.803Z",
"level": "ERROR",
"thread": "s1-io-3",
"mdc": {
"eventId": "ac688927-c5f7-47d3-832b-6805caf147ea",
"eventClass": "org.apache.james.jmap.change.StateChangeEvent",
"user": "[email protected]",
"registrationKeys":
"[AccountIdRegistrationKey(org.apache.james.jmap.api.model.AccountId@9171bb2e)]"
},
"logger": "org.apache.james.events.TMailEventDispatcher",
"message": "Exception happens when dispatching event",
"context": "default",
"exception": "reactor.core.publisher.Sinks$EmissionException: Spec. Rule
1.3 - onSubscribe, onNext, onError and onComplete signaled to a Subscriber MUST
be signaled serially.\n\tat
reactor.core.publisher.InternalManySink.emitNext(InternalManySink.java:56)\n\tat
org.apache.james.jmap.change.StateChangeListener.$anonfun$reactiveEvent$2(StateChangeListener.scala:37)\n\tat
org.apache.james.jmap.change.StateChangeListener.$anonfun$reactiveEvent$2$adapted(StateChangeListener.scala:37)\n\tat
scala.Option.foreach(Option.scala:437)\n\tat
org.apache.james.jmap.change.StateChangeListener.$anonfun$reactiveEvent$1(StateChangeListener.scala:37)\n\tat
org.apache.james.jmap.change.StateChangeListener.$anonfun$reactiveEvent$1$adapted(StateChangeListener.scala:35)\n\tat
reactor.core.publisher.MonoCallable$MonoCallableSubscription.request(MonoCallable.java:137)\n\tat
reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72)\n\tat
reactor.core.publ
isher.MonoCallable.subscribe(MonoCallable.java:48)\n\tat
reactor.core.publisher.Mono.subscribe(Mono.java:4568)\n\tat
reactor.core.publisher.MonoIgnorePublisher.subscribe(MonoIgnorePublisher.java:57)\n\tat
reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76)\n\tat
reactor.core.publisher.MonoUsing.subscribe(MonoUsing.java:109)\n\tat
reactor.core.publisher.Mono.subscribe(Mono.java:4568)\n\tat
reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:430)\n\tat
reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:113)\n\tat
reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmit(FluxFlatMap.java:547)\n\tat
reactor.core.publisher.FluxFlatMap$FlatMapInner.onNext(FluxFlatMap.java:988)\n\tat
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:129)\n\tat
reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:335)\n\tat
reactor.core.publisher.FluxIterable$IterableS
ubscription.request(FluxIterable.java:294)\n\tat
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:171)\n\tat
reactor.core.publisher.FluxFlatMap$FlatMapInner.onSubscribe(FluxFlatMap.java:968)\n\tat
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:96)\n\tat
reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201)\n\tat
reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83)\n\tat
reactor.core.publisher.Flux.subscribe(Flux.java:8840)\n\tat
reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:430)\n\tat
reactor.core.publisher.FluxIterable$IterableSubscription.slowPath(FluxIterable.java:335)\n\tat
reactor.core.publisher.FluxIterable$IterableSubscription.request(FluxIterable.java:294)\n\tat
reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:373)\n\tat
reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201)\n\tat
reactor.core.
publisher.FluxIterable.subscribe(FluxIterable.java:83)\n\tat
reactor.core.publisher.Mono.subscribe(Mono.java:4568)\n\tat
reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.onComplete(FluxConcatArray.java:238)\n\tat
reactor.core.publisher.FluxConcatArray.subscribe(FluxConcatArray.java:79)\n\tat
reactor.core.publisher.MonoFromFluxOperator.subscribe(MonoFromFluxOperator.java:83)\n\tat
reactor.core.publisher.MonoUsing.subscribe(MonoUsing.java:109)\n\tat
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241)\n\tat
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204)\n\tat
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231)\n\tat
reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)\n\tat
reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89)\n\tat
reactor.core.publ
isher.MonoNext$NextSubscriber.onComplete(MonoNext.java:102)\n\tat
com.datastax.dse.driver.internal.core.cql.reactive.ReactiveResultSetSubscription.doOnComplete(ReactiveResultSetSubscription.java:379)\n\tat
com.datastax.dse.driver.internal.core.cql.reactive.ReactiveResultSetSubscription.drain(ReactiveResultSetSubscription.java:242)\n\tat
com.datastax.dse.driver.internal.core.cql.reactive.ReactiveResultSetSubscription.lambda$fetchNextPageAndEnqueue$2(ReactiveResultSetSubscription.java:360)\n\tat
java.base/java.util.concurrent.CompletableFuture$UniAccept.tryFire(Unknown
Source)\n\tat
java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown
Source)\n\tat java.base/java.util.concurrent.CompletableFuture.complete(Unknown
Source)\n\tat
com.datastax.oss.driver.internal.core.cql.CqlRequestHandler.setFinalResult(CqlRequestHandler.java:326)\n\tat
com.datastax.oss.driver.internal.core.cql.CqlRequestHandler.access$1500(CqlRequestHandler.java:97)\n\tat
com.datastax.oss.driver.interna
l.core.cql.CqlRequestHandler$NodeResponseCallback.onResponse(CqlRequestHandler.java:657)\n\tat
com.datastax.oss.driver.internal.core.channel.InFlightHandler.channelRead(InFlightHandler.java:259)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)\n\tat
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)\n\tat
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:289)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:442)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)\n\tat
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)\n\tat
io.netty.handler.codec.MessageToMessageDecoder.
channelRead(MessageToMessageDecoder.java:103)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)\n\tat
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)\n\tat
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)\n\tat
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)\n\tat
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)\n\tat
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1
407)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)\n\tat
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)\n\tat
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918)\n\tat
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)\n\tat
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788)\n\tat
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724)\n\tat
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650)\n\tat
io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)\n\tat
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)\n\tat
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)\n\tat
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadL
ocalRunnable.java:30)\n\tat java.base/java.lang.Thread.run(Unknown Source)\n"
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
