Rename jsonrpc bulk to batch message

diff --git a/graalvm-config-dir/reflect-config.json b/graalvm-config-dir/reflect-config.json
index 32274e8d41a3bca6ca04cd93b4fe22481334d010..1ba9c82f51bf264027bbad8c4164b29d8ef7b530 100644 (file)
--- a/graalvm-config-dir/reflect-config.json
+++ b/graalvm-config-dir/reflect-config.json
@@ -623,7 +623,7 @@
   "allDeclaredConstructors":true}
 ,
 {
-  "name":"org.asamk.signal.jsonrpc.JsonRpcBulkMessage",
+  "name":"org.asamk.signal.jsonrpc.JsonRpcBatchMessage",
   "allDeclaredFields":true,
   "allDeclaredMethods":true,
   "allDeclaredConstructors":true}

diff --git a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcBulkMessage.java b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcBatchMessage.java
similarity index 66%
rename from src/main/java/org/asamk/signal/jsonrpc/JsonRpcBulkMessage.java
rename to src/main/java/org/asamk/signal/jsonrpc/JsonRpcBatchMessage.java
index 1ffdb01623b50c2f6c6b416cd13fa36a1e0f13e8..09a87a6ee49d83fd2282830443b1faff6d13d9d8 100644 (file)
--- a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcBulkMessage.java
+++ b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcBatchMessage.java
@@ -4,11 +4,11 @@ import com.fasterxml.jackson.databind.JsonNode;
 
 import java.util.List;
 
-public final class JsonRpcBulkMessage extends JsonRpcMessage {
+public final class JsonRpcBatchMessage extends JsonRpcMessage {
 
     List<JsonNode> messages;
 
-    public JsonRpcBulkMessage(final List<JsonNode> messages) {
+    public JsonRpcBatchMessage(final List<JsonNode> messages) {
         this.messages = messages;
     }
 

diff --git a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcMessage.java b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcMessage.java
index 9cc7c87d2daea8c51897374a08986fd32a969071..8d1fcbf7efa7ac7286ccc7e7db961ca335a48494 100644 (file)
--- a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcMessage.java
+++ b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcMessage.java
@@ -1,9 +1,9 @@
 package org.asamk.signal.jsonrpc;
 
 /**
- * Represents a JSON-RPC (bulk) request or (bulk) response.
+ * Represents a JSON-RPC (batch) request or (batch) response.
  * https://www.jsonrpc.org/specification
  */
-public sealed abstract class JsonRpcMessage permits JsonRpcBulkMessage, JsonRpcRequest, JsonRpcResponse {
+public sealed abstract class JsonRpcMessage permits JsonRpcBatchMessage, JsonRpcRequest, JsonRpcResponse {
 
 }

diff --git a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java
index 64220a38994e57bf2078d1497a7e00d8f27d06c0..c2727d28410102948fe0cb82db6c52954a14e3d7 100644 (file)
--- a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java
+++ b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcReader.java
@@ -50,7 +50,7 @@ public class JsonRpcReader {
             } else if (message instanceof JsonRpcResponse jsonRpcResponse) {
                 responseHandler.accept(jsonRpcResponse);
             } else {
-                final var responseList = ((JsonRpcBulkMessage) message).getMessages().stream().map(jsonNode -> {
+                final var responseList = ((JsonRpcBatchMessage) message).getMessages().stream().map(jsonNode -> {
                     final JsonRpcRequest request;
                     try {
                         request = parseJsonRpcRequest(jsonNode);
@@ -61,7 +61,7 @@ public class JsonRpcReader {
                     return handleRequest(requestHandler, request);
                 }).filter(Objects::nonNull).collect(Collectors.toList());
 
-                jsonRpcSender.sendBulkResponses(responseList);
+                jsonRpcSender.sendBatchResponses(responseList);
             }
         }
     }
@@ -130,7 +130,7 @@ public class JsonRpcReader {
                         null), null));
                 return null;
             }
-            return new JsonRpcBulkMessage(StreamSupport.stream(jsonNode.spliterator(), false)
+            return new JsonRpcBatchMessage(StreamSupport.stream(jsonNode.spliterator(), false)
                     .collect(Collectors.toList()));
         } else if (jsonNode.isObject()) {
             if (jsonNode.has("result") || jsonNode.has("error")) {

diff --git a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcSender.java b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcSender.java
index cdacdf28c488c7decd4ef58d7bf5a745586101cf..11dc16987a583d481be79f0831dbb4aa9a8ceec7 100644 (file)
--- a/src/main/java/org/asamk/signal/jsonrpc/JsonRpcSender.java
+++ b/src/main/java/org/asamk/signal/jsonrpc/JsonRpcSender.java
@@ -16,7 +16,7 @@ public class JsonRpcSender {
         jsonWriter.write(request);
     }
 
-    public void sendBulkRequests(List<JsonRpcRequest> requests) {
+    public void sendBatchRequests(List<JsonRpcRequest> requests) {
         jsonWriter.write(requests);
     }
 
@@ -24,7 +24,7 @@ public class JsonRpcSender {
         jsonWriter.write(response);
     }
 
-    public void sendBulkResponses(List<JsonRpcResponse> responses) {
+    public void sendBatchResponses(List<JsonRpcResponse> responses) {
         jsonWriter.write(responses);
     }
 }