Package dev.restate.sdk.core

Class ProtocolException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

dev.restate.sdk.core.ProtocolException

All Implemented Interfaces:

Serializable

public class ProtocolException
extends RuntimeException

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INTERNAL_CODE
static final int	JOURNAL_MISMATCH_CODE
static final int	UNSUPPORTED_MEDIA_TYPE_CODE

Constructor Summary

Constructors

Constructor	Description
ProtocolException(String message, int code)
ProtocolException(String message, int code, Throwable cause)

Method Summary

Modifier and Type	Method	Description
static ProtocolException	badNotificationMessage(String missingField)
static ProtocolException	badRunNotificationId(NotificationId notificationId)
static ProtocolException	badState(Object thisState)
static ProtocolException	closedWhileWaitingEntries()
static ProtocolException	commandMissingField(Class<?> clazz, String missingField)
static ProtocolException	commandsToProcessIsEmpty()
int	getCode()
static ProtocolException	idempotencyKeyIsEmpty()
static ProtocolException	inputClosedWhileWaitingEntries()
static ProtocolException	methodNotFound(String serviceName, String handlerName)
static ProtocolException	unauthorized(Throwable e)
static ProtocolException	uncompletedDoProgressDuringReplay(List<NotificationId> sortedNotificationIds, Map<NotificationId,String> notificationDescriptions)
static ProtocolException	unexpectedMessage(Class<? extends com.google.protobuf.MessageLite> expected, com.google.protobuf.MessageLite actual)
static ProtocolException	unexpectedMessage(String expected, com.google.protobuf.MessageLite actual)
static ProtocolException	unknownMessageType(short type)
static ProtocolException	unsupportedFeature(String featureName, Protocol.ServiceProtocolVersion requiredVersion, Protocol.ServiceProtocolVersion negotiatedVersion)

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

UNSUPPORTED_MEDIA_TYPE_CODE

public static final int UNSUPPORTED_MEDIA_TYPE_CODE

See Also:

• Constant Field Values

INTERNAL_CODE

public static final int INTERNAL_CODE

See Also:

• Constant Field Values

JOURNAL_MISMATCH_CODE

public static final int JOURNAL_MISMATCH_CODE

See Also:

• Constant Field Values

Constructor Details

ProtocolException

public ProtocolException(String message,
 int code)

ProtocolException

public ProtocolException(String message,
 int code,
 Throwable cause)

Method Details

getCode

public int getCode()

unexpectedMessage

public static ProtocolException unexpectedMessage(Class<? extends com.google.protobuf.MessageLite> expected,
 com.google.protobuf.MessageLite actual)

unexpectedMessage

public static ProtocolException unexpectedMessage(String expected,
 com.google.protobuf.MessageLite actual)

commandsToProcessIsEmpty

public static ProtocolException commandsToProcessIsEmpty()

unknownMessageType

public static ProtocolException unknownMessageType(short type)

methodNotFound

public static ProtocolException methodNotFound(String serviceName,
 String handlerName)

badState

public static ProtocolException badState(Object thisState)

badNotificationMessage

public static ProtocolException badNotificationMessage(String missingField)

badRunNotificationId

public static ProtocolException badRunNotificationId(NotificationId notificationId)

commandMissingField

public static ProtocolException commandMissingField(Class<?> clazz,
 String missingField)

inputClosedWhileWaitingEntries

public static ProtocolException inputClosedWhileWaitingEntries()

closedWhileWaitingEntries

public static ProtocolException closedWhileWaitingEntries()

idempotencyKeyIsEmpty

public static ProtocolException idempotencyKeyIsEmpty()

unauthorized

public static ProtocolException unauthorized(Throwable e)

uncompletedDoProgressDuringReplay

public static ProtocolException uncompletedDoProgressDuringReplay(List<NotificationId> sortedNotificationIds,
 Map<NotificationId,String> notificationDescriptions)

unsupportedFeature

public static ProtocolException unsupportedFeature(String featureName,
 Protocol.ServiceProtocolVersion requiredVersion,
 Protocol.ServiceProtocolVersion negotiatedVersion)