+
+ @VisibleForTesting
+ synchronized ActorSelection getListenerRegistrationActor() {
+ return listenerRegistrationActor;
+ }
+
+ @VisibleForTesting
+ ActorRef getDataChangeListenerActor() {
+ return dataChangeListenerActor;
+ }
+
+ private String logContext() {
+ return actorContext.getDatastoreContext().getLogicalStoreType().toString();
+ }