|
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