style: spotless-apply on examples and recipes

These modules used Gradle's `application` plugin, which was outside the
java-library scope where spotless was applied — so their sources never
got auto-formatted. Maven now applies spotless reactor-wide, surfacing
the drift. Reformat in bulk to align with googleJavaFormat.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: nficano

examples/ack-backpressure/src/main/java/dev/arcp/examples/ackbackpressure/Main.java

@@ -16,62 +16,71 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 /**
- * Demonstrates manual ack/back-pressure: client opts out of auto-ack,
- * counts events itself, then sends a single explicit ack at the end.
+ * Demonstrates manual ack/back-pressure: client opts out of auto-ack, counts events itself, then
+ * sends a single explicit ack at the end.
  */
 public final class Main {
-    public static void main(String[] args) throws Exception {
-        MemoryTransport.Pair pair = MemoryTransport.pair();
-        ArcpRuntime runtime = ArcpRuntime.builder()
-                .agent("ticker", "1.0.0", (input, ctx) -> {
-                    for (int i = 1; i <= 20; i++) {
-                        ctx.emit(new StatusEvent("tick-" + i, null));
-                    }
-                    return JobOutcome.Success.inline(input.payload());
+  public static void main(String[] args) throws Exception {
+    MemoryTransport.Pair pair = MemoryTransport.pair();
+    ArcpRuntime runtime =
+        ArcpRuntime.builder()
+            .agent(
+                "ticker",
+                "1.0.0",
+                (input, ctx) -> {
+                  for (int i = 1; i <= 20; i++) {
+                    ctx.emit(new StatusEvent("tick-" + i, null));
+                  }
+                  return JobOutcome.Success.inline(input.payload());
                 })
-                .build();
-        runtime.accept(pair.runtime());
+            .build();
+    runtime.accept(pair.runtime());
 
-        AtomicInteger received = new AtomicInteger();
+    AtomicInteger received = new AtomicInteger();
 
-        try (ArcpClient client = ArcpClient.builder(pair.client())
-                .autoAck(false)
-                .features(EnumSet.allOf(Feature.class))
-                .build()) {
-            client.connect(Duration.ofSeconds(5));
+    try (ArcpClient client =
+        ArcpClient.builder(pair.client())
+            .autoAck(false)
+            .features(EnumSet.allOf(Feature.class))
+            .build()) {
+      client.connect(Duration.ofSeconds(5));
 
-            JobHandle handle = client.submit(
-                    ArcpClient.jobSubmit("ticker@1.0.0", JsonNodeFactory.instance.objectNode()));
+      JobHandle handle =
+          client.submit(
+              ArcpClient.jobSubmit("ticker@1.0.0", JsonNodeFactory.instance.objectNode()));
 
-            handle.events().subscribe(new Flow.Subscriber<>() {
+      handle
+          .events()
+          .subscribe(
+              new Flow.Subscriber<>() {
                 @Override
                 public void onSubscribe(Flow.Subscription s) {
-                    s.request(Long.MAX_VALUE);
+                  s.request(Long.MAX_VALUE);
                 }
 
                 @Override
                 public void onNext(EventBody body) {
-                    received.incrementAndGet();
+                  received.incrementAndGet();
                 }
 
                 @Override
                 public void onError(Throwable throwable) {}
 
                 @Override
                 public void onComplete() {}
-            });
+              });
 
-            handle.result().get(5, TimeUnit.SECONDS);
+      handle.result().get(5, TimeUnit.SECONDS);
 
-            // Allow event delivery to finish.
-            Thread.sleep(200);
+      // Allow event delivery to finish.
+      Thread.sleep(200);
 
-            assert received.get() == 20 : "expected 20 events, got " + received.get();
+      assert received.get() == 20 : "expected 20 events, got " + received.get();
 
-            // Explicit ack after processing all events.
-            client.ack(client.lastSeenSeq());
-            System.out.println("OK ack-backpressure");
-        }
-        runtime.close();
+      // Explicit ack after processing all events.
+      client.ack(client.lastSeenSeq());
+      System.out.println("OK ack-backpressure");
     }
+    runtime.close();
+  }
 }

examples/agent-versions/src/main/java/dev/arcp/examples/agentversions/Main.java

@@ -13,49 +13,57 @@
 
 /** Two registered versions; bare-name resolves to default; unknown version errors. */
 public final class Main {
-    public static void main(String[] args) throws Exception {
-        MemoryTransport.Pair pair = MemoryTransport.pair();
-        ArcpRuntime runtime = ArcpRuntime.builder()
-                .agent("code-refactor", "1.0.0",
-                        (input, ctx) -> JobOutcome.Success.inline(
-                                JsonNodeFactory.instance.objectNode().put("v", "1.0.0")))
-                .agent("code-refactor", "2.0.0",
-                        (input, ctx) -> JobOutcome.Success.inline(
-                                JsonNodeFactory.instance.objectNode().put("v", "2.0.0")))
-                .build();
-        runtime.agents().setDefault("code-refactor", "2.0.0");
-        runtime.accept(pair.runtime());
+  public static void main(String[] args) throws Exception {
+    MemoryTransport.Pair pair = MemoryTransport.pair();
+    ArcpRuntime runtime =
+        ArcpRuntime.builder()
+            .agent(
+                "code-refactor",
+                "1.0.0",
+                (input, ctx) ->
+                    JobOutcome.Success.inline(
+                        JsonNodeFactory.instance.objectNode().put("v", "1.0.0")))
+            .agent(
+                "code-refactor",
+                "2.0.0",
+                (input, ctx) ->
+                    JobOutcome.Success.inline(
+                        JsonNodeFactory.instance.objectNode().put("v", "2.0.0")))
+            .build();
+    runtime.agents().setDefault("code-refactor", "2.0.0");
+    runtime.accept(pair.runtime());
 
-        try (ArcpClient client = ArcpClient.builder(pair.client()).build()) {
-            client.connect(Duration.ofSeconds(5));
+    try (ArcpClient client = ArcpClient.builder(pair.client()).build()) {
+      client.connect(Duration.ofSeconds(5));
 
-            JobHandle pinned = client.submit(ArcpClient.jobSubmit(
-                    "code-refactor@1.0.0", JsonNodeFactory.instance.objectNode()));
-            JobResult pinnedResult = pinned.result().get(5, TimeUnit.SECONDS);
-            assert "1.0.0".equals(pinnedResult.result().get("v").asText());
-            assert "code-refactor@1.0.0".equals(pinned.resolvedAgent());
+      JobHandle pinned =
+          client.submit(
+              ArcpClient.jobSubmit("code-refactor@1.0.0", JsonNodeFactory.instance.objectNode()));
+      JobResult pinnedResult = pinned.result().get(5, TimeUnit.SECONDS);
+      assert "1.0.0".equals(pinnedResult.result().get("v").asText());
+      assert "code-refactor@1.0.0".equals(pinned.resolvedAgent());
 
-            JobHandle bare = client.submit(ArcpClient.jobSubmit(
-                    "code-refactor", JsonNodeFactory.instance.objectNode()));
-            JobResult bareResult = bare.result().get(5, TimeUnit.SECONDS);
-            assert "2.0.0".equals(bareResult.result().get("v").asText());
-            assert "code-refactor@2.0.0".equals(bare.resolvedAgent());
+      JobHandle bare =
+          client.submit(
+              ArcpClient.jobSubmit("code-refactor", JsonNodeFactory.instance.objectNode()));
+      JobResult bareResult = bare.result().get(5, TimeUnit.SECONDS);
+      assert "2.0.0".equals(bareResult.result().get("v").asText());
+      assert "code-refactor@2.0.0".equals(bare.resolvedAgent());
 
-            try {
-                client.submit(ArcpClient.jobSubmit(
-                        "code-refactor@9.9.9", JsonNodeFactory.instance.objectNode()));
-                throw new AssertionError("expected AgentVersionNotAvailableException");
-            } catch (RuntimeException e) {
-                Throwable root = e;
-                while (root.getCause() != null) {
-                    root = root.getCause();
-                }
-                assert root instanceof AgentVersionNotAvailableException
-                        : "got " + root;
-            }
-
-            System.out.println("OK agent-versions");
+      try {
+        client.submit(
+            ArcpClient.jobSubmit("code-refactor@9.9.9", JsonNodeFactory.instance.objectNode()));
+        throw new AssertionError("expected AgentVersionNotAvailableException");
+      } catch (RuntimeException e) {
+        Throwable root = e;
+        while (root.getCause() != null) {
+          root = root.getCause();
         }
-        runtime.close();
+        assert root instanceof AgentVersionNotAvailableException : "got " + root;
+      }
+
+      System.out.println("OK agent-versions");
     }
+    runtime.close();
+  }
 }

examples/cancel/src/main/java/dev/arcp/examples/cancel/Main.java

@@ -3,7 +3,6 @@
 import com.fasterxml.jackson.databind.node.JsonNodeFactory;
 import dev.arcp.client.ArcpClient;
 import dev.arcp.client.JobHandle;
-import dev.arcp.core.error.ArcpException;
 import dev.arcp.core.error.CancelledException;
 import dev.arcp.core.events.LogEvent;
 import dev.arcp.core.transport.MemoryTransport;
@@ -13,38 +12,45 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 
-/** Submits a long-running job, then cancels it; the resulting future fails with CancelledException. */
+/**
+ * Submits a long-running job, then cancels it; the resulting future fails with CancelledException.
+ */
 public final class Main {
-    public static void main(String[] args) throws Exception {
-        MemoryTransport.Pair pair = MemoryTransport.pair();
-        ArcpRuntime runtime = ArcpRuntime.builder()
-                .agent("sleeper", "1.0.0", (input, ctx) -> {
-                    ctx.emit(new LogEvent("info", "sleeping"));
-                    while (!ctx.cancelled()) {
-                        Thread.sleep(50);
-                    }
-                    return new JobOutcome.Failure(
-                            dev.arcp.core.error.ErrorCode.CANCELLED, "cooperative");
+  public static void main(String[] args) throws Exception {
+    MemoryTransport.Pair pair = MemoryTransport.pair();
+    ArcpRuntime runtime =
+        ArcpRuntime.builder()
+            .agent(
+                "sleeper",
+                "1.0.0",
+                (input, ctx) -> {
+                  ctx.emit(new LogEvent("info", "sleeping"));
+                  while (!ctx.cancelled()) {
+                    Thread.sleep(50);
+                  }
+                  return new JobOutcome.Failure(
+                      dev.arcp.core.error.ErrorCode.CANCELLED, "cooperative");
                 })
-                .build();
-        runtime.accept(pair.runtime());
+            .build();
+    runtime.accept(pair.runtime());
 
-        try (ArcpClient client = ArcpClient.builder(pair.client()).build()) {
-            client.connect(Duration.ofSeconds(5));
-            JobHandle handle = client.submit(
-                    ArcpClient.jobSubmit("sleeper@1.0.0", JsonNodeFactory.instance.objectNode()));
-            Thread.sleep(100);
-            handle.cancel();
+    try (ArcpClient client = ArcpClient.builder(pair.client()).build()) {
+      client.connect(Duration.ofSeconds(5));
+      JobHandle handle =
+          client.submit(
+              ArcpClient.jobSubmit("sleeper@1.0.0", JsonNodeFactory.instance.objectNode()));
+      Thread.sleep(100);
+      handle.cancel();
 
-            try {
-                handle.result().get(5, TimeUnit.SECONDS);
-                throw new AssertionError("expected cancellation");
-            } catch (ExecutionException e) {
-                assert e.getCause() instanceof CancelledException
-                        : "expected CancelledException, got " + e.getCause();
-                System.out.println("OK cancel");
-            }
-        }
-        runtime.close();
+      try {
+        handle.result().get(5, TimeUnit.SECONDS);
+        throw new AssertionError("expected cancellation");
+      } catch (ExecutionException e) {
+        assert e.getCause() instanceof CancelledException
+            : "expected CancelledException, got " + e.getCause();
+        System.out.println("OK cancel");
+      }
     }
+    runtime.close();
+  }
 }

examples/cost-budget/src/main/java/dev/arcp/examples/costbudget/Main.java

@@ -16,44 +16,41 @@
 
 /** Tracks a USD budget; agent over-spends and surfaces BUDGET_EXHAUSTED. */
 public final class Main {
-    public static void main(String[] args) throws Exception {
-        MemoryTransport.Pair pair = MemoryTransport.pair();
-        ArcpRuntime runtime = ArcpRuntime.builder()
-                .agent("spender", "1.0.0", (input, ctx) -> {
-                    // Spend over budget by accumulating cost.inference metrics.
-                    for (int i = 0; i < 10; i++) {
-                        ctx.emit(new MetricEvent(
-                                "cost.inference", new BigDecimal("0.75"),
-                                "USD", null));
-                        ctx.authorize("tool.call", "*");
-                    }
-                    return JobOutcome.Success.inline(input.payload());
+  public static void main(String[] args) throws Exception {
+    MemoryTransport.Pair pair = MemoryTransport.pair();
+    ArcpRuntime runtime =
+        ArcpRuntime.builder()
+            .agent(
+                "spender",
+                "1.0.0",
+                (input, ctx) -> {
+                  // Spend over budget by accumulating cost.inference metrics.
+                  for (int i = 0; i < 10; i++) {
+                    ctx.emit(
+                        new MetricEvent("cost.inference", new BigDecimal("0.75"), "USD", null));
+                    ctx.authorize("tool.call", "*");
+                  }
+                  return JobOutcome.Success.inline(input.payload());
                 })
-                .build();
-        runtime.accept(pair.runtime());
+            .build();
+    runtime.accept(pair.runtime());
 
-        try (ArcpClient client = ArcpClient.builder(pair.client()).build()) {
-            client.connect(Duration.ofSeconds(5));
-            Lease lease = Lease.builder()
-                    .allow("tool.call", "*")
-                    .allow("cost.budget", "USD:5.00")
-                    .build();
-            JobHandle handle = client.submit(ArcpClient.jobSubmit(
-                    "spender@1.0.0",
-                    JsonNodeFactory.instance.objectNode(),
-                    lease,
-                    null,
-                    null,
-                    null));
-            try {
-                handle.result().get(5, TimeUnit.SECONDS);
-                throw new AssertionError("expected BudgetExhaustedException");
-            } catch (ExecutionException e) {
-                assert e.getCause() instanceof BudgetExhaustedException
-                        : "got " + e.getCause();
-                System.out.println("OK cost-budget");
-            }
-        }
-        runtime.close();
+    try (ArcpClient client = ArcpClient.builder(pair.client()).build()) {
+      client.connect(Duration.ofSeconds(5));
+      Lease lease =
+          Lease.builder().allow("tool.call", "*").allow("cost.budget", "USD:5.00").build();
+      JobHandle handle =
+          client.submit(
+              ArcpClient.jobSubmit(
+                  "spender@1.0.0", JsonNodeFactory.instance.objectNode(), lease, null, null, null));
+      try {
+        handle.result().get(5, TimeUnit.SECONDS);
+        throw new AssertionError("expected BudgetExhaustedException");
+      } catch (ExecutionException e) {
+        assert e.getCause() instanceof BudgetExhaustedException : "got " + e.getCause();
+        System.out.println("OK cost-budget");
+      }
     }
+    runtime.close();
+  }
 }