File tree 2 files changed +4
-0
lines changed
aeron-client/src/main/java/io/aeron
2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -437,6 +437,8 @@ public long offer(
437
437
* available.
438
438
* <p>
439
439
* <b>Note:</b> This method can only be used for message lengths less than MTU length minus header.
440
+ * If the claim is held for more than the aeron.publication.unblock.timeout system property then the driver will
441
+ * assume the publication thread is dead and will unblock the claim thus allowing other threads to make progress.
440
442
* <pre>{@code
441
443
* final ExclusiveBufferClaim bufferClaim = new ExclusiveBufferClaim();
442
444
*
Original file line number Diff line number Diff line change @@ -417,6 +417,8 @@ public long offer(
417
417
* Once the message has been written then {@link BufferClaim#commit()} should be called thus making it available.
418
418
* <p>
419
419
* <b>Note:</b> This method can only be used for message lengths less than MTU length minus header.
420
+ * If the claim is held for more than the aeron.publication.unblock.timeout system property then the driver will
421
+ * assume the publication thread is dead and will unblock the claim thus allowing other threads to make progress.
420
422
* <pre>{@code
421
423
* final BufferClaim bufferClaim = new BufferClaim(); // Can be stored and reused to avoid allocation
422
424
*
You can’t perform that action at this time.
0 commit comments