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 testHandleSignalWithAcknowledgementRequest() {
          new TestKit(actorSystem) {{
              final TestKit probe = new TestKit(actorSystem);
              final ActorRef underTest =
                      TestConstants.createConnectionSupervisorActor(connectionId, actorSystem, proxyActor,
                              (connection, connectionActor, proxyActor) -> TestActor.props(probe),
                              TestConstants.dummyDittoProtocolSub(pubSubMediator, dittoProtocolSubMock), pubSubMediator);
              watch(underTest);
  
              // create connection
              underTest.tell(createConnection, getRef());
              expectMsgClass(CreateConnectionResponse.class);
  
              // Wait until connection is established
              expectAnySubscribe();
  
              final AcknowledgementLabel acknowledgementLabel = AcknowledgementLabel.of("test-ack");
              final DittoHeaders dittoHeaders = DittoHeaders.newBuilder()
                      .acknowledgementRequest(AcknowledgementRequest.of(acknowledgementLabel))
                      .readGrantedSubjects(Collections.singleton(TestConstants.Authorization.SUBJECT))
                      .timeout("2s")
                      .randomCorrelationId()
                      .build();
  
              final AttributeModified attributeModified = AttributeModified.of(
                      TestConstants.Things.THING_ID, JsonPointer.of("hello"), JsonValue.of("world!"), 5L, dittoHeaders);
              underTest.tell(attributeModified, getRef());
  
              final OutboundSignal unmappedOutboundSignal = probe.expectMsgClass(OutboundSignal.class);
              assertThat(unmappedOutboundSignal.getSource()).isEqualTo(attributeModified);
  
              final Acknowledgement acknowledgement =
                      Acknowledgement.of(acknowledgementLabel, TestConstants.Things.THING_ID, HttpStatusCode.OK,
                              dittoHeaders);
              underTest.tell(acknowledgement, getRef());
  
              expectMsg(acknowledgement);
          }};
      }
test_case.class_method_signature: ConnectionPersistenceActorTest.testHandleSignalWithAcknowledgementRequest()
test_case.full_signature: @Test public void testHandleSignalWithAcknowledgementRequest()
test_case.identifier: testHandleSignalWithAcknowledgementRequest
test_case.invocations: createConnectionSupervisorActor props dummyDittoProtocolSub watch tell getRef expectMsgClass expectAnySubscribe of build randomCorrelationId timeout readGrantedSubjects acknowledgementRequest newBuilder of singleton of of of tell getRef expectMsgClass isEqualTo assertThat getSource of tell getRef expectMsg
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testHandleSignalWithAcknowledgementRequest()
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
      )