|
16 | 16 | import java.lang.reflect.InvocationTargetException;
|
17 | 17 | import java.util.AbstractMap;
|
18 | 18 | import java.util.Map;
|
| 19 | +import java.util.Objects; |
19 | 20 | import java.util.stream.Collectors;
|
20 | 21 |
|
21 | 22 | public final class Entity<A extends BaseActor, B extends ActorBehavior> {
|
@@ -174,7 +175,11 @@ private static Map<String, Entity.EntityMethod> getTimerActions(Map<String, Acti
|
174 | 175 | }
|
175 | 176 |
|
176 | 177 | private static Entity buildNamedActor(Class<?> stateType, StatefulActor actor, NamedActorBehavior behavior, BehaviorCtx ctx) {
|
177 |
| - final String actorName = behavior.getName(); |
| 178 | + String actorName = behavior.getName() ; |
| 179 | + if (Objects.isNull(actorName) || behavior.getName().isBlank()) { |
| 180 | + actorName = actor.getClass().getSimpleName(); |
| 181 | + } |
| 182 | + |
178 | 183 | final ActorKind kind = behavior.getActorType();
|
179 | 184 | final String channel = behavior.getChannel();
|
180 | 185 | final long deactivateTimeout = behavior.getDeactivatedTimeout();
|
@@ -205,7 +210,11 @@ private static Entity buildNamedActor(Class<?> stateType, StatefulActor actor, N
|
205 | 210 | }
|
206 | 211 |
|
207 | 212 | private static Entity buildNamedActor(Class<?> stateType, StatelessActor actor, NamedActorBehavior behavior, BehaviorCtx ctx) {
|
208 |
| - final String actorName = behavior.getName(); |
| 213 | + String actorName = behavior.getName() ; |
| 214 | + if (Objects.isNull(actorName) || behavior.getName().isBlank()) { |
| 215 | + actorName = actor.getClass().getSimpleName(); |
| 216 | + } |
| 217 | + |
209 | 218 | final ActorKind kind = behavior.getActorType();
|
210 | 219 | final String channel = behavior.getChannel();
|
211 | 220 | final long deactivateTimeout = behavior.getDeactivatedTimeout();
|
@@ -233,7 +242,11 @@ private static Entity buildNamedActor(Class<?> stateType, StatelessActor actor,
|
233 | 242 | }
|
234 | 243 |
|
235 | 244 | private static Entity buildUnNamedActor(Class<?> stateType, StatefulActor actor, UnNamedActorBehavior behavior, BehaviorCtx ctx) {
|
236 |
| - final String actorName = behavior.getName(); |
| 245 | + String actorName = behavior.getName() ; |
| 246 | + if (Objects.isNull(actorName) || behavior.getName().isBlank()) { |
| 247 | + actorName = actor.getClass().getSimpleName(); |
| 248 | + } |
| 249 | + |
237 | 250 | final ActorKind kind = behavior.getActorType();
|
238 | 251 | final String channel = behavior.getChannel();
|
239 | 252 | long deactivateTimeout = behavior.getDeactivatedTimeout();
|
@@ -264,7 +277,11 @@ private static Entity buildUnNamedActor(Class<?> stateType, StatefulActor actor,
|
264 | 277 | }
|
265 | 278 |
|
266 | 279 | private static Entity buildUnNamedActor(Class<?> stateType, StatelessActor actor, UnNamedActorBehavior behavior, BehaviorCtx ctx) {
|
267 |
| - final String actorName = behavior.getName(); |
| 280 | + String actorName = behavior.getName() ; |
| 281 | + if (Objects.isNull(actorName) || behavior.getName().isBlank()) { |
| 282 | + actorName = actor.getClass().getSimpleName(); |
| 283 | + } |
| 284 | + |
268 | 285 | final ActorKind kind = behavior.getActorType();
|
269 | 286 | final String channel = behavior.getChannel();
|
270 | 287 | long deactivateTimeout = behavior.getDeactivatedTimeout();
|
|
0 commit comments