WIP bump minimum JDK to 17

Author: slinkydeveloper

.github/workflows/release.yml

@@ -14,7 +14,7 @@ jobs:
       - name: Set up JDK ${{ matrix.java }}
         uses: actions/setup-java@v3
         with:
-          java-version: 11
+          java-version: 17
           distribution: 'adopt'
 
       - name: Setup Gradle

.github/workflows/tests.yml

@@ -15,7 +15,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        java: [ 11, 17, 21 ]
+        java: [ 17, 21 ]
     steps:
       - uses: actions/checkout@v4
       - name: Set up JDK ${{ matrix.java }}

README.md

@@ -314,7 +314,7 @@ We know that your time is precious and, therefore, deeply value any effort to co
 
 Prerequisites:
 
-- JDK >= 11
+- JDK >= 17
 - Docker or Podman
 
 To build the SDK:

buildSrc/src/main/kotlin/java-conventions.gradle.kts

@@ -11,7 +11,7 @@ dependencies { errorprone("com.google.errorprone:error_prone_core:2.28.0") }
 
 // Configure the java toolchain to use. If not found, it will be downloaded automatically
 java {
-    toolchain { languageVersion = JavaLanguageVersion.of(11) }
+    toolchain { languageVersion = JavaLanguageVersion.of(17) }
 
     withJavadocJar()
     withSourcesJar()

buildSrc/src/main/kotlin/kotlin-conventions.gradle.kts

@@ -5,7 +5,7 @@ plugins {
 }
 
 java {
-    toolchain { languageVersion = JavaLanguageVersion.of(11) }
+    toolchain { languageVersion = JavaLanguageVersion.of(17) }
 
     withJavadocJar()
     withSourcesJar()

examples/src/main/java/my/restate/sdk/examples/Counter.java

@@ -48,13 +48,6 @@ public long get(SharedObjectContext ctx) {
     return ctx.get(TOTAL).orElse(0L);
   }
 
-  /** Get the current counter value. */
-  @Shared
-  @Handler
-  public Node getNode(SharedObjectContext ctx) {
-    return null;
-  }
-
   /** Add a value, and get both the previous value and the new value. */
   @Handler
   public CounterUpdateResult getAndAdd(ObjectContext ctx, long request) {
@@ -71,39 +64,5 @@ public static void main(String[] args) {
     RestateHttpEndpointBuilder.builder().bind(new Counter()).buildAndListen();
   }
 
-  public static class Node {
-    private final String data;
-    private final Node inner;
-
-    public Node(String data, Node inner) {
-      this.data = data;
-      this.inner = inner;
-    }
-
-    public String getData() {
-      return data;
-    }
-
-    public Node getInner() {
-      return inner;
-    }
-  }
-
-  public static class CounterUpdateResult {
-    private final long newValue;
-    private final long oldValue;
-
-    public CounterUpdateResult(long newValue, long oldValue) {
-      this.newValue = newValue;
-      this.oldValue = oldValue;
-    }
-
-    public long getNewValue() {
-      return newValue;
-    }
-
-    public long getOldValue() {
-      return oldValue;
-    }
-  }
+  public record CounterUpdateResult(long newValue, long oldValue) {}
 }

examples/src/main/java/my/restate/sdk/examples/LoanWorkflow.java

@@ -8,8 +8,6 @@
 // https://github.com/restatedev/sdk-java/blob/main/LICENSE
 package my.restate.sdk.examples;
 
-import com.fasterxml.jackson.annotation.JsonCreator;
-import com.fasterxml.jackson.annotation.JsonProperty;
 import dev.restate.sdk.Context;
 import dev.restate.sdk.JsonSerdes;
 import dev.restate.sdk.SharedWorkflowContext;
@@ -45,41 +43,8 @@ public enum Status {
     TRANSFER_FAILED
   }
 
-  public static class LoanRequest {
-
-    private final String customerName;
-    private final String customerId;
-    private final String customerBankAccount;
-    private final BigDecimal amount;
-
-    @JsonCreator
-    public LoanRequest(
-        @JsonProperty("customerName") String customerName,
-        @JsonProperty("customerId") String customerId,
-        @JsonProperty("customerBankAccount") String customerBankAccount,
-        @JsonProperty("amount") BigDecimal amount) {
-      this.customerName = customerName;
-      this.customerId = customerId;
-      this.customerBankAccount = customerBankAccount;
-      this.amount = amount;
-    }
-
-    public String getCustomerName() {
-      return customerName;
-    }
-
-    public String getCustomerId() {
-      return customerId;
-    }
-
-    public String getCustomerBankAccount() {
-      return customerBankAccount;
-    }
-
-    public BigDecimal getAmount() {
-      return amount;
-    }
-  }
+  public record LoanRequest(
+      String customerName, String customerId, String customerBankAccount, BigDecimal amount) {}
 
   private static final Logger LOG = LogManager.getLogger(LoanWorkflow.class);
 
@@ -123,8 +88,7 @@ public String run(WorkflowContext ctx, LoanRequest loanRequest) {
       executionTime =
           bankClient
               .transfer(
-                  new TransferRequest(
-                      loanRequest.getCustomerBankAccount(), loanRequest.getAmount()))
+                  new TransferRequest(loanRequest.customerBankAccount(), loanRequest.amount()))
               .await(Duration.ofDays(7));
     } catch (TerminalException | TimeoutException e) {
       LOG.warn("Transaction failed", e);
@@ -223,24 +187,5 @@ public Instant transfer(Context context, TransferRequest request) throws Termina
     }
   }
 
-  public static class TransferRequest {
-    private final String bankAccount;
-    private final BigDecimal amount;
-
-    @JsonCreator
-    public TransferRequest(
-        @JsonProperty("bankAccount") String bankAccount,
-        @JsonProperty("amount") BigDecimal amount) {
-      this.bankAccount = bankAccount;
-      this.amount = amount;
-    }
-
-    public String getBankAccount() {
-      return bankAccount;
-    }
-
-    public BigDecimal getAmount() {
-      return amount;
-    }
-  }
+  public record TransferRequest(String bankAccount, BigDecimal amount) {}
 }

sdk-api-gen-common/src/main/java/dev/restate/sdk/gen/model/Handler.java

@@ -11,54 +11,13 @@
 import java.util.Objects;
 import org.jspecify.annotations.Nullable;
 
-public class Handler {
-
-  private final CharSequence name;
-  private final HandlerType handlerType;
-  private final @Nullable String inputAccept;
-  private final PayloadType inputType;
-  private final PayloadType outputType;
-  private final @Nullable String documentation;
-
-  public Handler(
-      CharSequence name,
-      HandlerType handlerType,
-      @Nullable String inputAccept,
-      PayloadType inputType,
-      PayloadType outputType,
-      @Nullable String documentation) {
-    this.name = name;
-    this.handlerType = handlerType;
-    this.inputAccept = inputAccept;
-    this.inputType = inputType;
-    this.outputType = outputType;
-    this.documentation = documentation;
-  }
-
-  public CharSequence getName() {
-    return name;
-  }
-
-  public HandlerType getHandlerType() {
-    return handlerType;
-  }
-
-  @Nullable
-  public String getInputAccept() {
-    return inputAccept;
-  }
-
-  public PayloadType getInputType() {
-    return inputType;
-  }
-
-  public PayloadType getOutputType() {
-    return outputType;
-  }
-
-  public @Nullable String getDocumentation() {
-    return documentation;
-  }
+public record Handler(
+    CharSequence name,
+    HandlerType handlerType,
+    @Nullable String inputAccept,
+    PayloadType inputType,
+    PayloadType outputType,
+    @Nullable String documentation) {
 
   public static Builder builder() {
     return new Builder();

sdk-api-gen-common/src/main/java/dev/restate/sdk/gen/model/HandlerType.java

@@ -12,5 +12,5 @@ public enum HandlerType {
   SHARED,
   EXCLUSIVE,
   STATELESS,
-  WORKFLOW;
+  WORKFLOW
 }

sdk-api-gen-common/src/main/java/dev/restate/sdk/gen/model/PayloadType.java

@@ -8,66 +8,4 @@
 // https://github.com/restatedev/sdk-java/blob/main/LICENSE
 package dev.restate.sdk.gen.model;
 
-import java.util.Objects;
-
-public class PayloadType {
-
-  private final boolean isEmpty;
-  private final String name;
-  private final String boxed;
-  private final String serdeDecl;
-
-  public PayloadType(boolean isEmpty, String name, String boxed, String serdeDecl) {
-    this.isEmpty = isEmpty;
-    this.name = name;
-    this.boxed = boxed;
-    this.serdeDecl = serdeDecl;
-  }
-
-  public boolean isEmpty() {
-    return isEmpty;
-  }
-
-  public String getName() {
-    return name;
-  }
-
-  public String getBoxed() {
-    return boxed;
-  }
-
-  public String getSerdeDecl() {
-    return serdeDecl;
-  }
-
-  @Override
-  public boolean equals(Object o) {
-    if (this == o) return true;
-    if (!(o instanceof PayloadType)) return false;
-    PayloadType that = (PayloadType) o;
-    return isEmpty == that.isEmpty
-        && Objects.equals(name, that.name)
-        && Objects.equals(boxed, that.boxed)
-        && Objects.equals(serdeDecl, that.serdeDecl);
-  }
-
-  @Override
-  public int hashCode() {
-    return Objects.hash(name, boxed, serdeDecl);
-  }
-
-  @Override
-  public String toString() {
-    return "PayloadType{"
-        + "name='"
-        + name
-        + '\''
-        + ", boxed='"
-        + boxed
-        + '\''
-        + ", serdeDecl='"
-        + serdeDecl
-        + '\''
-        + '}';
-  }
-}
+public record PayloadType(boolean isEmpty, String name, String boxed, String serdeDecl) {}