test_class.declarator: actorSystem
test_class.modifier: private static
test_class.original_string: private static ActorSystem actorSystem;
test_class.type: ActorSystem
test_class.var_name: actorSystem
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/ReconnectActorTest.java
test_class.identifier: ReconnectActorTest
test_case.body: @Test
      public void testRecoverConnectionsIsNotStartedTwice() {
          new TestKit(actorSystem) {{
              final TestProbe probe = new TestProbe(actorSystem);
              final Props props = ReconnectActor.props(probe.ref(),
                      () -> Source.from(Arrays.asList(
                              ConnectionPersistenceActor.PERSISTENCE_ID_PREFIX + "connection-1",
                              ConnectionPersistenceActor.PERSISTENCE_ID_PREFIX + "connection-2",
                              ConnectionPersistenceActor.PERSISTENCE_ID_PREFIX + "connection-3")));
  
              final ActorRef reconnectActor = actorSystem.actorOf(props);
              reconnectActor.tell(ReconnectActor.ReconnectMessages.START_RECONNECT, getRef());
  
              probe.expectMsgClass(RetrieveConnectionStatus.class);
              probe.expectMsgClass(RetrieveConnectionStatus.class);
              probe.expectMsgClass(RetrieveConnectionStatus.class);
              probe.expectNoMessage();
          }};
      }
test_case.class_method_signature: ReconnectActorTest.testRecoverConnectionsIsNotStartedTwice()
test_case.full_signature: @Test public void testRecoverConnectionsIsNotStartedTwice()
test_case.identifier: testRecoverConnectionsIsNotStartedTwice
test_case.invocations: props ref from asList actorOf tell getRef expectMsgClass expectMsgClass expectMsgClass expectNoMessage
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testRecoverConnectionsIsNotStartedTwice()
focal_class.declarator: ACTOR_NAME = "reconnect"
focal_class.modifier: public static final
focal_class.original_string: public static final String ACTOR_NAME = "reconnect";
focal_class.type: String
focal_class.var_name: ACTOR_NAME
focal_class.declarator: CORRELATION_ID_PREFIX = "reconnect-actor-triggered:"
focal_class.modifier: private static final
focal_class.original_string: private static final String CORRELATION_ID_PREFIX = "reconnect-actor-triggered:";
focal_class.type: String
focal_class.var_name: CORRELATION_ID_PREFIX
focal_class.declarator: log = LogUtil.obtain(this)
focal_class.modifier: private final
focal_class.original_string: private final DiagnosticLoggingAdapter log = LogUtil.obtain(this);
focal_class.type: DiagnosticLoggingAdapter
focal_class.var_name: log
focal_class.declarator: connectionShardRegion
focal_class.modifier: private final
focal_class.original_string: private final ActorRef connectionShardRegion;
focal_class.type: ActorRef
focal_class.var_name: connectionShardRegion
focal_class.declarator: currentPersistenceIdsSourceSupplier
focal_class.modifier: private final
focal_class.original_string: private final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier;
focal_class.type: Supplier<Source<String, NotUsed>>
focal_class.var_name: currentPersistenceIdsSourceSupplier
focal_class.declarator: reconnectConfig
focal_class.modifier: private final
focal_class.original_string: private final ReconnectConfig reconnectConfig;
focal_class.type: ReconnectConfig
focal_class.var_name: reconnectConfig
focal_class.declarator: materializer
focal_class.modifier: private final
focal_class.original_string: private final Materializer materializer;
focal_class.type: Materializer
focal_class.var_name: materializer
focal_class.declarator: reconnectCheck
focal_class.modifier: private
focal_class.original_string: private Cancellable reconnectCheck;
focal_class.type: Cancellable
focal_class.var_name: reconnectCheck
focal_class.declarator: reconnectInProgress = false
focal_class.modifier: private
focal_class.original_string: private boolean reconnectInProgress = false;
focal_class.type: boolean
focal_class.var_name: reconnectInProgress
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/ReconnectActor.java
focal_class.identifier: ReconnectActor
focal_class.class_method_signature: ReconnectActor.ReconnectActor(final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.full_signature: @SuppressWarnings("unused") private  ReconnectActor(final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.identifier: ReconnectActor
focal_class.modifiers: @SuppressWarnings("unused") private
focal_class.parameters: (final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.signature:  ReconnectActor(final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.class_method_signature: ReconnectActor.ReconnectActor(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.full_signature: @SuppressWarnings("unused") private  ReconnectActor(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.identifier: ReconnectActor
focal_class.modifiers: @SuppressWarnings("unused") private
focal_class.parameters: (final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.signature:  ReconnectActor(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.class_method_signature: ReconnectActor.props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.full_signature: public static Props props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.identifier: props
focal_class.modifiers: public static
focal_class.parameters: (final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.return: Props
focal_class.signature: Props props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_class.class_method_signature: ReconnectActor.props(final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.full_signature: static Props props(final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.identifier: props
focal_class.modifiers: static
focal_class.parameters: (final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.return: Props
focal_class.signature: Props props(final ActorRef connectionShardRegion,
              final Supplier<Source<String, NotUsed>> currentPersistenceIdsSourceSupplier)
focal_class.class_method_signature: ReconnectActor.scheduleReconnect()
focal_class.full_signature: private Cancellable scheduleReconnect()
focal_class.identifier: scheduleReconnect
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Cancellable
focal_class.signature: Cancellable scheduleReconnect()
focal_class.class_method_signature: ReconnectActor.getInitialDelay()
focal_class.full_signature: private FiniteDuration getInitialDelay()
focal_class.identifier: getInitialDelay
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: FiniteDuration
focal_class.signature: FiniteDuration getInitialDelay()
focal_class.class_method_signature: ReconnectActor.getInterval()
focal_class.full_signature: private FiniteDuration getInterval()
focal_class.identifier: getInterval
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: FiniteDuration
focal_class.signature: FiniteDuration getInterval()
focal_class.class_method_signature: ReconnectActor.preStart()
focal_class.full_signature: @Override public void preStart()
focal_class.identifier: preStart
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void preStart()
focal_class.class_method_signature: ReconnectActor.postStop()
focal_class.full_signature: @Override public void postStop()
focal_class.identifier: postStop
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void postStop()
focal_class.class_method_signature: ReconnectActor.createReceive()
focal_class.full_signature: @Override public Receive createReceive()
focal_class.identifier: createReceive
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Receive
focal_class.signature: Receive createReceive()
focal_class.class_method_signature: ReconnectActor.handleStartReconnect()
focal_class.full_signature: private void handleStartReconnect()
focal_class.identifier: handleStartReconnect
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void handleStartReconnect()
focal_class.class_method_signature: ReconnectActor.handleEndReconnect()
focal_class.full_signature: private void handleEndReconnect()
focal_class.identifier: handleEndReconnect
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void handleEndReconnect()
focal_class.class_method_signature: ReconnectActor.reconnect(final String persistenceId)
focal_class.full_signature: private void reconnect(final String persistenceId)
focal_class.identifier: reconnect
focal_class.modifiers: private
focal_class.parameters: (final String persistenceId)
focal_class.return: void
focal_class.signature: void reconnect(final String persistenceId)
focal_class.class_method_signature: ReconnectActor.toCorrelationId(final ConnectionId connectionId)
focal_class.full_signature: static String toCorrelationId(final ConnectionId connectionId)
focal_class.identifier: toCorrelationId
focal_class.modifiers: static
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: String
focal_class.signature: String toCorrelationId(final ConnectionId connectionId)
focal_class.class_method_signature: ReconnectActor.toConnectionId(final String correlationId)
focal_class.full_signature: static Optional<ConnectionId> toConnectionId(final String correlationId)
focal_class.identifier: toConnectionId
focal_class.modifiers: static
focal_class.parameters: (final String correlationId)
focal_class.return: Optional<ConnectionId>
focal_class.signature: Optional<ConnectionId> toConnectionId(final String correlationId)
focal_class.class_method_signature: ReconnectActor.getReconnectConfig(final ActorContext context)
focal_class.full_signature: private static ReconnectConfig getReconnectConfig(final ActorContext context)
focal_class.identifier: getReconnectConfig
focal_class.modifiers: private static
focal_class.parameters: (final ActorContext context)
focal_class.return: ReconnectConfig
focal_class.signature: ReconnectConfig getReconnectConfig(final ActorContext context)
focal_class.superclass: extends AbstractActor
focal_method.body: public static Props props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal) {
  
          return Props.create(ReconnectActor.class, connectionShardRegion, readJournal);
      }
focal_method.class_method_signature: ReconnectActor.props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_method.full_signature: public static Props props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_method.identifier: props
focal_method.invocations: create
focal_method.modifiers: public static
focal_method.parameters: (final ActorRef connectionShardRegion, final MongoReadJournal readJournal)
focal_method.return: Props
focal_method.signature: Props props(final ActorRef connectionShardRegion, final MongoReadJournal readJournal)