[Java] Poll for error response from archive in RecordedBasicPublisher.

clockskew · Feb 26, 2018 · 89cdafe · 89cdafe
1 parent dbed999
commit 89cdafe
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/aeron-samples/src/main/java/io/aeron/samples/archive/RecordedBasicPublisher.java b/aeron-samples/src/main/java/io/aeron/samples/archive/RecordedBasicPublisher.java
@@ -86,6 +86,12 @@ public static void main(final String[] args) throws Exception
                     final long result = publication.offer(BUFFER, 0, messageBytes.length);
                     checkResult(result);
 
+                    final String errorMessage = archive.pollForErrorResponse();
+                    if (null != errorMessage)
+                    {
+                        throw new IllegalStateException(errorMessage);
+                    }
+
                     Thread.sleep(TimeUnit.SECONDS.toMillis(1));
                 }