test_class.declarator: SUBJECTS = Sets.newHashSet(TestConstants.Authorization.SUBJECT_ID,
              TestConstants.Authorization.UNAUTHORIZED_SUBJECT_ID)
test_class.modifier: private static final
test_class.original_string: private static final Set<String> SUBJECTS = Sets.newHashSet(TestConstants.Authorization.SUBJECT_ID,
              TestConstants.Authorization.UNAUTHORIZED_SUBJECT_ID);
test_class.type: Set<String>
test_class.var_name: SUBJECTS
test_class.declarator: TWIN_AND_LIVE_EVENTS =
              EnumSet.of(StreamingType.EVENTS, StreamingType.LIVE_EVENTS)
test_class.modifier: private static final
test_class.original_string: private static final Set<StreamingType> TWIN_AND_LIVE_EVENTS =
              EnumSet.of(StreamingType.EVENTS, StreamingType.LIVE_EVENTS);
test_class.type: Set<StreamingType>
test_class.var_name: TWIN_AND_LIVE_EVENTS
test_class.declarator: TWIN_AND_LIVE_EVENTS_AND_MESSAGES =
              EnumSet.of(StreamingType.EVENTS, StreamingType.LIVE_EVENTS, StreamingType.MESSAGES)
test_class.modifier: private static final
test_class.original_string: private static final Set<StreamingType> TWIN_AND_LIVE_EVENTS_AND_MESSAGES =
              EnumSet.of(StreamingType.EVENTS, StreamingType.LIVE_EVENTS, StreamingType.MESSAGES);
test_class.type: Set<StreamingType>
test_class.var_name: TWIN_AND_LIVE_EVENTS_AND_MESSAGES
test_class.declarator: actorSystem
test_class.modifier: private
test_class.original_string: private ActorSystem actorSystem;
test_class.type: ActorSystem
test_class.var_name: actorSystem
test_class.declarator: pubSubMediator
test_class.modifier: private
test_class.original_string: private ActorRef pubSubMediator;
test_class.type: ActorRef
test_class.var_name: pubSubMediator
test_class.declarator: proxyActor
test_class.modifier: private
test_class.original_string: private ActorRef proxyActor;
test_class.type: ActorRef
test_class.var_name: proxyActor
test_class.declarator: connectionId
test_class.modifier: private
test_class.original_string: private ConnectionId connectionId;
test_class.type: ConnectionId
test_class.var_name: connectionId
test_class.declarator: createConnection
test_class.modifier: private
test_class.original_string: private CreateConnection createConnection;
test_class.type: CreateConnection
test_class.var_name: createConnection
test_class.declarator: createClosedConnectionWith2Clients
test_class.modifier: private
test_class.original_string: private CreateConnection createClosedConnectionWith2Clients;
test_class.type: CreateConnection
test_class.var_name: createClosedConnectionWith2Clients
test_class.declarator: createClosedConnection
test_class.modifier: private
test_class.original_string: private CreateConnection createClosedConnection;
test_class.type: CreateConnection
test_class.var_name: createClosedConnection
test_class.declarator: modifyConnection
test_class.modifier: private
test_class.original_string: private ModifyConnection modifyConnection;
test_class.type: ModifyConnection
test_class.var_name: modifyConnection
test_class.declarator: modifyClosedConnection
test_class.modifier: private
test_class.original_string: private ModifyConnection modifyClosedConnection;
test_class.type: ModifyConnection
test_class.var_name: modifyClosedConnection
test_class.declarator: deleteConnection
test_class.modifier: private
test_class.original_string: private DeleteConnection deleteConnection;
test_class.type: DeleteConnection
test_class.var_name: deleteConnection
test_class.declarator: testConnection
test_class.modifier: private
test_class.original_string: private TestConnection testConnection;
test_class.type: TestConnection
test_class.var_name: testConnection
test_class.declarator: testConnectionCausingFailure
test_class.modifier: private
test_class.original_string: private TestConnection testConnectionCausingFailure;
test_class.type: TestConnection
test_class.var_name: testConnectionCausingFailure
test_class.declarator: testConnectionCausingException
test_class.modifier: private
test_class.original_string: private TestConnection testConnectionCausingException;
test_class.type: TestConnection
test_class.var_name: testConnectionCausingException
test_class.declarator: createConnectionResponse
test_class.modifier: private
test_class.original_string: private CreateConnectionResponse createConnectionResponse;
test_class.type: CreateConnectionResponse
test_class.var_name: createConnectionResponse
test_class.declarator: createClosedConnectionResponse
test_class.modifier: private
test_class.original_string: private CreateConnectionResponse createClosedConnectionResponse;
test_class.type: CreateConnectionResponse
test_class.var_name: createClosedConnectionResponse
test_class.declarator: modifyConnectionResponse
test_class.modifier: private
test_class.original_string: private ModifyConnectionResponse modifyConnectionResponse;
test_class.type: ModifyConnectionResponse
test_class.var_name: modifyConnectionResponse
test_class.declarator: openConnection
test_class.modifier: private
test_class.original_string: private OpenConnection openConnection;
test_class.type: OpenConnection
test_class.var_name: openConnection
test_class.declarator: closeConnection
test_class.modifier: private
test_class.original_string: private CloseConnection closeConnection;
test_class.type: CloseConnection
test_class.var_name: closeConnection
test_class.declarator: closeConnectionResponse
test_class.modifier: private
test_class.original_string: private CloseConnectionResponse closeConnectionResponse;
test_class.type: CloseConnectionResponse
test_class.var_name: closeConnectionResponse
test_class.declarator: deleteConnectionResponse
test_class.modifier: private
test_class.original_string: private DeleteConnectionResponse deleteConnectionResponse;
test_class.type: DeleteConnectionResponse
test_class.var_name: deleteConnectionResponse
test_class.declarator: retrieveConnection
test_class.modifier: private
test_class.original_string: private RetrieveConnection retrieveConnection;
test_class.type: RetrieveConnection
test_class.var_name: retrieveConnection
test_class.declarator: retrieveConnectionStatus
test_class.modifier: private
test_class.original_string: private RetrieveConnectionStatus retrieveConnectionStatus;
test_class.type: RetrieveConnectionStatus
test_class.var_name: retrieveConnectionStatus
test_class.declarator: resetConnectionMetrics
test_class.modifier: private
test_class.original_string: private ResetConnectionMetrics resetConnectionMetrics;
test_class.type: ResetConnectionMetrics
test_class.var_name: resetConnectionMetrics
test_class.declarator: retrieveModifiedConnectionResponse
test_class.modifier: private
test_class.original_string: private RetrieveConnectionResponse retrieveModifiedConnectionResponse;
test_class.type: RetrieveConnectionResponse
test_class.var_name: retrieveModifiedConnectionResponse
test_class.declarator: retrieveConnectionStatusOpenResponse
test_class.modifier: private
test_class.original_string: private RetrieveConnectionStatusResponse retrieveConnectionStatusOpenResponse;
test_class.type: RetrieveConnectionStatusResponse
test_class.var_name: retrieveConnectionStatusOpenResponse
test_class.declarator: connectionNotAccessibleException
test_class.modifier: private
test_class.original_string: private ConnectionNotAccessibleException connectionNotAccessibleException;
test_class.type: ConnectionNotAccessibleException
test_class.var_name: connectionNotAccessibleException
test_class.declarator: thingModified
test_class.modifier: private
test_class.original_string: private ThingModifiedEvent thingModified;
test_class.type: ThingModifiedEvent
test_class.var_name: thingModified
test_class.declarator: dittoProtocolSubMock
test_class.modifier: private
test_class.original_string: private DittoProtocolSub dittoProtocolSubMock;
test_class.type: DittoProtocolSub
test_class.var_name: dittoProtocolSubMock
test_class.declarator: actorSystem2
test_class.modifier: private
test_class.original_string: private ActorSystem actorSystem2;
test_class.type: ActorSystem
test_class.var_name: actorSystem2
test_class.declarator: closedConnection
test_class.modifier: private
test_class.original_string: private Connection closedConnection;
test_class.type: Connection
test_class.var_name: closedConnection
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActorTest.java
test_class.identifier: ConnectionPersistenceActorTest
test_class.superclass: extends WithMockServers
test_case.body: @Test
      public void manageConnection() {
          new TestKit(actorSystem) {{
              final TestProbe probe = TestProbe.apply(actorSystem);
              final ActorRef underTest = TestConstants.createConnectionSupervisorActor(
                      connectionId, actorSystem, proxyActor,
                      (connection, concierge, connectionActor) -> MockClientActor.props(probe.ref()),
                      TestConstants.dummyDittoProtocolSub(pubSubMediator, dittoProtocolSubMock),
                      pubSubMediator
              );
              watch(underTest);
  
              // create connection
              underTest.tell(createConnection, getRef());
              probe.expectMsg(openConnection);
              expectMsg(createConnectionResponse);
              expectRemoveSubscriber(1);
              expectSubscribe(TWIN_AND_LIVE_EVENTS, SUBJECTS);
  
              // close connection
              underTest.tell(closeConnection, getRef());
              probe.expectMsg(closeConnection);
              expectMsg(closeConnectionResponse);
              expectRemoveSubscriber(2);
  
              // delete connection
              underTest.tell(deleteConnection, getRef());
              expectMsg(deleteConnectionResponse);
              probe.expectNoMessage();
              expectTerminated(underTest);
          }};
      }
test_case.class_method_signature: ConnectionPersistenceActorTest.manageConnection()
test_case.full_signature: @Test public void manageConnection()
test_case.identifier: manageConnection
test_case.invocations: apply createConnectionSupervisorActor props ref dummyDittoProtocolSub watch tell getRef expectMsg expectMsg expectRemoveSubscriber expectSubscribe tell getRef expectMsg expectMsg expectRemoveSubscriber tell getRef expectMsg expectNoMessage expectTerminated
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void manageConnection()
focal_class.declarator: PERSISTENCE_ID_PREFIX = "connection:"
focal_class.modifier: public static final
focal_class.original_string: public static final String PERSISTENCE_ID_PREFIX = "connection:";
focal_class.type: String
focal_class.var_name: PERSISTENCE_ID_PREFIX
focal_class.declarator: JOURNAL_PLUGIN_ID = "akka-contrib-mongodb-persistence-connection-journal"
focal_class.modifier: public static final
focal_class.original_string: public static final String JOURNAL_PLUGIN_ID = "akka-contrib-mongodb-persistence-connection-journal";
focal_class.type: String
focal_class.var_name: JOURNAL_PLUGIN_ID
focal_class.declarator: SNAPSHOT_PLUGIN_ID = "akka-contrib-mongodb-persistence-connection-snapshots"
focal_class.modifier: public static final
focal_class.original_string: public static final String SNAPSHOT_PLUGIN_ID = "akka-contrib-mongodb-persistence-connection-snapshots";
focal_class.type: String
focal_class.var_name: SNAPSHOT_PLUGIN_ID
focal_class.declarator: DEFAULT_RETRIEVE_STATUS_TIMEOUT = Duration.ofMillis(500L)
focal_class.modifier: private static final
focal_class.original_string: private static final Duration DEFAULT_RETRIEVE_STATUS_TIMEOUT = Duration.ofMillis(500L);
focal_class.type: Duration
focal_class.var_name: DEFAULT_RETRIEVE_STATUS_TIMEOUT
focal_class.declarator: CLIENT_ACTORS_PER_NODE = 1
focal_class.modifier: private static final
focal_class.original_string: private static final int CLIENT_ACTORS_PER_NODE = 1;
focal_class.type: int
focal_class.var_name: CLIENT_ACTORS_PER_NODE
focal_class.declarator: dittoProtocolSub
focal_class.modifier: private final
focal_class.original_string: private final DittoProtocolSub dittoProtocolSub;
focal_class.type: DittoProtocolSub
focal_class.var_name: dittoProtocolSub
focal_class.declarator: proxyActor
focal_class.modifier: private final
focal_class.original_string: private final ActorRef proxyActor;
focal_class.type: ActorRef
focal_class.var_name: proxyActor
focal_class.declarator: propsFactory
focal_class.modifier: private final
focal_class.original_string: private final ClientActorPropsFactory propsFactory;
focal_class.type: ClientActorPropsFactory
focal_class.var_name: propsFactory
focal_class.declarator: clientActorsPerNode
focal_class.modifier: private final
focal_class.original_string: private final int clientActorsPerNode;
focal_class.type: int
focal_class.var_name: clientActorsPerNode
focal_class.declarator: commandValidator
focal_class.modifier: private final
focal_class.original_string: private final ConnectivityCommandInterceptor commandValidator;
focal_class.type: ConnectivityCommandInterceptor
focal_class.var_name: commandValidator
focal_class.declarator: connectionLogger
focal_class.modifier: private final
focal_class.original_string: private final ConnectionLogger connectionLogger;
focal_class.type: ConnectionLogger
focal_class.var_name: connectionLogger
focal_class.declarator: connectionClosedAt = Instant.now()
focal_class.modifier: private
focal_class.original_string: private Instant connectionClosedAt = Instant.now();
focal_class.type: Instant
focal_class.var_name: connectionClosedAt
focal_class.declarator: clientActorRouter
focal_class.modifier: @Nullable private
focal_class.original_string: @Nullable private ActorRef clientActorRouter;
focal_class.type: ActorRef
focal_class.var_name: clientActorRouter
focal_class.declarator: clientActorAskTimeout
focal_class.modifier: private final
focal_class.original_string: private final Duration clientActorAskTimeout;
focal_class.type: Duration
focal_class.var_name: clientActorAskTimeout
focal_class.declarator: connectionMonitorRegistry
focal_class.modifier: private final
focal_class.original_string: private final ConnectionMonitorRegistry<ConnectionMonitor> connectionMonitorRegistry;
focal_class.type: ConnectionMonitorRegistry<ConnectionMonitor>
focal_class.var_name: connectionMonitorRegistry
focal_class.declarator: checkLoggingActiveInterval
focal_class.modifier: private final
focal_class.original_string: private final Duration checkLoggingActiveInterval;
focal_class.type: Duration
focal_class.var_name: checkLoggingActiveInterval
focal_class.declarator: signalFilter = null
focal_class.modifier: @Nullable private
focal_class.original_string: @Nullable private SignalFilter signalFilter = null;
focal_class.type: SignalFilter
focal_class.var_name: signalFilter
focal_class.declarator: loggingEnabledUntil
focal_class.modifier: @Nullable private
focal_class.original_string: @Nullable private Instant loggingEnabledUntil;
focal_class.type: Instant
focal_class.var_name: loggingEnabledUntil
focal_class.declarator: loggingEnabledDuration
focal_class.modifier: private final
focal_class.original_string: private final Duration loggingEnabledDuration;
focal_class.type: Duration
focal_class.var_name: loggingEnabledDuration
focal_class.declarator: config
focal_class.modifier: private final
focal_class.original_string: private final ConnectionConfig config;
focal_class.type: ConnectionConfig
focal_class.var_name: config
focal_class.declarator: monitoringConfig
focal_class.modifier: private final
focal_class.original_string: private final MonitoringConfig monitoringConfig;
focal_class.type: MonitoringConfig
focal_class.var_name: monitoringConfig
focal_class.declarator: subscriptionCounter = 0
focal_class.modifier: private
focal_class.original_string: private int subscriptionCounter = 0;
focal_class.type: int
focal_class.var_name: subscriptionCounter
focal_class.declarator: pubSubStatus = ConnectivityStatus.UNKNOWN
focal_class.modifier: private
focal_class.original_string: private ConnectivityStatus pubSubStatus = ConnectivityStatus.UNKNOWN;
focal_class.type: ConnectivityStatus
focal_class.var_name: pubSubStatus
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionPersistenceActor.java
focal_class.identifier: ConnectionPersistenceActor
focal_class.class_method_signature: ConnectionPersistenceActor.ConnectionPersistenceActor(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor customCommandValidator,
              final int clientActorsPerNode)
focal_class.full_signature:   ConnectionPersistenceActor(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor customCommandValidator,
              final int clientActorsPerNode)
focal_class.identifier: ConnectionPersistenceActor
focal_class.parameters: (final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor customCommandValidator,
              final int clientActorsPerNode)
focal_class.signature:  ConnectionPersistenceActor(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor customCommandValidator,
              final int clientActorsPerNode)
focal_class.class_method_signature: ConnectionPersistenceActor.props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_class.full_signature: public static Props props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_class.identifier: props
focal_class.modifiers: public static
focal_class.parameters: (final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_class.return: Props
focal_class.signature: Props props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_class.class_method_signature: ConnectionPersistenceActor.persistenceId()
focal_class.full_signature: @Override public String persistenceId()
focal_class.identifier: persistenceId
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String persistenceId()
focal_class.class_method_signature: ConnectionPersistenceActor.journalPluginId()
focal_class.full_signature: @Override public String journalPluginId()
focal_class.identifier: journalPluginId
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String journalPluginId()
focal_class.class_method_signature: ConnectionPersistenceActor.snapshotPluginId()
focal_class.full_signature: @Override public String snapshotPluginId()
focal_class.identifier: snapshotPluginId
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String snapshotPluginId()
focal_class.class_method_signature: ConnectionPersistenceActor.getEventClass()
focal_class.full_signature: @Override protected Class<ConnectivityEvent> getEventClass()
focal_class.identifier: getEventClass
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: Class<ConnectivityEvent>
focal_class.signature: Class<ConnectivityEvent> getEventClass()
focal_class.class_method_signature: ConnectionPersistenceActor.getStrategyContext()
focal_class.full_signature: @Override protected CommandStrategy.Context<ConnectionState> getStrategyContext()
focal_class.identifier: getStrategyContext
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: CommandStrategy.Context<ConnectionState>
focal_class.signature: CommandStrategy.Context<ConnectionState> getStrategyContext()
focal_class.class_method_signature: ConnectionPersistenceActor.getCreatedStrategy()
focal_class.full_signature: @Override protected ConnectionCreatedStrategies getCreatedStrategy()
focal_class.identifier: getCreatedStrategy
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: ConnectionCreatedStrategies
focal_class.signature: ConnectionCreatedStrategies getCreatedStrategy()
focal_class.class_method_signature: ConnectionPersistenceActor.getDeletedStrategy()
focal_class.full_signature: @Override protected ConnectionDeletedStrategies getDeletedStrategy()
focal_class.identifier: getDeletedStrategy
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: ConnectionDeletedStrategies
focal_class.signature: ConnectionDeletedStrategies getDeletedStrategy()
focal_class.class_method_signature: ConnectionPersistenceActor.getEventStrategy()
focal_class.full_signature: @Override protected EventStrategy<ConnectivityEvent, Connection> getEventStrategy()
focal_class.identifier: getEventStrategy
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: EventStrategy<ConnectivityEvent, Connection>
focal_class.signature: EventStrategy<ConnectivityEvent, Connection> getEventStrategy()
focal_class.class_method_signature: ConnectionPersistenceActor.getActivityCheckConfig()
focal_class.full_signature: @Override protected ActivityCheckConfig getActivityCheckConfig()
focal_class.identifier: getActivityCheckConfig
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: ActivityCheckConfig
focal_class.signature: ActivityCheckConfig getActivityCheckConfig()
focal_class.class_method_signature: ConnectionPersistenceActor.getSnapshotConfig()
focal_class.full_signature: @Override protected org.eclipse.ditto.services.utils.persistence.mongo.config.SnapshotConfig getSnapshotConfig()
focal_class.identifier: getSnapshotConfig
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: org.eclipse.ditto.services.utils.persistence.mongo.config.SnapshotConfig
focal_class.signature: org.eclipse.ditto.services.utils.persistence.mongo.config.SnapshotConfig getSnapshotConfig()
focal_class.class_method_signature: ConnectionPersistenceActor.entityExistsAsDeleted()
focal_class.full_signature: @Override protected boolean entityExistsAsDeleted()
focal_class.identifier: entityExistsAsDeleted
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean entityExistsAsDeleted()
focal_class.class_method_signature: ConnectionPersistenceActor.newNotAccessibleExceptionBuilder()
focal_class.full_signature: @Override protected DittoRuntimeExceptionBuilder newNotAccessibleExceptionBuilder()
focal_class.identifier: newNotAccessibleExceptionBuilder
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: DittoRuntimeExceptionBuilder
focal_class.signature: DittoRuntimeExceptionBuilder newNotAccessibleExceptionBuilder()
focal_class.class_method_signature: ConnectionPersistenceActor.publishEvent(final ConnectivityEvent event)
focal_class.full_signature: @Override protected void publishEvent(final ConnectivityEvent event)
focal_class.identifier: publishEvent
focal_class.modifiers: @Override protected
focal_class.parameters: (final ConnectivityEvent event)
focal_class.return: void
focal_class.signature: void publishEvent(final ConnectivityEvent event)
focal_class.class_method_signature: ConnectionPersistenceActor.getEntitySchemaVersion(final Connection entity)
focal_class.full_signature: @Override protected JsonSchemaVersion getEntitySchemaVersion(final Connection entity)
focal_class.identifier: getEntitySchemaVersion
focal_class.modifiers: @Override protected
focal_class.parameters: (final Connection entity)
focal_class.return: JsonSchemaVersion
focal_class.signature: JsonSchemaVersion getEntitySchemaVersion(final Connection entity)
focal_class.class_method_signature: ConnectionPersistenceActor.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: ConnectionPersistenceActor.staleEventsKeptAfterCleanup()
focal_class.full_signature: @Override protected long staleEventsKeptAfterCleanup()
focal_class.identifier: staleEventsKeptAfterCleanup
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long staleEventsKeptAfterCleanup()
focal_class.class_method_signature: ConnectionPersistenceActor.recoveryCompleted(final RecoveryCompleted event)
focal_class.full_signature: @Override protected void recoveryCompleted(final RecoveryCompleted event)
focal_class.identifier: recoveryCompleted
focal_class.modifiers: @Override protected
focal_class.parameters: (final RecoveryCompleted event)
focal_class.return: void
focal_class.signature: void recoveryCompleted(final RecoveryCompleted event)
focal_class.class_method_signature: ConnectionPersistenceActor.onMutation(final Command command, final ConnectivityEvent event, final WithDittoHeaders response,
              final boolean becomeCreated, final boolean becomeDeleted)
focal_class.full_signature: @Override public void onMutation(final Command command, final ConnectivityEvent event, final WithDittoHeaders response,
              final boolean becomeCreated, final boolean becomeDeleted)
focal_class.identifier: onMutation
focal_class.modifiers: @Override public
focal_class.parameters: (final Command command, final ConnectivityEvent event, final WithDittoHeaders response,
              final boolean becomeCreated, final boolean becomeDeleted)
focal_class.return: void
focal_class.signature: void onMutation(final Command command, final ConnectivityEvent event, final WithDittoHeaders response,
              final boolean becomeCreated, final boolean becomeDeleted)
focal_class.class_method_signature: ConnectionPersistenceActor.checkForActivity(final CheckForActivity trigger)
focal_class.full_signature: @Override protected void checkForActivity(final CheckForActivity trigger)
focal_class.identifier: checkForActivity
focal_class.modifiers: @Override protected
focal_class.parameters: (final CheckForActivity trigger)
focal_class.return: void
focal_class.signature: void checkForActivity(final CheckForActivity trigger)
focal_class.class_method_signature: ConnectionPersistenceActor.interpretStagedCommand(final StagedCommand command)
focal_class.full_signature: private void interpretStagedCommand(final StagedCommand command)
focal_class.identifier: interpretStagedCommand
focal_class.modifiers: private
focal_class.parameters: (final StagedCommand command)
focal_class.return: void
focal_class.signature: void interpretStagedCommand(final StagedCommand command)
focal_class.class_method_signature: ConnectionPersistenceActor.matchAnyAfterInitialization()
focal_class.full_signature: @Override protected Receive matchAnyAfterInitialization()
focal_class.identifier: matchAnyAfterInitialization
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: Receive
focal_class.signature: Receive matchAnyAfterInitialization()
focal_class.class_method_signature: ConnectionPersistenceActor.handleResponseOrAcknowledgement(final WithDittoHeaders<?> responseOrAck)
focal_class.full_signature: private void handleResponseOrAcknowledgement(final WithDittoHeaders<?> responseOrAck)
focal_class.identifier: handleResponseOrAcknowledgement
focal_class.modifiers: private
focal_class.parameters: (final WithDittoHeaders<?> responseOrAck)
focal_class.return: void
focal_class.signature: void handleResponseOrAcknowledgement(final WithDittoHeaders<?> responseOrAck)
focal_class.class_method_signature: ConnectionPersistenceActor.handleSignal(final Signal<?> signal)
focal_class.full_signature: private void handleSignal(final Signal<?> signal)
focal_class.identifier: handleSignal
focal_class.modifiers: private
focal_class.parameters: (final Signal<?> signal)
focal_class.return: void
focal_class.signature: void handleSignal(final Signal<?> signal)
focal_class.class_method_signature: ConnectionPersistenceActor.forwardSignalToClientActors(final Signal<?> signal)
focal_class.full_signature: private void forwardSignalToClientActors(final Signal<?> signal)
focal_class.identifier: forwardSignalToClientActors
focal_class.modifiers: private
focal_class.parameters: (final Signal<?> signal)
focal_class.return: void
focal_class.signature: void forwardSignalToClientActors(final Signal<?> signal)
focal_class.class_method_signature: ConnectionPersistenceActor.forwardThingSearchCommandToClientActors(final ThingSearchCommand<?> command)
focal_class.full_signature: private void forwardThingSearchCommandToClientActors(final ThingSearchCommand<?> command)
focal_class.identifier: forwardThingSearchCommandToClientActors
focal_class.modifiers: private
focal_class.parameters: (final ThingSearchCommand<?> command)
focal_class.return: void
focal_class.signature: void forwardThingSearchCommandToClientActors(final ThingSearchCommand<?> command)
focal_class.class_method_signature: ConnectionPersistenceActor.augmentWithPrefixAndForward(final ActorRef receiver, final CreateSubscription createSubscription)
focal_class.full_signature: private void augmentWithPrefixAndForward(final ActorRef receiver, final CreateSubscription createSubscription)
focal_class.identifier: augmentWithPrefixAndForward
focal_class.modifiers: private
focal_class.parameters: (final ActorRef receiver, final CreateSubscription createSubscription)
focal_class.return: void
focal_class.signature: void augmentWithPrefixAndForward(final ActorRef receiver, final CreateSubscription createSubscription)
focal_class.class_method_signature: ConnectionPersistenceActor.computeEnvelopeAndForward(final ActorRef receiver, final String subscriptionId,
              final ThingSearchCommand<?> command)
focal_class.full_signature: private void computeEnvelopeAndForward(final ActorRef receiver, final String subscriptionId,
              final ThingSearchCommand<?> command)
focal_class.identifier: computeEnvelopeAndForward
focal_class.modifiers: private
focal_class.parameters: (final ActorRef receiver, final String subscriptionId,
              final ThingSearchCommand<?> command)
focal_class.return: void
focal_class.signature: void computeEnvelopeAndForward(final ActorRef receiver, final String subscriptionId,
              final ThingSearchCommand<?> command)
focal_class.class_method_signature: ConnectionPersistenceActor.consistentHashableEnvelope(final Object message, final String hashKey)
focal_class.full_signature: private Object consistentHashableEnvelope(final Object message, final String hashKey)
focal_class.identifier: consistentHashableEnvelope
focal_class.modifiers: private
focal_class.parameters: (final Object message, final String hashKey)
focal_class.return: Object
focal_class.signature: Object consistentHashableEnvelope(final Object message, final String hashKey)
focal_class.class_method_signature: ConnectionPersistenceActor.getSubscriptionPrefixLength()
focal_class.full_signature: private int getSubscriptionPrefixLength()
focal_class.identifier: getSubscriptionPrefixLength
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getSubscriptionPrefixLength()
focal_class.class_method_signature: ConnectionPersistenceActor.checkLoggingEnabled(final CheckLoggingActive message)
focal_class.full_signature: private void checkLoggingEnabled(final CheckLoggingActive message)
focal_class.identifier: checkLoggingEnabled
focal_class.modifiers: private
focal_class.parameters: (final CheckLoggingActive message)
focal_class.return: void
focal_class.signature: void checkLoggingEnabled(final CheckLoggingActive message)
focal_class.class_method_signature: ConnectionPersistenceActor.prepareForSignalForwarding(final StagedCommand command)
focal_class.full_signature: private void prepareForSignalForwarding(final StagedCommand command)
focal_class.identifier: prepareForSignalForwarding
focal_class.modifiers: private
focal_class.parameters: (final StagedCommand command)
focal_class.return: void
focal_class.signature: void prepareForSignalForwarding(final StagedCommand command)
focal_class.class_method_signature: ConnectionPersistenceActor.testConnection(final StagedCommand command)
focal_class.full_signature: private void testConnection(final StagedCommand command)
focal_class.identifier: testConnection
focal_class.modifiers: private
focal_class.parameters: (final StagedCommand command)
focal_class.return: void
focal_class.signature: void testConnection(final StagedCommand command)
focal_class.class_method_signature: ConnectionPersistenceActor.setConnectionStatusClosedForTestConnection()
focal_class.full_signature: private void setConnectionStatusClosedForTestConnection()
focal_class.identifier: setConnectionStatusClosedForTestConnection
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void setConnectionStatusClosedForTestConnection()
focal_class.class_method_signature: ConnectionPersistenceActor.openConnection(final StagedCommand command, final boolean ignoreErrors)
focal_class.full_signature: private void openConnection(final StagedCommand command, final boolean ignoreErrors)
focal_class.identifier: openConnection
focal_class.modifiers: private
focal_class.parameters: (final StagedCommand command, final boolean ignoreErrors)
focal_class.return: void
focal_class.signature: void openConnection(final StagedCommand command, final boolean ignoreErrors)
focal_class.class_method_signature: ConnectionPersistenceActor.closeConnection(final StagedCommand command)
focal_class.full_signature: private void closeConnection(final StagedCommand command)
focal_class.identifier: closeConnection
focal_class.modifiers: private
focal_class.parameters: (final StagedCommand command)
focal_class.return: void
focal_class.signature: void closeConnection(final StagedCommand command)
focal_class.class_method_signature: ConnectionPersistenceActor.enhanceLogUtil(final WithDittoHeaders<?> createConnection)
focal_class.full_signature: private void enhanceLogUtil(final WithDittoHeaders<?> createConnection)
focal_class.identifier: enhanceLogUtil
focal_class.modifiers: private
focal_class.parameters: (final WithDittoHeaders<?> createConnection)
focal_class.return: void
focal_class.signature: void enhanceLogUtil(final WithDittoHeaders<?> createConnection)
focal_class.class_method_signature: ConnectionPersistenceActor.logDroppedSignal(final String type, final String reason)
focal_class.full_signature: private void logDroppedSignal(final String type, final String reason)
focal_class.identifier: logDroppedSignal
focal_class.modifiers: private
focal_class.parameters: (final String type, final String reason)
focal_class.return: void
focal_class.signature: void logDroppedSignal(final String type, final String reason)
focal_class.class_method_signature: ConnectionPersistenceActor.retrieveConnectionLogs(final RetrieveConnectionLogs command, final ActorRef sender)
focal_class.full_signature: private void retrieveConnectionLogs(final RetrieveConnectionLogs command, final ActorRef sender)
focal_class.identifier: retrieveConnectionLogs
focal_class.modifiers: private
focal_class.parameters: (final RetrieveConnectionLogs command, final ActorRef sender)
focal_class.return: void
focal_class.signature: void retrieveConnectionLogs(final RetrieveConnectionLogs command, final ActorRef sender)
focal_class.class_method_signature: ConnectionPersistenceActor.isLoggingEnabled()
focal_class.full_signature: private boolean isLoggingEnabled()
focal_class.identifier: isLoggingEnabled
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isLoggingEnabled()
focal_class.class_method_signature: ConnectionPersistenceActor.loggingEnabled()
focal_class.full_signature: private void loggingEnabled()
focal_class.identifier: loggingEnabled
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void loggingEnabled()
focal_class.class_method_signature: ConnectionPersistenceActor.updateLoggingIfEnabled()
focal_class.full_signature: private void updateLoggingIfEnabled()
focal_class.identifier: updateLoggingIfEnabled
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void updateLoggingIfEnabled()
focal_class.class_method_signature: ConnectionPersistenceActor.loggingDisabled()
focal_class.full_signature: private void loggingDisabled()
focal_class.identifier: loggingDisabled
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void loggingDisabled()
focal_class.class_method_signature: ConnectionPersistenceActor.cancelEnabledLoggingChecker()
focal_class.full_signature: private void cancelEnabledLoggingChecker()
focal_class.identifier: cancelEnabledLoggingChecker
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void cancelEnabledLoggingChecker()
focal_class.class_method_signature: ConnectionPersistenceActor.startEnabledLoggingChecker()
focal_class.full_signature: private void startEnabledLoggingChecker()
focal_class.identifier: startEnabledLoggingChecker
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void startEnabledLoggingChecker()
focal_class.class_method_signature: ConnectionPersistenceActor.respondWithEmptyLogs(final RetrieveConnectionLogs command, final ActorRef origin)
focal_class.full_signature: private void respondWithEmptyLogs(final RetrieveConnectionLogs command, final ActorRef origin)
focal_class.identifier: respondWithEmptyLogs
focal_class.modifiers: private
focal_class.parameters: (final RetrieveConnectionLogs command, final ActorRef origin)
focal_class.return: void
focal_class.signature: void respondWithEmptyLogs(final RetrieveConnectionLogs command, final ActorRef origin)
focal_class.class_method_signature: ConnectionPersistenceActor.startAndAskClientActors(final Command<?> cmd, final int clientCount)
focal_class.full_signature: private CompletionStage<Object> startAndAskClientActors(final Command<?> cmd, final int clientCount)
focal_class.identifier: startAndAskClientActors
focal_class.modifiers: private
focal_class.parameters: (final Command<?> cmd, final int clientCount)
focal_class.return: CompletionStage<Object>
focal_class.signature: CompletionStage<Object> startAndAskClientActors(final Command<?> cmd, final int clientCount)
focal_class.class_method_signature: ConnectionPersistenceActor.broadcastToClientActorsIfStarted(final Command<?> cmd, final ActorRef sender)
focal_class.full_signature: private void broadcastToClientActorsIfStarted(final Command<?> cmd, final ActorRef sender)
focal_class.identifier: broadcastToClientActorsIfStarted
focal_class.modifiers: private
focal_class.parameters: (final Command<?> cmd, final ActorRef sender)
focal_class.return: void
focal_class.signature: void broadcastToClientActorsIfStarted(final Command<?> cmd, final ActorRef sender)
focal_class.class_method_signature: ConnectionPersistenceActor.broadcastToClientActorsIfStarted(final Command<?> cmd)
focal_class.full_signature: private CompletionStage<Object> broadcastToClientActorsIfStarted(final Command<?> cmd)
focal_class.identifier: broadcastToClientActorsIfStarted
focal_class.modifiers: private
focal_class.parameters: (final Command<?> cmd)
focal_class.return: CompletionStage<Object>
focal_class.signature: CompletionStage<Object> broadcastToClientActorsIfStarted(final Command<?> cmd)
focal_class.class_method_signature: ConnectionPersistenceActor.broadcastCommandWithDifferentSender(final ConnectivityQueryCommand<?> command,
              final BiFunction<Connection, Duration, Props> senderPropsForConnectionWithTimeout,
              final Runnable onClientActorNotStarted)
focal_class.full_signature: private void broadcastCommandWithDifferentSender(final ConnectivityQueryCommand<?> command,
              final BiFunction<Connection, Duration, Props> senderPropsForConnectionWithTimeout,
              final Runnable onClientActorNotStarted)
focal_class.identifier: broadcastCommandWithDifferentSender
focal_class.modifiers: private
focal_class.parameters: (final ConnectivityQueryCommand<?> command,
              final BiFunction<Connection, Duration, Props> senderPropsForConnectionWithTimeout,
              final Runnable onClientActorNotStarted)
focal_class.return: void
focal_class.signature: void broadcastCommandWithDifferentSender(final ConnectivityQueryCommand<?> command,
              final BiFunction<Connection, Duration, Props> senderPropsForConnectionWithTimeout,
              final Runnable onClientActorNotStarted)
focal_class.class_method_signature: ConnectionPersistenceActor.forwardToClientActors(final Props aggregatorProps, final Command<?> cmd,
              final Runnable onClientActorNotStarted)
focal_class.full_signature: private void forwardToClientActors(final Props aggregatorProps, final Command<?> cmd,
              final Runnable onClientActorNotStarted)
focal_class.identifier: forwardToClientActors
focal_class.modifiers: private
focal_class.parameters: (final Props aggregatorProps, final Command<?> cmd,
              final Runnable onClientActorNotStarted)
focal_class.return: void
focal_class.signature: void forwardToClientActors(final Props aggregatorProps, final Command<?> cmd,
              final Runnable onClientActorNotStarted)
focal_class.class_method_signature: ConnectionPersistenceActor.handleException(final String action, @Nullable final ActorRef origin, final Throwable exception)
focal_class.full_signature: private Void handleException(final String action, @Nullable final ActorRef origin, final Throwable exception)
focal_class.identifier: handleException
focal_class.modifiers: private
focal_class.parameters: (final String action, @Nullable final ActorRef origin, final Throwable exception)
focal_class.return: Void
focal_class.signature: Void handleException(final String action, @Nullable final ActorRef origin, final Throwable exception)
focal_class.class_method_signature: ConnectionPersistenceActor.handleException(final String action,
              @Nullable final ActorRef origin,
              final Throwable error,
              final boolean sendExceptionResponse)
focal_class.full_signature: private Void handleException(final String action,
              @Nullable final ActorRef origin,
              final Throwable error,
              final boolean sendExceptionResponse)
focal_class.identifier: handleException
focal_class.modifiers: private
focal_class.parameters: (final String action,
              @Nullable final ActorRef origin,
              final Throwable error,
              final boolean sendExceptionResponse)
focal_class.return: Void
focal_class.signature: Void handleException(final String action,
              @Nullable final ActorRef origin,
              final Throwable error,
              final boolean sendExceptionResponse)
focal_class.class_method_signature: ConnectionPersistenceActor.retrieveConnectionStatus(final RetrieveConnectionStatus command, final ActorRef sender)
focal_class.full_signature: private void retrieveConnectionStatus(final RetrieveConnectionStatus command, final ActorRef sender)
focal_class.identifier: retrieveConnectionStatus
focal_class.modifiers: private
focal_class.parameters: (final RetrieveConnectionStatus command, final ActorRef sender)
focal_class.return: void
focal_class.signature: void retrieveConnectionStatus(final RetrieveConnectionStatus command, final ActorRef sender)
focal_class.class_method_signature: ConnectionPersistenceActor.extractTimeoutFromCommand(final DittoHeaders headers)
focal_class.full_signature: private static Duration extractTimeoutFromCommand(final DittoHeaders headers)
focal_class.identifier: extractTimeoutFromCommand
focal_class.modifiers: private static
focal_class.parameters: (final DittoHeaders headers)
focal_class.return: Duration
focal_class.signature: Duration extractTimeoutFromCommand(final DittoHeaders headers)
focal_class.class_method_signature: ConnectionPersistenceActor.retrieveConnectionMetrics(final RetrieveConnectionMetrics command, final ActorRef sender)
focal_class.full_signature: private void retrieveConnectionMetrics(final RetrieveConnectionMetrics command, final ActorRef sender)
focal_class.identifier: retrieveConnectionMetrics
focal_class.modifiers: private
focal_class.parameters: (final RetrieveConnectionMetrics command, final ActorRef sender)
focal_class.return: void
focal_class.signature: void retrieveConnectionMetrics(final RetrieveConnectionMetrics command, final ActorRef sender)
focal_class.class_method_signature: ConnectionPersistenceActor.respondWithEmptyMetrics(final RetrieveConnectionMetrics command, final ActorRef origin)
focal_class.full_signature: private void respondWithEmptyMetrics(final RetrieveConnectionMetrics command, final ActorRef origin)
focal_class.identifier: respondWithEmptyMetrics
focal_class.modifiers: private
focal_class.parameters: (final RetrieveConnectionMetrics command, final ActorRef origin)
focal_class.return: void
focal_class.signature: void respondWithEmptyMetrics(final RetrieveConnectionMetrics command, final ActorRef origin)
focal_class.class_method_signature: ConnectionPersistenceActor.respondWithEmptyStatus(final RetrieveConnectionStatus command, final ActorRef origin)
focal_class.full_signature: private void respondWithEmptyStatus(final RetrieveConnectionStatus command, final ActorRef origin)
focal_class.identifier: respondWithEmptyStatus
focal_class.modifiers: private
focal_class.parameters: (final RetrieveConnectionStatus command, final ActorRef origin)
focal_class.return: void
focal_class.signature: void respondWithEmptyStatus(final RetrieveConnectionStatus command, final ActorRef origin)
focal_class.class_method_signature: ConnectionPersistenceActor.getUniqueTopics(@Nullable final Connection theConnection)
focal_class.full_signature: private Set<Topic> getUniqueTopics(@Nullable final Connection theConnection)
focal_class.identifier: getUniqueTopics
focal_class.modifiers: private
focal_class.parameters: (@Nullable final Connection theConnection)
focal_class.return: Set<Topic>
focal_class.signature: Set<Topic> getUniqueTopics(@Nullable final Connection theConnection)
focal_class.class_method_signature: ConnectionPersistenceActor.getTargetAuthSubjects()
focal_class.full_signature: private Set<String> getTargetAuthSubjects()
focal_class.identifier: getTargetAuthSubjects
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: Set<String>
focal_class.signature: Set<String> getTargetAuthSubjects()
focal_class.class_method_signature: ConnectionPersistenceActor.startClientActorsIfRequired(final int clientCount)
focal_class.full_signature: private void startClientActorsIfRequired(final int clientCount)
focal_class.identifier: startClientActorsIfRequired
focal_class.modifiers: private
focal_class.parameters: (final int clientCount)
focal_class.return: void
focal_class.signature: void startClientActorsIfRequired(final int clientCount)
focal_class.class_method_signature: ConnectionPersistenceActor.getClientCount()
focal_class.full_signature: private int getClientCount()
focal_class.identifier: getClientCount
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getClientCount()
focal_class.class_method_signature: ConnectionPersistenceActor.stopClientActors()
focal_class.full_signature: private void stopClientActors()
focal_class.identifier: stopClientActors
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void stopClientActors()
focal_class.class_method_signature: ConnectionPersistenceActor.stopChildActor(final ActorRef actor)
focal_class.full_signature: private void stopChildActor(final ActorRef actor)
focal_class.identifier: stopChildActor
focal_class.modifiers: private
focal_class.parameters: (final ActorRef actor)
focal_class.return: void
focal_class.signature: void stopChildActor(final ActorRef actor)
focal_class.class_method_signature: ConnectionPersistenceActor.isDesiredStateOpen()
focal_class.full_signature: private boolean isDesiredStateOpen()
focal_class.identifier: isDesiredStateOpen
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isDesiredStateOpen()
focal_class.class_method_signature: ConnectionPersistenceActor.restoreOpenConnection()
focal_class.full_signature: private void restoreOpenConnection()
focal_class.identifier: restoreOpenConnection
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void restoreOpenConnection()
focal_class.class_method_signature: ConnectionPersistenceActor.hasSource()
focal_class.full_signature: private boolean hasSource()
focal_class.identifier: hasSource
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean hasSource()
focal_class.class_method_signature: ConnectionPersistenceActor.toStreamingTypes(final Set<Topic> uniqueTopics)
focal_class.full_signature: private static Collection<StreamingType> toStreamingTypes(final Set<Topic> uniqueTopics)
focal_class.identifier: toStreamingTypes
focal_class.modifiers: private static
focal_class.parameters: (final Set<Topic> uniqueTopics)
focal_class.return: Collection<StreamingType>
focal_class.signature: Collection<StreamingType> toStreamingTypes(final Set<Topic> uniqueTopics)
focal_class.class_method_signature: ConnectionPersistenceActor.failedFuture(final Throwable cause)
focal_class.full_signature: private static CompletionStage<T> failedFuture(final Throwable cause)
focal_class.identifier: failedFuture
focal_class.modifiers: private static
focal_class.parameters: (final Throwable cause)
focal_class.return: CompletionStage<T>
focal_class.signature: CompletionStage<T> failedFuture(final Throwable cause)
focal_class.class_method_signature: ConnectionPersistenceActor.toDittoRuntimeException(final Throwable error, final ConnectionId id,
              final DittoHeaders headers)
focal_class.full_signature: private static DittoRuntimeException toDittoRuntimeException(final Throwable error, final ConnectionId id,
              final DittoHeaders headers)
focal_class.identifier: toDittoRuntimeException
focal_class.modifiers: private static
focal_class.parameters: (final Throwable error, final ConnectionId id,
              final DittoHeaders headers)
focal_class.return: DittoRuntimeException
focal_class.signature: DittoRuntimeException toDittoRuntimeException(final Throwable error, final ConnectionId id,
              final DittoHeaders headers)
focal_class.class_method_signature: ConnectionPersistenceActor.processClientAskResult(final CompletionStage<Object> askResultFuture)
focal_class.full_signature: private static CompletionStage<Object> processClientAskResult(final CompletionStage<Object> askResultFuture)
focal_class.identifier: processClientAskResult
focal_class.modifiers: private static
focal_class.parameters: (final CompletionStage<Object> askResultFuture)
focal_class.return: CompletionStage<Object>
focal_class.signature: CompletionStage<Object> processClientAskResult(final CompletionStage<Object> askResultFuture)
focal_class.superclass: extends AbstractShardedPersistenceActor<ConnectivityCommand, Connection, ConnectionId, ConnectionState,
          ConnectivityEvent>
focal_method.body: public static Props props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      ) {
          return Props.create(ConnectionPersistenceActor.class, connectionId, dittoProtocolSub, proxyActor,
                  propsFactory, commandValidator, CLIENT_ACTORS_PER_NODE);
      }
focal_method.class_method_signature: ConnectionPersistenceActor.props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_method.full_signature: public static Props props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_method.identifier: props
focal_method.invocations: create
focal_method.modifiers: public static
focal_method.parameters: (final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )
focal_method.return: Props
focal_method.signature: Props props(final ConnectionId connectionId,
              final DittoProtocolSub dittoProtocolSub,
              final ActorRef proxyActor,
              final ClientActorPropsFactory propsFactory,
              @Nullable final ConnectivityCommandInterceptor commandValidator
      )