sqs messaging connector extension

[scrocquesel]

Follow up from #1431

[scrocquesel]

@ozangunalp When running the deployment test, it passed but logs show

2024-10-11 20:19:02,676 WARN  [io.net.uti.con.DefaultPromise] (vert.x-eventloop-thread-9) An exception was thrown by software.amazon.awssdk.http.nio.netty.internal.IdleConnectionCountingChannelPool$$Lambda/0x00007858c3b7a778.operationComplete(): java.util.concurrent.RejectedExecutionException: event executor terminated
        at io.netty.util.concurrent.SingleThreadEventExecutor.reject(SingleThreadEventExecutor.java:931)
        at io.netty.util.concurrent.SingleThreadEventExecutor.offerTask(SingleThreadEventExecutor.java:350)
        at io.netty.util.concurrent.SingleThreadEventExecutor.addTask(SingleThreadEventExecutor.java:343)
        at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:833)
        at io.netty.util.concurrent.SingleThreadEventExecutor.execute0(SingleThreadEventExecutor.java:824)
        at io.netty.util.concurrent.SingleThreadEventExecutor.execute(SingleThreadEventExecutor.java:814)
        at java.base/java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:123)
        at io.netty.util.concurrent.AbstractEventExecutor.submit(AbstractEventExecutor.java:117)
        at software.amazon.awssdk.http.nio.netty.internal.utils.NettyUtils.doInEventLoop(NettyUtils.java:254)
        at software.amazon.awssdk.http.nio.netty.internal.IdleConnectionCountingChannelPool.channelClosed(IdleConnectionCountingChannelPool.java:189)
        at software.amazon.awssdk.http.nio.netty.internal.IdleConnectionCountingChannelPool.lambda$addUpdateIdleCountOnCloseListener$4(IdleConnectionCountingChannelPool.java:127)
        at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:590)
        at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:557)
        at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:492)
        at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:636)
        at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:625)
        at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:105)
        at io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at io.netty.channel.AbstractChannel$CloseFuture.setClosed(AbstractChannel.java:1161)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.doClose0(AbstractChannel.java:753)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:729)
        at io.netty.channel.AbstractChannel$AbstractUnsafe.close(AbstractChannel.java:619)
        at io.netty.channel.nio.NioEventLoop.closeAll(NioEventLoop.java:838)
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:595)
        at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994)
        at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.base/java.lang.Thread.run(Thread.java:1570)

Is it expected ?

[ozangunalp]

I need to check, probably the connector is closed abruptly while still polling. It may be something to see on the connector code.

[scrocquesel]

@all-contributors please add @ozangunalp for code

[allcontributors]

@scrocquesel

I've put up a pull request to add @ozangunalp! 🎉