Apache Aries Remote Service Admin で記録キューを使用するアダプターを作成しています。単一のスレッドのみを使用すると、正常に機能します。複数のスレッドを使用すると、以下のような例外が発生します。
私が間違っていることは何ですか?
参考までに、これは私のコードです: https://github.com/cschneider/rsa-chronicle-provider/blob/master/src/test/java/org/apache/aries/rsa/provider/chronicle/ChronicleProviderTest.java
エグゼキューターのスレッド数を増やすと、例外が発生する可能性があります。
Exception in thread "pool-3-thread-2" java.nio.BufferOverflowException
at net.openhft.chronicle.bytes.AbstractBytes.writePosition(AbstractBytes.java:182)
at net.openhft.chronicle.bytes.AbstractBytes.writePosition(AbstractBytes.java:29)
at net.openhft.chronicle.wire.AbstractWire.writeHeader0(AbstractWire.java:183)
at net.openhft.chronicle.wire.AbstractWire.writeHeader(AbstractWire.java:171)
at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.append(SingleChronicleQueueExcerpts.java:252)
at net.openhft.chronicle.queue.impl.single.SingleChronicleQueueExcerpts$StoreAppender.writeBytes(SingleChronicleQueueExcerpts.java:153)
at org.apache.aries.rsa.provider.chronicle.ChronicleInvocationHandler.invoke(ChronicleInvocationHandler.java:45)
at com.sun.proxy.$Proxy7.callOneWay(Unknown Source)
at org.apache.aries.rsa.provider.chronicle.ChronicleProviderTest$1.run(ChronicleProviderTest.java:87)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)