Skip to content

Commit b8f05e2

Browse files
Bump protocol version
1 parent 1b26150 commit b8f05e2

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

sdk-core/src/main/java/dev/restate/sdk/core/MessageHeader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414

1515
public class MessageHeader {
1616

17-
static final short SUPPORTED_PROTOCOL_VERSION = 0;
17+
static final short SUPPORTED_PROTOCOL_VERSION = 1;
1818

1919
static final short VERSION_MASK = 0x03FF;
2020
static final short DONE_FLAG = 0x0001;

sdk-core/src/test/java/dev/restate/sdk/core/ProtoUtils.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,10 @@ public class ProtoUtils {
3333
*/
3434
public static MessageHeader headerFromMessage(MessageLite msg) {
3535
if (msg instanceof Protocol.StartMessage) {
36-
return new MessageHeader(MessageType.StartMessage, (short) 0, msg.getSerializedSize());
36+
return new MessageHeader(
37+
MessageType.StartMessage,
38+
MessageHeader.SUPPORTED_PROTOCOL_VERSION,
39+
msg.getSerializedSize());
3740
} else if (msg instanceof Protocol.CompletionMessage) {
3841
return new MessageHeader(MessageType.CompletionMessage, (short) 0, msg.getSerializedSize());
3942
}

0 commit comments

Comments
 (0)