Package kalix.javasdk.eventsourced

Class ReflectiveEventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>

Object

kalix.javasdk.eventsourced.ReflectiveEventSourcedEntityProvider<S,E,ES>

All Implemented Interfaces:

kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES>

public class ReflectiveEventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>
extends Object
implements kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES>

Constructor Summary

Constructors

Constructor	Description
ReflectiveEventSourcedEntityProvider(Class<ES> entityClass, kalix.javasdk.impl.JsonMessageCodec messageCodec, Function<kalix.javasdk.eventsourcedentity.EventSourcedEntityContext,ES> factory, kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions options)

Method Summary

Modifier and Type	Method	Description
com.google.protobuf.Descriptors.FileDescriptor[]	additionalDescriptors()
Optional<kalix.javasdk.impl.MessageCodec>	alternativeCodec()
kalix.javasdk.impl.eventsourcedentity.EventSourcedEntityRouter<S,E,ES>	newRouter(kalix.javasdk.eventsourcedentity.EventSourcedEntityContext context)
static <S, E, ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S, E>> ReflectiveEventSourcedEntityProvider<S,E,ES>	of(Class<ES> cls, kalix.javasdk.impl.JsonMessageCodec messageCodec, Function<kalix.javasdk.eventsourcedentity.EventSourcedEntityContext,ES> factory)
kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions	options()
com.google.protobuf.Descriptors.ServiceDescriptor	serviceDescriptor()
String	typeId()

Methods inherited from class java.lang.Object

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

Constructor Details

ReflectiveEventSourcedEntityProvider

public ReflectiveEventSourcedEntityProvider(Class<ES> entityClass,
 kalix.javasdk.impl.JsonMessageCodec messageCodec,
 Function<kalix.javasdk.eventsourcedentity.EventSourcedEntityContext,ES> factory,
 kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions options)

Method Details

of

public static <S,
E,
ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,
E>>
ReflectiveEventSourcedEntityProvider<S,E,ES> of(Class<ES> cls,
 kalix.javasdk.impl.JsonMessageCodec messageCodec,
 Function<kalix.javasdk.eventsourcedentity.EventSourcedEntityContext,ES> factory)

options

public kalix.javasdk.eventsourcedentity.EventSourcedEntityOptions options()

Specified by:

options in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>

serviceDescriptor

public com.google.protobuf.Descriptors.ServiceDescriptor serviceDescriptor()

Specified by:

serviceDescriptor in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>

typeId

public String typeId()

Specified by:

typeId in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>

newRouter

public kalix.javasdk.impl.eventsourcedentity.EventSourcedEntityRouter<S,E,ES> newRouter(kalix.javasdk.eventsourcedentity.EventSourcedEntityContext context)

Specified by:

newRouter in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>

additionalDescriptors

public com.google.protobuf.Descriptors.FileDescriptor[] additionalDescriptors()

Specified by:

additionalDescriptors in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>

alternativeCodec

public Optional<kalix.javasdk.impl.MessageCodec> alternativeCodec()

Specified by:

alternativeCodec in interface kalix.javasdk.eventsourcedentity.EventSourcedEntityProvider<S,E,ES extends kalix.javasdk.eventsourcedentity.EventSourcedEntity<S,E>>