test_class.declarator: ID = ConnectionLoggerRegistryTest.class.getSimpleName()
test_class.modifier: private static final
test_class.original_string: private static final String ID = ConnectionLoggerRegistryTest.class.getSimpleName();
test_class.type: String
test_class.var_name: ID
test_class.declarator: underTest =
              ConnectionLoggerRegistry.fromConfig(TestConstants.MONITORING_CONFIG.logger())
test_class.modifier: private final
test_class.original_string: private final ConnectionLoggerRegistry underTest =
              ConnectionLoggerRegistry.fromConfig(TestConstants.MONITORING_CONFIG.logger());
test_class.type: ConnectionLoggerRegistry
test_class.var_name: underTest
test_class.declarator: moreThanLoggingDuration =
              TestConstants.MONITORING_CONFIG.logger().logDuration()
                      .plusMinutes(1)
test_class.modifier: private final
test_class.original_string: private final Duration moreThanLoggingDuration =
              TestConstants.MONITORING_CONFIG.logger().logDuration()
                      .plusMinutes(1);
test_class.type: Duration
test_class.var_name: moreThanLoggingDuration
test_class.file: services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistryTest.java
test_class.identifier: ConnectionLoggerRegistryTest
test_case.body: @Test
      public void isActiveForConnection() {
          final ConnectionId connectionId = connectionId();
          underTest.initForConnection(connection(connectionId));
  
          assertThat(underTest.isActiveForConnection(connectionId)).isFalse();
  
          underTest.unmuteForConnection(connectionId);
  
          assertThat(underTest.isActiveForConnection(connectionId)).isTrue();
  
          underTest.muteForConnection(connectionId);
  
          assertThat(underTest.isActiveForConnection(connectionId)).isFalse();
      }
test_case.class_method_signature: ConnectionLoggerRegistryTest.isActiveForConnection()
test_case.full_signature: @Test public void isActiveForConnection()
test_case.identifier: isActiveForConnection
test_case.invocations: connectionId initForConnection connection isFalse assertThat isActiveForConnection unmuteForConnection isTrue assertThat isActiveForConnection muteForConnection isFalse assertThat isActiveForConnection
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void isActiveForConnection()
focal_class.declarator: LOGGER = LoggerFactory.getLogger(ConnectionLoggerRegistry.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOGGER = LoggerFactory.getLogger(ConnectionLoggerRegistry.class);
focal_class.type: Logger
focal_class.var_name: LOGGER
focal_class.declarator: loggers = new ConcurrentHashMap<>()
focal_class.modifier: private static final
focal_class.original_string: private static final ConcurrentMap<MapKey, MuteableConnectionLogger> loggers = new ConcurrentHashMap<>();
focal_class.type: ConcurrentMap<MapKey, MuteableConnectionLogger>
focal_class.var_name: loggers
focal_class.declarator: metadata = new ConcurrentHashMap<>()
focal_class.modifier: private static final
focal_class.original_string: private static final ConcurrentMap<EntityId, LogMetadata> metadata = new ConcurrentHashMap<>();
focal_class.type: ConcurrentMap<EntityId, LogMetadata>
focal_class.var_name: metadata
focal_class.declarator: RESPONSES_ADDRESS = "_responses"
focal_class.modifier: private static final
focal_class.original_string: private static final String RESPONSES_ADDRESS = "_responses";
focal_class.type: String
focal_class.var_name: RESPONSES_ADDRESS
focal_class.declarator: successCapacity
focal_class.modifier: private final
focal_class.original_string: private final int successCapacity;
focal_class.type: int
focal_class.var_name: successCapacity
focal_class.declarator: failureCapacity
focal_class.modifier: private final
focal_class.original_string: private final int failureCapacity;
focal_class.type: int
focal_class.var_name: failureCapacity
focal_class.declarator: loggingDuration
focal_class.modifier: private final
focal_class.original_string: private final TemporalAmount loggingDuration;
focal_class.type: TemporalAmount
focal_class.var_name: loggingDuration
focal_class.declarator: maximumLogSizeInByte
focal_class.modifier: private final
focal_class.original_string: private final long maximumLogSizeInByte;
focal_class.type: long
focal_class.var_name: maximumLogSizeInByte
focal_class.file: services/connectivity/messaging/src/main/java/org/eclipse/ditto/services/connectivity/messaging/monitoring/logs/ConnectionLoggerRegistry.java
focal_class.identifier: ConnectionLoggerRegistry
focal_class.interfaces: implements ConnectionMonitorRegistry<ConnectionLogger>
focal_class.class_method_signature: ConnectionLoggerRegistry.ConnectionLoggerRegistry(final int successCapacity, final int failureCapacity,
              final long maximumLogSizeInByte, final Duration loggingDuration)
focal_class.full_signature: private  ConnectionLoggerRegistry(final int successCapacity, final int failureCapacity,
              final long maximumLogSizeInByte, final Duration loggingDuration)
focal_class.identifier: ConnectionLoggerRegistry
focal_class.modifiers: private
focal_class.parameters: (final int successCapacity, final int failureCapacity,
              final long maximumLogSizeInByte, final Duration loggingDuration)
focal_class.signature:  ConnectionLoggerRegistry(final int successCapacity, final int failureCapacity,
              final long maximumLogSizeInByte, final Duration loggingDuration)
focal_class.class_method_signature: ConnectionLoggerRegistry.fromConfig(final MonitoringLoggerConfig config)
focal_class.full_signature: public static ConnectionLoggerRegistry fromConfig(final MonitoringLoggerConfig config)
focal_class.identifier: fromConfig
focal_class.modifiers: public static
focal_class.parameters: (final MonitoringLoggerConfig config)
focal_class.return: ConnectionLoggerRegistry
focal_class.signature: ConnectionLoggerRegistry fromConfig(final MonitoringLoggerConfig config)
focal_class.class_method_signature: ConnectionLoggerRegistry.aggregateLogs(final ConnectionId connectionId)
focal_class.full_signature: public ConnectionLogs aggregateLogs(final ConnectionId connectionId)
focal_class.identifier: aggregateLogs
focal_class.modifiers: public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: ConnectionLogs
focal_class.signature: ConnectionLogs aggregateLogs(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.restrictMaxLogEntriesLength(final List<LogEntry> originalLogEntries, final ConnectionId connectionId)
focal_class.full_signature: private List<LogEntry> restrictMaxLogEntriesLength(final List<LogEntry> originalLogEntries, final ConnectionId connectionId)
focal_class.identifier: restrictMaxLogEntriesLength
focal_class.modifiers: private
focal_class.parameters: (final List<LogEntry> originalLogEntries, final ConnectionId connectionId)
focal_class.return: List<LogEntry>
focal_class.signature: List<LogEntry> restrictMaxLogEntriesLength(final List<LogEntry> originalLogEntries, final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.isActiveForConnection(final ConnectionId connectionId)
focal_class.full_signature: protected boolean isActiveForConnection(final ConnectionId connectionId)
focal_class.identifier: isActiveForConnection
focal_class.modifiers: protected
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: boolean
focal_class.signature: boolean isActiveForConnection(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.isLoggingExpired(final ConnectionId connectionId, final Instant timestamp)
focal_class.full_signature: public boolean isLoggingExpired(final ConnectionId connectionId, final Instant timestamp)
focal_class.identifier: isLoggingExpired
focal_class.modifiers: public
focal_class.parameters: (final ConnectionId connectionId, final Instant timestamp)
focal_class.return: boolean
focal_class.signature: boolean isLoggingExpired(final ConnectionId connectionId, final Instant timestamp)
focal_class.class_method_signature: ConnectionLoggerRegistry.muteForConnection(final ConnectionId connectionId)
focal_class.full_signature: public void muteForConnection(final ConnectionId connectionId)
focal_class.identifier: muteForConnection
focal_class.modifiers: public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: void
focal_class.signature: void muteForConnection(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.unmuteForConnection(final ConnectionId connectionId)
focal_class.full_signature: public void unmuteForConnection(final ConnectionId connectionId)
focal_class.identifier: unmuteForConnection
focal_class.modifiers: public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: void
focal_class.signature: void unmuteForConnection(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.streamLoggers(final ConnectionId connectionId)
focal_class.full_signature: private Stream<MuteableConnectionLogger> streamLoggers(final ConnectionId connectionId)
focal_class.identifier: streamLoggers
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: Stream<MuteableConnectionLogger>
focal_class.signature: Stream<MuteableConnectionLogger> streamLoggers(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.initForConnection(final Connection connection)
focal_class.full_signature: @Override public void initForConnection(final Connection connection)
focal_class.identifier: initForConnection
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection)
focal_class.return: void
focal_class.signature: void initForConnection(final Connection connection)
focal_class.class_method_signature: ConnectionLoggerRegistry.initLogger(final ConnectionId connectionId, final LogCategory logCategory)
focal_class.full_signature: private void initLogger(final ConnectionId connectionId, final LogCategory logCategory)
focal_class.identifier: initLogger
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId, final LogCategory logCategory)
focal_class.return: void
focal_class.signature: void initLogger(final ConnectionId connectionId, final LogCategory logCategory)
focal_class.class_method_signature: ConnectionLoggerRegistry.initLogger(final ConnectionId connectionId, final LogCategory logCategory,
              @Nullable final String address)
focal_class.full_signature: private void initLogger(final ConnectionId connectionId, final LogCategory logCategory,
              @Nullable final String address)
focal_class.identifier: initLogger
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId, final LogCategory logCategory,
              @Nullable final String address)
focal_class.return: void
focal_class.signature: void initLogger(final ConnectionId connectionId, final LogCategory logCategory,
              @Nullable final String address)
focal_class.class_method_signature: ConnectionLoggerRegistry.resetForConnection(final Connection connection)
focal_class.full_signature: @Override public void resetForConnection(final Connection connection)
focal_class.identifier: resetForConnection
focal_class.modifiers: @Override public
focal_class.parameters: (final Connection connection)
focal_class.return: void
focal_class.signature: void resetForConnection(final Connection connection)
focal_class.class_method_signature: ConnectionLoggerRegistry.resetForConnectionId(final ConnectionId connectionId)
focal_class.full_signature: private void resetForConnectionId(final ConnectionId connectionId)
focal_class.identifier: resetForConnectionId
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: void
focal_class.signature: void resetForConnectionId(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.refreshMetadata(final ConnectionId connectionId)
focal_class.full_signature: private LogMetadata refreshMetadata(final ConnectionId connectionId)
focal_class.identifier: refreshMetadata
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: LogMetadata
focal_class.signature: LogMetadata refreshMetadata(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.startMetadata(final ConnectionId connectionId)
focal_class.full_signature: private void startMetadata(final ConnectionId connectionId)
focal_class.identifier: startMetadata
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: void
focal_class.signature: void startMetadata(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.stopMetadata(final ConnectionId connectionId)
focal_class.full_signature: private void stopMetadata(final ConnectionId connectionId)
focal_class.identifier: stopMetadata
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: void
focal_class.signature: void stopMetadata(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.getMetadata(final ConnectionId connectionId)
focal_class.full_signature: private LogMetadata getMetadata(final ConnectionId connectionId)
focal_class.identifier: getMetadata
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: LogMetadata
focal_class.signature: LogMetadata getMetadata(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.forOutboundDispatched(final ConnectionId connectionId, final String target)
focal_class.full_signature: @Override public ConnectionLogger forOutboundDispatched(final ConnectionId connectionId, final String target)
focal_class.identifier: forOutboundDispatched
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String target)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forOutboundDispatched(final ConnectionId connectionId, final String target)
focal_class.class_method_signature: ConnectionLoggerRegistry.forOutboundAcknowledged(final ConnectionId connectionId, final String target)
focal_class.full_signature: @Override public ConnectionLogger forOutboundAcknowledged(final ConnectionId connectionId, final String target)
focal_class.identifier: forOutboundAcknowledged
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String target)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forOutboundAcknowledged(final ConnectionId connectionId, final String target)
focal_class.class_method_signature: ConnectionLoggerRegistry.forOutboundFiltered(final ConnectionId connectionId, final String target)
focal_class.full_signature: @Override public ConnectionLogger forOutboundFiltered(final ConnectionId connectionId, final String target)
focal_class.identifier: forOutboundFiltered
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String target)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forOutboundFiltered(final ConnectionId connectionId, final String target)
focal_class.class_method_signature: ConnectionLoggerRegistry.forOutboundPublished(final ConnectionId connectionId, final String target)
focal_class.full_signature: @Override public ConnectionLogger forOutboundPublished(final ConnectionId connectionId, final String target)
focal_class.identifier: forOutboundPublished
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String target)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forOutboundPublished(final ConnectionId connectionId, final String target)
focal_class.class_method_signature: ConnectionLoggerRegistry.forInboundConsumed(final ConnectionId connectionId, final String source)
focal_class.full_signature: @Override public ConnectionLogger forInboundConsumed(final ConnectionId connectionId, final String source)
focal_class.identifier: forInboundConsumed
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String source)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forInboundConsumed(final ConnectionId connectionId, final String source)
focal_class.class_method_signature: ConnectionLoggerRegistry.forInboundAcknowledged(final ConnectionId connectionId, final String source)
focal_class.full_signature: @Override public ConnectionLogger forInboundAcknowledged(final ConnectionId connectionId, final String source)
focal_class.identifier: forInboundAcknowledged
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String source)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forInboundAcknowledged(final ConnectionId connectionId, final String source)
focal_class.class_method_signature: ConnectionLoggerRegistry.forInboundMapped(final ConnectionId connectionId, final String source)
focal_class.full_signature: @Override public ConnectionLogger forInboundMapped(final ConnectionId connectionId, final String source)
focal_class.identifier: forInboundMapped
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String source)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forInboundMapped(final ConnectionId connectionId, final String source)
focal_class.class_method_signature: ConnectionLoggerRegistry.forInboundEnforced(final ConnectionId connectionId, final String source)
focal_class.full_signature: @Override public ConnectionLogger forInboundEnforced(final ConnectionId connectionId, final String source)
focal_class.identifier: forInboundEnforced
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String source)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forInboundEnforced(final ConnectionId connectionId, final String source)
focal_class.class_method_signature: ConnectionLoggerRegistry.forInboundDropped(final ConnectionId connectionId, final String source)
focal_class.full_signature: @Override public ConnectionLogger forInboundDropped(final ConnectionId connectionId, final String source)
focal_class.identifier: forInboundDropped
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId, final String source)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forInboundDropped(final ConnectionId connectionId, final String source)
focal_class.class_method_signature: ConnectionLoggerRegistry.forResponseDispatched(final ConnectionId connectionId)
focal_class.full_signature: @Override public ConnectionLogger forResponseDispatched(final ConnectionId connectionId)
focal_class.identifier: forResponseDispatched
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forResponseDispatched(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.forResponseDropped(final ConnectionId connectionId)
focal_class.full_signature: @Override public ConnectionLogger forResponseDropped(final ConnectionId connectionId)
focal_class.identifier: forResponseDropped
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forResponseDropped(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.forResponseMapped(final ConnectionId connectionId)
focal_class.full_signature: @Override public ConnectionLogger forResponseMapped(final ConnectionId connectionId)
focal_class.identifier: forResponseMapped
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forResponseMapped(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.forResponsePublished(final ConnectionId connectionId)
focal_class.full_signature: @Override public ConnectionLogger forResponsePublished(final ConnectionId connectionId)
focal_class.identifier: forResponsePublished
focal_class.modifiers: @Override public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forResponsePublished(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.forConnection(final ConnectionId connectionId)
focal_class.full_signature: public ConnectionLogger forConnection(final ConnectionId connectionId)
focal_class.identifier: forConnection
focal_class.modifiers: public
focal_class.parameters: (final ConnectionId connectionId)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger forConnection(final ConnectionId connectionId)
focal_class.class_method_signature: ConnectionLoggerRegistry.getLogger(
              final ConnectionId connectionId,
              final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.full_signature: public ConnectionLogger getLogger(
              final ConnectionId connectionId,
              final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.identifier: getLogger
focal_class.modifiers: public
focal_class.parameters: (
              final ConnectionId connectionId,
              final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.return: ConnectionLogger
focal_class.signature: ConnectionLogger getLogger(
              final ConnectionId connectionId,
              final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.class_method_signature: ConnectionLoggerRegistry.newMuteableLogger(final ConnectionId connectionId, final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.full_signature: private MuteableConnectionLogger newMuteableLogger(final ConnectionId connectionId, final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.identifier: newMuteableLogger
focal_class.modifiers: private
focal_class.parameters: (final ConnectionId connectionId, final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.return: MuteableConnectionLogger
focal_class.signature: MuteableConnectionLogger newMuteableLogger(final ConnectionId connectionId, final LogCategory logCategory,
              final LogType logType,
              @Nullable final String address)
focal_class.class_method_signature: ConnectionLoggerRegistry.equals(@Nullable final Object o)
focal_class.full_signature: @Override public boolean equals(@Nullable final Object o)
focal_class.identifier: equals
focal_class.modifiers: @Override public
focal_class.parameters: (@Nullable final Object o)
focal_class.return: boolean
focal_class.signature: boolean equals(@Nullable final Object o)
focal_class.class_method_signature: ConnectionLoggerRegistry.hashCode()
focal_class.full_signature: @Override public int hashCode()
focal_class.identifier: hashCode
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int hashCode()
focal_class.class_method_signature: ConnectionLoggerRegistry.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_method.body: protected boolean isActiveForConnection(final ConnectionId connectionId) {
          final boolean muted = streamLoggers(connectionId)
                  .findFirst()
                  .map(MuteableConnectionLogger::isMuted)
                  .orElse(true);
          return !muted;
      }
focal_method.class_method_signature: ConnectionLoggerRegistry.isActiveForConnection(final ConnectionId connectionId)
focal_method.full_signature: protected boolean isActiveForConnection(final ConnectionId connectionId)
focal_method.identifier: isActiveForConnection
focal_method.invocations: orElse map findFirst streamLoggers
focal_method.modifiers: protected
focal_method.parameters: (final ConnectionId connectionId)
focal_method.return: boolean
focal_method.signature: boolean isActiveForConnection(final ConnectionId connectionId)