Changes
prepared Ditto 2.0.0 release notes + announcement blogpost
(details / githubweb ) Open and create connection with automated logging activation
(details / githubweb ) Fix test when open connection with automated logging activation
(details / githubweb ) Mention that connection logging is enabled when opening or creating connection
(details / githubweb ) Fix test for logging enabling
(details / githubweb ) Issue #1043: Moved `EmptyTopicPath` from `ImmutableTopicPathBuilder` to package level. Added a unit test.
(details / githubweb ) updated release notes with the current module/package structure
(details / githubweb ) documented removal of "x-ditto-dummy-auth" header
(details / githubweb ) updated renamed modules/packages
(details / githubweb ) Issue #1043: Reduced too high amount of constructor arguments of `ImmutableTopicPath`.
(details / githubweb ) Issue #1043: Added methods for easier evaluation of `TopicPath`.
(details / githubweb ) Issue #1043: Replaced equality checks with call to `is...` methods of `TopicPath`.
(details / githubweb ) Issue #1043: Fixed result creation of `ImmutableTopicPath#getPath()` and added a unit test that covers an empty namespace part.
(details / githubweb ) update maven packages names in maven structure overview;
(details / githubweb ) improve release announcement and release notes;
(details / githubweb ) fiy typo;
(details / githubweb ) Issue #1043: Set '@since' version to 2.0.0.
(details / githubweb ) Issue #1043: Removed empty topic path and its usage. Ditto Protocol messages are always required to have a topic. Thus an empty topic path implementation did not make sense.
(details / githubweb ) Issue #1043: Added missing 'package-info' files to packages to add `@Nullable` annotations.
(details / githubweb ) Issue #1043: Fixed Javadoc comment.
(details / githubweb ) Add connectivity announcements for when a connection was opened or closed
(details / githubweb ) Issue #1043: Refactored `AbstractAdapter`.
(details / githubweb ) fixed GitHub actions (dockerfiles were moved)
(details / githubweb ) Issue #1043: Re-added missing 'package-info' files to packages to add `@Nullable` annotations.
(details / githubweb ) Issue #1043: Fixed compilation errors after merging master branch.
(details / githubweb ) added ditto-things-model and ditto-policies-model as explicit dependencies to ditto-protocol
(details / githubweb ) Issue #1043: Fixed invalid reference in Javadoc.
(details / githubweb ) changed scope to compile for ditto-internal-utils-persistence
(details / githubweb ) temporary ignore TimeMeasuringFlowTests
(details / githubweb ) Issue 1043 fix minor misspelling as part of review
(details / githubweb ) Add connectivity announcements to the ditto protocol
(details / githubweb ) added "akka-discovery-kubernetes-api" and "akka-lease-kubernetes" dependencies to ditto-base-service so that all services depend on it
(details / githubweb ) stabilize PolicyPersistenceActorTest by waiting for at least once for deletion announcement
(details / githubweb ) stabilize ConnectionPersistenceActorTest EnableConnectionLogs related test instabilities
(details / githubweb ) Also resolve connectivity signals from Adaptables
(details / githubweb ) stabilize ConnectionPersistenceActorTest EnableConnectionLogs related test instabilities, part 2
(details / githubweb ) Add connection announcements to the Topic
(details / githubweb ) made EmptyEvent no longer implement WithEntityId
(details / githubweb ) stabilize ConnectionPersistenceActorTest EnableConnectionLogs related test instabilities, part 3
(details / githubweb ) Add connection announcements to the signal filter
(details / githubweb ) fix MQTT publisher warnings when no MQTT consumer was present
(details / githubweb ) Don't subscribe to internal Ditto PubSub for connectivity announcements as they are only sent outwards
(details / githubweb ) redact sensitive parameter/header values before logging
(details / githubweb ) fixed some sonar issues and typos;
(details / githubweb ) don't calculate filteredRawRequestUri if debug logging was not activated
(details / githubweb ) updated date of release 2.0 in docs
(details / githubweb ) fixed javadoc errors discovered in release build
(details / githubweb ) added Ditto 2.0 to documentation version picker
(details / githubweb ) activate binary compatibility check to version 2.0.0
(details / githubweb ) added Ditto 2.0.x to SECURITY.md
(details / githubweb ) restructure kubernetes deployment Readmes;
(details / githubweb ) bump nginx version to 1.20-alpine;
(details / githubweb ) #1052: Fix typo
(details / githubweb ) Send connection announcement after opening and before closing a connection
(details / githubweb ) Close connections when shutting down the the cluster (which will trigger sending a close announcement)
(details / githubweb ) Close connection before deleting it (which will automatically send a connection announcement)
(details / githubweb ) fix ErrorHandlingActorTest
(details / githubweb ) Avoids throwing exceptions in ditto metrics and return more or less
(details / githubweb ) fixed typo in 2.0 announcement
(details / githubweb ) only log warning if already stopped timer should be stopped
(details / githubweb ) fixed parallelism of search-updater using "flatMapMerge"
(details / githubweb ) added custom dispatchers for flatMapMerge() with async() usage in
(details / githubweb ) fixed EnforcementFlowTest
(details / githubweb ) added missing dispatcher to search test config
(details / githubweb ) fixed SearchActorIT
(details / githubweb ) fixed that Policy Error responses in WS contained wrong topic path
(details / githubweb ) #1052: validate that connection announcements can only be used with client count 1
(details / githubweb ) fixed default config of retrieval.parallelism to be a factor of 2
(details / githubweb ) removed .withAttributes(Attributes.inputBuffer from search-updater-flows
(details / githubweb ) uncomment resources config for all services;
(details / githubweb ) #1052: Add documentation for connection announcement
(details / githubweb ) #1052: mention connection announcements in protocol-specification.md
(details / githubweb ) relax mqtt validation for source header mappings
(details / githubweb ) Fixed missing publish metrics for published messages without
(details / githubweb ) 1052: fix wording for connection announcement
(details / githubweb ) fixed that for commands requesting "search-persisted" the wrong write concern was used
(details / githubweb ) added "docker pulls" badge to readme
(details / githubweb ) Issue #1060: add test cases for Azure and AWS signing processes
(details / githubweb ) made AckUpdater work with ddata sharding
(details / githubweb ) Issue #1060: add azure monitor request signing
(details / githubweb ) Issue #1060: Add AwsRequestSigning; switch signing timestamp formatter to DateTimeFormatter; add TODO in AbstractBaseClientActorTest
(details / githubweb ) Issue #1060: Add HmacCredentials.
(details / githubweb ) Fix broken links in installation-operating.md
(details / githubweb ) Implement basic structure for kafka consumers
(details / githubweb ) added logging a type hint to AbstractEnforcement successful enforcement
(details / githubweb ) put log statements with debug content to DEBUG level
(details / githubweb ) Added validation for source address and target header mappings
(details / githubweb ) Issue #1060: add dynamic loading of HTTP request signing algorithms.
(details / githubweb ) review: fixed comment which still pointed to outdated enum name
(details / githubweb ) Handle exceptions in MessageProcessor to avoid exceptions in KafkaStreams
(details / githubweb ) Make move the logic again to a transformer
(details / githubweb ) use var keyword;
(details / githubweb ) Use correct branch names to access them in the map
(details / githubweb ) use min interval from backoffConfig to create RestartSettings;
(details / githubweb ) Issue #1060: Only validate certificate for client certificate credentials in the absence of server certificate; do not throw UnsupportedOperationsException in other cases.
(details / githubweb ) move start of stream to preStart hook
(details / githubweb ) move initialisation of logger back to top
(details / githubweb ) Use scalas Either to avoid using generic Object as return type
(details / githubweb ) WIP: switch to akka-stream-kafka
(details / githubweb ) fix MQTT protocol level acknowledgements
(details / githubweb ) fixed applying "eventLoopThreads" option
(details / githubweb ) #1052: edit documentation for topic path of connection announcements
(details / githubweb ) applied manual reconnect for MQTT connections
(details / githubweb ) make it possible to write logs to Logstash endpoint;
(details / githubweb ) add logstash-logback-encoder and janino dependency;
(details / githubweb ) add exclude for shade plugin;
(details / githubweb ) add volume and volumeMounts to access ditto log files;
(details / githubweb ) #1052 correct year in licence header
(details / githubweb ) removed duplicate check for empty failed responses;
(details / githubweb ) add missing volumeMounts;
(details / githubweb ) add logging possibilities to installation-operating.md;
(details / githubweb ) review: prefixed all logging related environment variables with `DITTO_LOGGING_`
(details / githubweb ) fixed logback XML error
(details / githubweb ) added Ditto 2.0.1 release notes
(details / githubweb ) Issue #1060: Support GET method in HTTP connections; support x-amz-content-sha256 in AwsRequestSigning.
(details / githubweb ) added a new introduction slide-deck for Eclipse Ditto
(details / githubweb ) Issue #1060: Fix xAmzContentSha256 field name; log outgoing HTTP request on DEBUG.
(details / githubweb ) Remove not needed hyphen in ditto-cluster.yaml
(details / githubweb ) Surround env value with double quotation marks
(details / githubweb ) Fix command to start ditto with another version
(details / githubweb ) Issue #1060: Log signed requests on DEBUG level.
(details / githubweb ) Connectivity: Improve debug log for incoming messages.
(details / githubweb ) Fix missing placeholder in debug log.
(details / githubweb ) #586 add configuration for kafka consumer, add migration notes for changed kafka configuration
(details / githubweb ) Fix parameter passing to payload mapper when topic path contains no channel
(details / githubweb ) Append signature topics with undefined channel
(details / githubweb ) add logging in case of errors;
(details / githubweb ) make ThingPersistenceActorMailbox size configurable via env variable;
(details / githubweb ) #1052: correctly deserialize and serialize the parts of a topic for the "none" channel (policies and connections) in the JavaScript mappings
(details / githubweb ) #1052: add unit tests verifying correct behaviour of the Ditto JavaScript helper functions for policy and connection announcements
(details / githubweb ) Issue #1060: Add missing header for AWS request signing.
(details / githubweb ) add debug log for dropped signals, if target address can not be resolved;
(details / githubweb ) Issue #1060: render auth parameters without quotes in AwsRequestSigning.
(details / githubweb ) split log for targets and replayTarget into separate statements;
(details / githubweb ) Issue #1060: Fix AwsRequestSigningTest.
(details / githubweb ) #586 use alpakka kafka also for sending messages to kafka cluster, remove dependencies to kafka-clients and kafka-streams, adapt service config and tests
(details / githubweb ) Issue #1060: Add reserved HTTP header "http.query" to replace the query string.
(details / githubweb ) #1060 fix behaviour on empty path. Add unit tests
(details / githubweb ) Issue #1060: Fix double-appending of "/" to empty paths in AwsRequestSigning.
(details / githubweb ) Issue #1060: Fix AwsRequestSigningTest again.
(details / githubweb ) bump nginx version in docker-compose.yml to 1.20-alpine;
(details / githubweb ) add initContainer for nginx to wait for gateway to be available before start up;
(details / githubweb ) remove link to /apidoc/1 in index.html in docker and kubernetes;
(details / githubweb ) add link to resource quota docu;
(details / githubweb ) Issue #1060: Add HMAC credentials to connection schema.
(details / githubweb ) Issue #1060: Document HMAC request signing.
(details / githubweb ) #586 add throttling config for kafka consumers, resolve defaults for akka.kafka.consumer and akka.kafka.producer
(details / githubweb ) Issue #1060: Validate connections with HMAC credentials.
(details / githubweb ) #1060: Documentation: add GET as new http verb for http1.1 connections
(details / githubweb ) #586 add defaults from reference.conf manually (temp. solution)
(details / githubweb ) #1060: add documentation entry for "http.query" header mapping
(details / githubweb ) #586 update to akka 2.6.14
(details / githubweb ) #586 configure shade plugin to append version.conf files for connectivity service (akka kafka contains another version.conf)
(details / githubweb ) #586 add immutability test and reduced logging for message transformer
(details / githubweb ) #1073 reduce logging of JWT parsing/validation errors to not contain stacktrace
(details / githubweb ) #586 use defaults from reference.conf
(details / githubweb ) omit secrets from toString() outputs of Credentials implementations
(details / githubweb ) change directory where ditto log files will be created;
(details / githubweb ) change fileNamePattern for TimeBasedRollingPolicy to absolute path;
(details / githubweb ) add log file directory to docker image and grabt ditto user write access;
(details / githubweb ) add env var DITTO_LOGGING_FILE_APPENDER to docker-compose.yml and create volume to access ditto logs on host machine;
(details / githubweb ) don't try to publish ExpiryAnnouncements for new or deleted policies (optimization)
(details / githubweb ) fixed imports of ditto-connecticity-model OSGi bundle
(details / githubweb ) [#1078] Add AzSaslRequestSigning.
(details / githubweb ) added (currently failing) test case for enriching MergeEvents with extra fields using the CachingSignalEnrichmentFacade
(details / githubweb ) fixed CachingSignalEnrichmentFacade for ThingMerged events
(details / githubweb ) fix docker image name;
(details / githubweb ) uncomment resources for easier testing;
(details / githubweb ) adjusted example usage of Ditto Java Client
(details / githubweb ) [#1078] Add option to set SR in AzSaslRequestSigning.
(details / githubweb ) Enable separate configuration for minimum reconnect delay for MQTT broker initiated disconnects of MQTT sessions
(details / githubweb ) [#1078] rename "sr" to "endpoint" in AzSaslRequestSigning.
(details / githubweb ) fixed test.conf
(details / githubweb ) fixed connection-test.conf
(details / githubweb ) [#1078] Make "endpoint" of AzSaslRequestSigning mandatory.
(details / githubweb ) #1081 add conditioned thing templates list to implicit mapper
(details / githubweb ) [#1078] Allow AzSaslRequestSigning to authenticate AMQP 1.0 connections.
(details / githubweb ) [#1078] Make JSON field definitions of request signing factories final.
(details / githubweb ) [#1078] Fix ConnectionValidatorTest.
(details / githubweb ) add pod to initialize ditto logs directory on host vm;
(details / githubweb ) use gid 1000 for ditto group;
(details / githubweb ) #1081 add exists to filter functions
(details / githubweb ) [#1078] Fix AMQP username of AzSaslRequestSigning.
(details / githubweb ) [#1078] use DittoDuration format for AzSaslRequestSigning's ttl parameter.
(details / githubweb ) rename volume for ditto log files;
(details / githubweb ) add prerequisite to documentation for ditto log files;
(details / githubweb ) #586 ignore duplicate headers (log warning only), clean up connectivity.conf
(details / githubweb ) [#1078] set default TTL of az-sasl to 1 week to prevent cascading backoff.
(details / githubweb ) Filter expired messages based on creation-time and ttl headers
(details / githubweb ) #586 add entity placeholders to resolver creators to use in kafka targets
(details / githubweb ) [#1078] provide actorSystem in ClientActorPropsFactory#getActorPropsForType instead of having it in every DittoService
(details / githubweb ) #586 add dispatcher for alpakka kafka
(details / githubweb ) #586 use dispatcher only for consuming messages from kafka
(details / githubweb ) [#1078] add test for SaslPlainCredentialsSupplier
(details / githubweb ) [#1078] split request signing factories into different factories for http push and amqp
(details / githubweb ) create $DITTO_HOME and $DITTO_LOGS directory inside the one RUN directive for all dockerfiles;
(details / githubweb ) Add documentation for kafka sources
(details / githubweb ) [#1078] fix DefaultAmqp10ConfigTest
(details / githubweb ) [#1078] Remove test to not verify SSL certificates.
(details / githubweb ) [#1078] Restore support of client-certificate credentials with basic-auth for SaslPlainCredentialsSupplier.
(details / githubweb ) #586 suffix kafka consumer/producer client ids
(details / githubweb ) [#1078] move documentation on HMAC signing onto extra page and reference it from HTTP and AMQP 1.0 bindings.
(details / githubweb ) [#1078] add blog post for HMAC signing for HTTP push and AMQP connections
(details / githubweb ) fix rounding up "policyExpiryGranularity" to "0" (disabling it)
(details / githubweb ) update installation-operating.md;
(details / githubweb ) [#1078] update little parts on the documentation of HMAC algorithms
(details / githubweb ) [#1078] fix how AMQP connections handle the validateCertificates configuration, which was causing timeouts when connecting to a secured resource with validateCertificates=false. Also re-add the 'testTLSConnectionWithoutCertificateCheck' which verifies the correct behavior for this.
(details / githubweb ) [#1078] add HMAC signing to sidebar and include examples section
(details / githubweb ) [#1060] Connectivity: Add reserved header http.path to set the path of outgoing HTTP requests.
(details / githubweb ) #586 drop consumed messages in dry run mode, disable auto commit in dry run mode
(details / githubweb ) [#1078] Fix typos.
(details / githubweb ) stabilize coordinated shutdown hook in BaseClientActor for sending connection announcements:
(details / githubweb ) update Akka to 2.6.15 and Akka Management to 1.1.0
(details / githubweb ) #586 use streams to publish messages to kafka
(details / githubweb ) #586 fix test
(details / githubweb ) fix HttpPushFactoryTest by using a parallelism with power of 2
(details / githubweb ) adjusted gateway.conf to let "service-requests-done" coordinated shutdown phase timeout be 12s, 2s longer than the "ditto.gateway.http.coordinated-shutdown-timeout"
(details / githubweb ) try to fix EnformcentFlowTest
(details / githubweb ) [#1060] Adjust AwsRequestSigning to support S3 better.
(details / githubweb ) [#1078] Add cloud integration examples using HMAC.
(details / githubweb ) fixed EnforcementFlow parallelism
(details / githubweb ) Fix naming
(details / githubweb ) downgrade to Akka 2.6.14 again after Akka streams has some changes (or even a bug) to attribute propagation which could lead to a very different behavior
(details / githubweb ) enable POST, PUT and DELETE requests for akka management api;
(details / githubweb ) [#1088] retry starting BaseClientActors when they fail when being started by the ConnectionPersistenceActor. Escalate failures of the router pool to the supervisor actor which can restart the ConnectionPersistenceActor.
(details / githubweb ) updated to Akka 2.6.15 again and fixed EnforcementFlowTest
(details / githubweb ) #586 use SendProducer instead of Producer.flexiFlow() to be able to handle the publish errors/acknowledgfements correctly, re-enabled KafkaPublisherActorTest
(details / githubweb ) don't remove all other addresses in ClusterMemberRemovedAware when own instance was terminated
(details / githubweb ) #586 move producer config to producer section
(details / githubweb ) remove non needed Attributes inputBuffer on EnforcementFlow
(details / githubweb ) review: made OneForOneEscalateStrategy final + minor javadoc addition
(details / githubweb ) #586 send connection failure message to parent if kafka producer stream fails
(details / githubweb ) #586 disable parallel publishing, use separate dispatcher for publishing
(details / githubweb ) [#1078] rewrite Azure IoT Hub example payload mapping to map the ditto protocol message to a direct method
(details / githubweb ) [#1078] fix use of jekylls %raw% in markdown
(details / githubweb ) adjusted "role" for all splitBrain resolver configs to be unset
(details / githubweb ) [#1078] add az-sasl to connection json in the documentation
(details / githubweb ) Adjust documentation for kafka sources
(details / githubweb ) #586 add dedicated kafka dispatcher also for unit tests
(details / githubweb ) configure "least-shard-allocation-strategy" algorithm in order to get better shard allocation / rebalancing
(details / githubweb ) downgrade Akka version to 2.6.13
(details / githubweb ) [#1078] align az-sasl hmac signing examples with the previous examples
(details / githubweb ) [#1060] test all paths of reserved headers in HttpPublisherActor
(details / githubweb ) #586 restart source if stream fails
(details / githubweb ) downgrade Akka Management version to 1.0.10
(details / githubweb ) #1081 Add priority to mappers
(details / githubweb ) #586 drop consumed messages in dry run mode, disable auto commit in dry run mode
(details / githubweb ) #586 make kafka producer restart backoff configurable
(details / githubweb ) #586 fix KafkaPublisherActorTest
(details / githubweb ) gracefully shutdown logback-classic logging in DittoService during coordinated shutdown
(details / githubweb ) add debug log to postStop method;
(details / githubweb ) Adds entity placeholder for http push target path
(details / githubweb ) #586 make kafka producer restart backoff configurable, move config for alpakka into separate config inside of consumer and producer, implemented config model for consumer and producer
(details / githubweb ) #586 wrap kafka send result in source and use flatmap to fail the source and restart it
(details / githubweb ) #586 recreate send producer and source queue when the producer stream is restarted
(details / githubweb ) #586 fix config file for tests
(details / githubweb ) #586 fix wrong parentheses in connectivity config
(details / githubweb ) to rule out runtime classnotfound errors, put janio back to "compile" scope
(details / githubweb ) #586 fix more wrong parentheses in connectivity config
(details / githubweb ) #1081: remove requirement of passing knowledge about "exists" function in PipelineFunctionFilter
(details / githubweb ) log shutdown reason;
(details / githubweb ) #1081: add optional parameters 'true' and 'false' to the 'exists' pipeline filter
(details / githubweb ) Revert "#1081 add conditioned thing templates list to implicit mapper"
(details / githubweb ) return completionStage from AkkaManagement.stop();
(details / githubweb ) [#1078] Documentation: Replace "message name" by "message subject" for consistency.
(details / githubweb ) [#1078] date hmac blogpost.
(details / githubweb ) #586 use RestartFlow instead of RestartSource to keep the source queue and restart only the publishing flow, fix handling queue offer result (also for amqp publisher)
(details / githubweb ) [#1078] Give testTLSConnectionWithoutCertificateCheck more time; remove actor system contamination between tests.
(details / githubweb ) stabilize coordinated shutdown hook in BaseClientActor for sending connection announcements:
(details / githubweb ) [#1081] minor fixes.
(details / githubweb ) [#1081] Make connection context available for message mappers.
(details / githubweb ) set allowed clock skew to 10 seconds to tolerate discrepancy when verifying local time against exp and nbf claims in JWT;
(details / githubweb ) [#1081] Replace ConnectivityConfigProvider by ConnectionContextProvider.
(details / githubweb ) Add setter for multiple subjects at once
(details / githubweb ) #586 add test to verify usage of entity:id placeholder in http push target
(details / githubweb ) #586 remove some debug statements
(details / githubweb ) added slidedeck for Ditto 2.0 release notes + roadmap
(details / githubweb ) [#1081] Make ConnectionContextProvider asynchronous.
(details / githubweb ) [#1081] Allow customization of expression resolver in ImplicitThingCreationMessageMapper.
(details / githubweb ) add new config key 'allowed-clock-skew' to oauth config;
(details / githubweb ) add unit test for setSubjects, add @since tag
(details / githubweb ) fix todo, remove unused import
(details / githubweb ) fix license header
(details / githubweb ) configure mongodb circuit breaker timeout higher
(details / githubweb ) made it possible to round policy announcements to milli seconds; min granularity is now 1ms;
(details / githubweb ) increase connectivity updating-state-timeout from default 5s to 15s
(details / githubweb ) added slidedeck for "Ditto in 20 minutes" in scope of upcoming WoT presentation
(details / githubweb ) document mapToDittoProtocolMsgWrapper and mapFromDittoProtocolMsgWrapper in connectivity-mapping.md;
(details / githubweb ) fix missing source and target parameter for ditto-rql-model;
(details / githubweb ) Allow to overcome some restrictions of the service by header: ditto-sudo=true
(details / githubweb ) Add tests for ditto-sudo header
(details / githubweb ) Add security protocol headers to kafka consumer properties
(details / githubweb ) add circuit breaker config to akka-contrib-mongodb-persistence-connection-journal in connectivity.conf;
(details / githubweb ) review of documenting javascript wrapper functions:
(details / githubweb ) Allow to configure the consumer group ID for a kafka connection
(details / githubweb ) Add documentation for the new specific config of a kafka connection
(details / githubweb ) added logging for publishing StreamingSession signals (WS/SSE)
(details / githubweb ) [#1081] Fix client actors not reacting to connectivity config updates.
(details / githubweb ) [#1081] update connection config in connection persistence actor.
(details / githubweb ) [#1081] make query parser asynchronous.
(details / githubweb ) [#1081]: add unit test for DittoConnectionContext
(details / githubweb ) [#1081] Add fail safe for connectivity config change registration.
(details / githubweb ) fixed DittoRuntimeException calculation from Throwable at various places
(details / githubweb ) [#1081] Make Ditto headers serializable & add them as an extra parameter for client actors.
(details / githubweb ) fix several issues with publishing messages to kafka
(details / githubweb ) temporary ignore failing unit tests
(details / githubweb ) fixed NPE in ThingPredicatePredicateVisitor when in fact "@Nullable" object to compare with was null
(details / githubweb ) add error message into GatewayInternalErrorException;
(details / githubweb ) Fix Kafka consumer and producer config
(details / githubweb ) fix KafkaPublisherActorTest
(details / githubweb ) remove test nonRetriableExceptionBecomesClientErrorAcknowledgement, it verified removed behavior
(details / githubweb ) FIX: kafka producer parallelism wasn't used
(details / githubweb ) [#1081]: add clarifying comment why deleteStrategy is get during runtime
(details / githubweb ) Try to avoid to wait for completion of each sending future before sending the next
(details / githubweb ) temporary ignore unit test
(details / githubweb ) fix unit test
(details / githubweb ) bump qpid-jms-client version to 1.0.0;
(details / githubweb ) [#1081] Remove blocking wait in JWT authentication.
(details / githubweb ) fixed that signal enrichment errors were not handled correctly as they were wrapped in
(details / githubweb ) removed max-bulk-size from UpdaterConfig;
(details / githubweb ) removed test for max-bulk-size from DefaultUpdaterConfigTest;
(details / githubweb ) add missing @since to isSudo method
(details / githubweb ) updated Eclipse jarsigner signing URL
(details / githubweb ) updated eclipse jarsigner version to latest 1.3.1
(details / githubweb ) add more check methods to ScopedConfig which check the values read from the config file and throws DittoConfigError when the value is not in the expected range;
(details / githubweb ) rename methods and fix result check;
(details / githubweb ) adapt snapshot-test.conf to fix DefaultSnapshotConfigTest;
(details / githubweb ) fix DefaultSnapshotConfigTest;
(details / githubweb ) allow EVENT_LOOP_THREADS to be 0;
(details / githubweb ) relaxed some checks for reading config values;
(details / githubweb ) add implicitStandanloneThingCreation mapper description
(details / githubweb ) update link to Eclipse Vorto
(details / githubweb ) [#1081] relax filter condition for mappers.
(details / githubweb ) fixed getting workers config in DefaultTunnelConfig (workers can be 0);
(details / githubweb ) [#1081]: add examples for the new exists filter for placeholders
(details / githubweb ) switch to getNonNegativeDurationOrThrow for writeInterval in DefaultStreamConfig;
(details / githubweb ) Add timer for adding a connection log entry
(details / githubweb ) [#1107] add requested-acks to subject announcements.
(details / githubweb ) threshold for Snapshot only have to be positive;
(details / githubweb ) fix evicting queue growing unbounded under high load
(details / githubweb ) change instantiation of DefaultPersistenceCleanupConfig when updating;
(details / githubweb ) fix consumed messages counted twice for kafka
(details / githubweb ) [#1081] fix copyright year
(details / githubweb ) Resolve connection id placeholder for group ID in specific config
(details / githubweb ) update Netty to 4.1.65.Final
(details / githubweb ) handle errors on stream completion in kafka consumer
(details / githubweb ) enable connection-checker for kafka consumer
(details / githubweb ) optimize imports
(details / githubweb ) #558 provide some basic Grafana dashboards as starting point in monitoring Eclipse Ditto
(details / githubweb ) fixed missing OSGi import of "org.atteo.classindex" in ditto-base-model
(details / githubweb ) [#1107] Add SubjectExpiryActor.
(details / githubweb ) fix connection-checker enablement
(details / githubweb ) review: made some configs "non 0"-able where reasonable
(details / githubweb ) configure max restarts for kafka publisher
(details / githubweb ) [#1107] Add PolicyAnnouncementManager.
(details / githubweb ) remove with consumer factory
(details / githubweb ) [#1107] rename SubjectAnnouncement field requestedAcks/beforeExpiry to requestedAcks/labels.
(details / githubweb ) Add two metrics in ditto publish and subscriber to make sure that the messages are los by akka remoting
(details / githubweb ) handle stream completion if consumer fails and escalate exception to client actor
(details / githubweb ) [#1107] Stabilize PolicyPersistenceActorTest.
(details / githubweb ) add new dependency commons-net to bom.xml;
(details / githubweb ) remove TagsConfig and all dependent implementations and configs because streamingCacheSize it is no longer used;
(details / githubweb ) renamed metric for actually sent messages in publisher
(details / githubweb ) add blocked-host-regex to connectivity.conf;
(details / githubweb ) fix NPE in HostValidatorTest;
(details / githubweb ) implement consumer offset reset within specific config of kafka connections
(details / githubweb ) [#1107] Start AcknowledgementForwarder for policy announcements.
(details / githubweb ) update SSHD version to 2.7.0
(details / githubweb ) undo updating sshd to 2.7.0 (breaking API changes in the version)
(details / githubweb ) Only fail validation if a value for consumer offset is configured
(details / githubweb ) use drainAndShutdown to gracefully shutdown the connection an minize loss of messages
(details / githubweb ) [#1107] Document qos-1 announcements.
(details / githubweb ) Introduce AskWithRetry "pattern" for async concierge cache loading
(details / githubweb ) [#1107] Add PolicyAnnouncementConfig.
(details / githubweb ) Added unit tests for AskWithRetry
(details / githubweb ) make unit test more stable
(details / githubweb ) make unit test more stable
(details / githubweb ) fixed non-0-able "limit" in DefaultThrottlingConfig
(details / githubweb ) moved AskException to ditto-base-model as the exception must be available everywhere (e.g. gateway/connectivity)
(details / githubweb ) Fix reconnect loop due to separate MQTT publisher client.
(details / githubweb ) Fix that QoS in target has no effect for MQTT.
(details / githubweb ) Fix ActorInitializationException in AmqpConsumerActor.
(details / githubweb ) MQTT: Do not suppress reconnection for redelivery.
(details / githubweb ) Test MQTT QoS from target.
(details / githubweb ) Fix spurious ConnectionNotAccessibleException during TestConnection; stabilize DefaultEvictingQueue.
(details / githubweb ) Fix logging in kafka message transformer
(details / githubweb ) bump netty-bom version to 4.1.66.Final;
(details / githubweb ) emit ConnectionDeleted event in ConnectionPersistenceActor;
(details / githubweb ) Make InboundMappingProcessorActor a streaming component
(details / githubweb ) [#1107] fixed review findings:
(details / githubweb ) [#1107] extracted constants in test
(details / githubweb ) Move mutable state handling into akkas hands
(details / githubweb ) removed empty enum from CachesConfig;
(details / githubweb ) fixed compile error in DefaultCachesConfig;
(details / githubweb ) fixed some broken links in docu;
(details / githubweb ) [#1107] review: enhanced documentation with:
(details / githubweb ) [#1107] fix documentation review findings
(details / githubweb ) extract kafka topic, key and timestamp from a received record and add them to the headers to make them available in payload and header mappings, implemented AbstractConsumerActorTest for Kafka, extracted source supplier from KafkaConsumerActor for better testability
(details / githubweb ) document special kafka headers
(details / githubweb ) Fix that configured persistence parallelism had no effect on search updater throughput.
(details / githubweb ) add since annotation to new methods in GenericTarget;
(details / githubweb ) increase added seconds to invalid nbf token to stabilize tests
(details / githubweb ) Model InboundDispatchingActor as Sink
(details / githubweb ) fixed HostValidationResult duplicated error message
(details / githubweb ) review: log IllegalArgumentException with stacktrace for subnet detection
(details / githubweb ) Allow to throttle the inbound stream after payload mapping
(details / githubweb ) increase added seconds to invalid nbf token to stabilize tests
(details / githubweb ) [#1107] Make exponential backoff of policy announcements configurable.
(details / githubweb ) update version of apache mina sshd to 2.7.0
(details / githubweb ) swtich to actions/setup-java@v2
(details / githubweb ) adjust logging of "Zombie" messages to DEBUG
(details / githubweb ) fix AbstractSSLContextTest for JDK >= 11.0.12
(details / githubweb ) add hint on expiry and announcement options
(details / githubweb ) build GH actions with "zulu" JDK
(details / githubweb ) Use MergeHub to inject messages into a sink that is materialized at
(details / githubweb ) fix license header issues
(details / githubweb ) Validate path of a live message in protocol adapter
(details / githubweb ) review: added/fixed javadoc
(details / githubweb ) fix conversion of ThingMerged events to a Thing
(details / githubweb ) fixed that cleanup shortcut added in AbstractPersistentActorWithTimersAndCleanup did not send a success
(details / githubweb ) Reuse success response handling
(details / githubweb ) Reduce unnecessary error logs.
(details / githubweb ) Log entire response on debug level.
(details / githubweb ) Log HTTP request for setting responseLocationUri.
(details / githubweb ) review: undid turning off JMS FailoverProvider logger
(details / githubweb ) Add new value "MISCONFIGURED" for ConnectivityStatus enum
(details / githubweb ) add missing since tag to new enum value
(details / githubweb ) Add javadoc to ConnectivityStatus#isFailure
(details / githubweb ) Show misconfigured live status if any client has misconfigured state
(details / githubweb ) adjusted RetrieveConnectionStatusAggregatorActor to also include sourceStatus, targetStatus and sshTunnelStatus in the combined calculated "liveStatus" of a connection
(details / githubweb ) with each "PingCommand", determine the live ConnectionStatus and log it to ERROR/WARN/INFO log depending on the overall live status
(details / githubweb ) Allow to define user indicated errors which can be resolved to a
(details / githubweb ) fix unit test
(details / githubweb ) speed up validation of message path
(details / githubweb ) Do not publish SubjectDeletedAnnouncement for updated subjects.
(details / githubweb ) #1135 implement basic tracing (using w3c trace context and kamon-opentelemetry), add dependency to kamon-opentelemetry, extend existing DittoMetrics timer to also create a trace, add rudimentary tracing (at least one trace per service) and read/propagate trace context at the edges (gateway/connectivity)
(details / githubweb ) #1135 document tracing configuration
(details / githubweb ) Add feature toggle for when-deleted subject announcements.
(details / githubweb ) fix bug in message path validation and add tests
(details / githubweb ) Resolve connectivity status from given exception for all client actors
(details / githubweb ) Remove TimeMeasuringFlow.
(details / githubweb ) added new MDC key "ditto-log-tag" used in Connection live status logs + switched misconfiguration to "warning" level
(details / githubweb ) #1135 make activiation of tracing configurable (generation of trace spans/context propagation)
(details / githubweb ) added "connection-id" MDC entry which got lost otherwise
(details / githubweb ) #1135 move tracing out of the metrics timer and provide a DittoTracing.wrapTimer instead
(details / githubweb ) review: made ImmutableConnectionFailurand ImmutableClientDisconnected package private, pulled static creators to interfaces
(details / githubweb ) review: added ConnectivityStatusResolver to BaseConsumerActor in order to resolve status in KafkaConsumer
(details / githubweb ) Switch to info level for misconfigured connectivity status
(details / githubweb ) Set connection status on every failure backoff based on the ConnectionFailure
(details / githubweb ) #1135 fix default channel in tracing config, add unit tests for context extraction/propagation
(details / githubweb ) handle 'canConnectViaSocket' for reconnect
(details / githubweb ) #1135 enclose tests for disabled tracing
(details / githubweb ) Treat kafka authenticaiton exceptions as user inidcated errors
(details / githubweb ) fixed duplicated throwable.getMessage() "statusDetails" error discription for JMS/AMQP1.0 errors
(details / githubweb ) added MQTT exceptions to "user-indicated-errors"
(details / githubweb ) added "connection-type" MDC for live-status log statements
(details / githubweb ) Allow to enhance the coded config list by specifying environment variables
(details / githubweb ) Fix hard-coded headers for HTTP protocol check.
(details / githubweb ) Configure exceptions for RabbitMQ that should be treated as user failure
(details / githubweb ) treat javax.net.ssl.SSLException as user failure
(details / githubweb ) review: added unit test in UserIndicatedErrorsTest testing the environment variable parsing of string objects
(details / githubweb ) additionally added configuration overwrites via system properties to make unit test run on Jenkins and via maven as well
(details / githubweb ) added timeout behavior to RetrieveConnectionStatusAggregatorActor:
(details / githubweb ) added timeouts multiple times if > 1 timeout was encountered; niceified code
(details / githubweb ) Categorize ssh tunnel exceptions
(details / githubweb ) tracing review:
(details / githubweb ) Add OpenAPI documentation about status 424 in messages routes.
(details / githubweb ) Add 424 responses to all requests that can request acknowledgements.
(details / githubweb ) update docker base image version to newest openj9 version;
(details / githubweb ) initial documentation of conditional updates;
(details / githubweb ) extend javadoc with ParserException;
(details / githubweb ) [#559] add conditionParam.yml and add reference in all thing resources;
(details / githubweb ) use ThreadSafeDittoLoggingAdapter in ThingsAggregatorActor;
(details / githubweb ) remove dependency to ditto-base-model in ditto-rql-model because it is not used;
(details / githubweb ) [#559] add condition header to DittoHeaderDefinition;
(details / githubweb ) [#559] fix ImmutableDittoHeadersTest;
(details / githubweb ) Test that subjects containing slashes cannot be deserialized as Adaptable.
(details / githubweb ) Fix parsing of slashes in topic or path of Ditto protocol messages.
(details / githubweb ) Handle topic path starting with "/".
(details / githubweb ) [#559] condition can be specified as query parameter and http header;
(details / githubweb ) [#559] extend unit test QueryParametersToHeadersMapTest;
(details / githubweb ) Reintroduce message path prefix validation for policy and thing message signals.
(details / githubweb ) Fix missing "extra" field in DittoProtocolAdapter#fromAdaptable.
(details / githubweb ) Add option to delete search entries immediately.
(details / githubweb ) Improve resilience of authentication chain.
(details / githubweb ) Do not log a stream completion exception as failed message consumption
(details / githubweb ) reflect consumer failure in connection status
(details / githubweb ) make fileNamePattern configurable via env variable;
(details / githubweb ) Add common certificate exceptions
(details / githubweb ) Add at least one cause for a failed source to the ConnectionFailedException
(details / githubweb ) Add missing mqtt exceptions
(details / githubweb ) Improve resilience of DittoRuntimeExceptionToErrorResponseFunction.
(details / githubweb ) Add log to analyze reasons of JMS errors
(details / githubweb ) Invalid destinations are a user failure
(details / githubweb ) [#559] implement conditional requests based on the condition in the ditto headers;
(details / githubweb ) Minor code changes during review
(details / githubweb ) [#559] fix broken test in ImmutableDittoHeadersTest;
(details / githubweb ) [#559] rework implementation of condition checking;
(details / githubweb ) [#559] add ThingConditionValidator;
(details / githubweb ) Fix enforcement timers not being stopped when filtered in pre-enforcer.
(details / githubweb ) Upgrade Akka libraries.
(details / githubweb ) Extend signal enrichment facade for search update; fix interpretation of delete events.
(details / githubweb ) Use CachingSignalEnrichmentFacade for search index update.
(details / githubweb ) Replace unnecessary SudoRetrieveThingResponse in EnforcementFlow; fix ThingUpdaterTest.
(details / githubweb ) use same version property for all kamon dependencies
(details / githubweb ) add OnStopHandler again as functional interface
(details / githubweb ) add tracing for enforcement (timer was removed from AbstractEnforcerActor on master)
(details / githubweb ) Enhance piggyback command responses with service and instance info.
(details / githubweb ) [#559] remove Condition class because no central validation of the specified condition is possible;
(details / githubweb ) [#559] introduce new FieldNamesPredicateVisitor to be able to extract the fieldNames from RQL expression;
(details / githubweb ) [#559] check read permission on all resource keys specified in the condition;
(details / githubweb ) fix "java.net.ConnectException" entry which contained the message in the exception name instead of the pattern
(details / githubweb ) Adjust documentation for piggyback command response format.
(details / githubweb ) update akka, scala, slf4j minor dependency versions
(details / githubweb ) added info logging for HTTP status code of http-push publishes
(details / githubweb ) improved failure logging, only log message on debug level
(details / githubweb ) pin used guava version to the one used in kamon-opentelemetry
(details / githubweb ) resolve deprecated API usage in HttpPublisherErrorTest
(details / githubweb ) Disable Java serialization.
(details / githubweb ) minor reformatting and improvements;
(details / githubweb ) [#559] add new exception ThingConditionInvalidException and unit test;
(details / githubweb ) Implement at-least-once message consumption for kafka
(details / githubweb ) [#559] add Ditto blog post for new conditional requests feature;
(details / githubweb ) Remove inheritance from Serializable interface.
(details / githubweb ) remove unused class
(details / githubweb ) add self reference to TaggedMetricInstrument
(details / githubweb ) add unit tests for tagging of PreparedTrace and StartedTrace
(details / githubweb ) extract adding tags from TaggedMetricInstrument interface, because some implementation might only be able to add tags not retrieve them. use TaggableMetricsInstrument for StartedTrace.
(details / githubweb ) add assertion to StartedKamonTraceTest and logback dependency for tests to suppress warnings
(details / githubweb ) remove debug logs in stream which were used during development
(details / githubweb ) Remove MessageSequentializer as it's not needed
(details / githubweb ) Configure parallelism in waiting for commit to max-in-flight
(details / githubweb ) explicitly add akka-http as dependency to connectivity-service
(details / githubweb ) review: harmonized AMQP 1.0 configuration for consumers/publisher with the Kafka one
(details / githubweb ) made DefaultConnectionConfig public again
(details / githubweb ) review:
(details / githubweb ) fixed unit test
(details / githubweb ) update caffeine dependency and fix compile errors
(details / githubweb ) Extract real cause out of potential CompletionException
(details / githubweb ) Cancel periodic priority update on delete connection
(details / githubweb ) Recover before MergeHub to avoid error log
(details / githubweb ) replace static scala version in dependency
(details / githubweb ) review findings:
(details / githubweb ) Add persistence methods to read SN from events and snapshots and delete them.
(details / githubweb ) add documentation for Kafka qos 0/1
(details / githubweb ) fixed that connection status of misconfigured connections was changed to "failed"
(details / githubweb ) fixed RetrieveConnectionStatusResponse "missingResources" addition to resources arrays
(details / githubweb ) fixed ConnectionPersistenceActorTest#recoverOpenConnection
(details / githubweb ) empty status arrays shall not be added to resulting Json document at all
(details / githubweb ) fixed RetrieveConnectionStatusResponseTest
(details / githubweb ) To avoid a timeout in RetrieveConnectionStatusAggregatorActor
(details / githubweb ) There is only one publisher actor for all targets
(details / githubweb ) Decrease akka-management.version back to 1.0.10 because of
(details / githubweb ) Add credit stream for background cleanup.
(details / githubweb ) Restructured AtLeastOnceConsumerStream
(details / githubweb ) Add PersistenceCleanUpActor.
(details / githubweb ) - set target resource status of dynamic targets (target address with placeholders) to UNKNOWN as we do not track those states
(details / githubweb ) Make KafkaConsumerStream @Immutable
(details / githubweb ) Await stopping of KafkaConsumerStream to a maximum of 10 seconds
(details / githubweb ) Instead of restarting the whole KafkaConsumerActor just restart the
(details / githubweb ) Rename and test CleanUpConfig; add PersistenceCleanUpActor.props
(details / githubweb ) Restart KafkaConsumerStream with exponential backoff
(details / githubweb ) backoff after a consumer was closed before recreating the message consumer to better reflect the actual state of the consumer in the source resourse status
(details / githubweb ) Count successful and failed acknowledgements in connection metrics
(details / githubweb ) add unit test for AmqpConsumerActor backoff and resource status update
(details / githubweb ) Avoid couting rejected messages as consume failures
(details / githubweb ) Fix and add unit tests
(details / githubweb ) Start PersistenceCleanUpActor in Things, Policies, Connectivity.
(details / githubweb ) Add counters for events and snapshots deleted in the background.
(details / githubweb ) Make deleted snapshots empty.
(details / githubweb ) Remove centralized background cleanup.
(details / githubweb ) Add live config retrieval and modification for background clean-up.
(details / githubweb ) add GH discussions as another feedback channel
(details / githubweb ) Reduce code duplication
(details / githubweb ) stabilize failure detection of connectivity live status
(details / githubweb ) fixed Ditto tracing precision bug regarding use of Instant.now(), use Kamon's clock instead
(details / githubweb ) round of HTTP parallelism to next factor of two
(details / githubweb ) use .map(DefaultHttpPushFactory::determineNextPowerOfTwo) in DefaultHttpPushFactory
(details / githubweb ) Make PoliciesRoute Path public
(details / githubweb ) Add SearchUpdateListener to MongoSearchUpdaterFlow
(details / githubweb ) Organized some imports and sorted Ditto modules alphabetically.
(details / githubweb ) Fixed config for things-search update listener implementation value.
(details / githubweb ) Fixed `SearchActorIT`.
(details / githubweb ) Use SearchUpdater in mapping stage instead of sink
(details / githubweb ) Issue #1093: Introduced `EntityIdInvalidException`.
(details / githubweb ) Issue #1093: Made `NamespacedEntityIdInvalidExcaption` a subclass of `EntityIdInvalidException`.
(details / githubweb ) Issue #1093: Small improvements.
(details / githubweb ) Increased some test time-outs which failed because of actorSystem init
(details / githubweb ) Add JsonParsable und fromJson to EntityIdForTestsInvalidException for error registry tests
(details / githubweb ) test UserIndicatedErrors matching with "cause" being the matching class
(details / githubweb ) Fix rebase
(details / githubweb ) PersistenceCleanUpActor: Enable setting last-pid in ModifyConfig
(details / githubweb ) fixed determination of cluster connectivity instances count
(details / githubweb ) review: renamed consumerRestartBackOffConfig to restartBackOffConfig
(details / githubweb ) Document new background cleanup DevOps API.
(details / githubweb ) Fix some code-smells
(details / githubweb ) Fix DefaultPersistenceStreamingActorTest.
(details / githubweb ) Log non successful status codes as failure for http publishes
(details / githubweb ) review: don't assume ConnectivityStatus.FAILED in AmqpPublisherActor when producer is closed
(details / githubweb ) fixed mocking in AmqpPublisherActorTest
(details / githubweb ) fix AmqpConsumerActorTest
(details / githubweb ) fix BaseClientActor backoff behavior: increase state timeout only for the first failure received during backoff
(details / githubweb ) enhance the message rejected log with information to identify the message that was rejected
(details / githubweb ) added more detailed resource "statusDetails" message for AMQP 1.0 producer closed
(details / githubweb ) also test the case when backoff is triggered from CONNECTED state
(details / githubweb ) Do not filter null record values
(details / githubweb ) Handle expired messages after transformation to ensure they are
(details / githubweb ) Document message expiration behavior for kafka
(details / githubweb ) fix spelling
(details / githubweb ) review: add "failureCount" to backoff/reconnecting logging
(details / githubweb ) remove 503 error response for messages from openapi docs
(details / githubweb ) review: rename CleanUp, add unit tests for CleanupResult and SnapshotRevision
(details / githubweb ) stabilize AmqpConsumerActorTest
(details / githubweb ) add JS mapper configuration to allow use of "unsafe" standard objects (useful when debugging)
(details / githubweb ) review: rename CleanUp
(details / githubweb ) Add visitors to compute the diff of BSON documents.
(details / githubweb ) Test incremental update via BsonDiff.
(details / githubweb ) Use BsonDocument as the document type for search index update.
(details / githubweb ) Introduce incremental update into search updater stream.
(details / githubweb ) Add 1% force update probability to ThingUpdater.
(details / githubweb ) Add counters for search background sync stream.
(details / githubweb ) Search updater: Add shortcut for identical JSON object diff.
(details / githubweb ) Fix incremental search update.
(details / githubweb ) Search update: improve array diff computation; optimize diff of internal arrays.
(details / githubweb ) Fix filter of UpdateOne write model; fix nonnegative hashcode computation.
(details / githubweb ) Fix code smells; remove unnecessary cleanup config in Concierge.
(details / githubweb ) Fix unit tests.
(details / githubweb ) [#1170]: Implement fn:replace
(details / githubweb ) Enrich deleted events with last state of twin if signal enrichment is
(details / githubweb ) respond with overall live connectionStatus "open" when subresources are in "unknown" state but all clients are "open"
(details / githubweb ) update to Netty 4.1.68.Final
(details / githubweb ) improve logs in order to find out why some amqp 1.0 connections still "fail"
(details / githubweb ) Ensure ConnectionLoggerRegistry and DefaultMuteableConnectionLogger do not throw exceptions
(details / githubweb ) update logback to 1.2.6
(details / githubweb ) Add missing periods
(details / githubweb ) Remove MongoDB dependencies from Concierge.
(details / githubweb ) Split implementation of CacheKey for SignalEnrichment and Enforcement
(details / githubweb ) Search updater: fix timer timeout and update error due to empty objects.
(details / githubweb ) Search updater: support nested {} as value.
(details / githubweb ) Fix double slashes in location header
(details / githubweb ) verify successful AmqpConsumerActor startup by checking their resource status after starting them
(details / githubweb ) review for deleted event enrichment:
(details / githubweb ) Fix IllegalArgumentException due to empty updates.
(details / githubweb ) fix NPE in unit test and verify resource status is correct after consumer actor failure
(details / githubweb ) A correlation ID shout not be part of the cache key
(details / githubweb ) Add correlation ID to headers if not present
(details / githubweb ) RetrieveThing and SudoRetrieveThing cannot be applied when thing is null
(details / githubweb ) allow overwriting the Contextual.askWithRetryConfig
(details / githubweb ) Use UnaryOperator instead of function
(details / githubweb ) review: adjusted config environment keys to include "AMQP10_" prefix
(details / githubweb ) UriForLocationHeaderSupplier: Test trailing slash.
(details / githubweb ) reset session data after failure in base client actor
(details / githubweb ) allow to use an URL as "definition" for Thing + Feature definitions in addition to the namespace:name:version
(details / githubweb ) Fix updater errors due to string values starting with '$'.
(details / githubweb ) increase Mockito.verify() timeout of MockSnapshotStorePlugin to 10s to stabilize CI
(details / githubweb ) Apply e2e backpressure by using requested acks
(details / githubweb ) Review commit:
(details / githubweb ) [#559] - review blog post
(details / githubweb ) [#559] - review openapi
(details / githubweb ) add "conditional updates" and move "signal enrichment" to "signal types" sub-folder
(details / githubweb ) review conditional updates
(details / githubweb ) [#559] Add more unit tests to new 'condition' validator
(details / githubweb ) [#559] Add unit tests for new field name visitor and little refactoring
(details / githubweb ) Issue #559: Renamed local variable to plural.
(details / githubweb ) Issue #559: Removed duplicate empty line and throw an AssertionError in constructor of this utility class.
(details / githubweb ) [#559] Make ditto headers mandatory for condition failed exception
(details / githubweb ) #559 extend QueryParametersToHeadersMapTest and test setting AllowPolicyLockout header via query parameters;
(details / githubweb ) #559 extend docu and blog post;
(details / githubweb ) remove http request directive from code snippet;
(details / githubweb ) #559 include docu review findings;
(details / githubweb ) #559 remove condition from message in ThingConditionFailedException;
(details / githubweb ) #559 add condition to protocol-envelope.json and protocol-specification.md;
(details / githubweb ) #559 extend ExistsFieldExpressionVisitor and FilterFieldExpressionVisitor to use metadata in conditions;
(details / githubweb ) #559 remove implementation for visitMetadata in GetExistsBsonVisitor and GetFilterBsonVisitor;
(details / githubweb ) #559 return bson filter that don't match for visitMetadata because searching for metadata isn't supported;
(details / githubweb ) #559 update date of blog post;
(details / githubweb ) remove unused imports;
(details / githubweb ) #559 update blog post;
(details / githubweb ) #559 use UTC timestamps in blog post example;
(details / githubweb ) Remove "deleteAt" from search queries to work around MongoDB issue SERVER-12869.
(details / githubweb ) Add documentation for backpressure of kafka consumers based on requested-acks
(details / githubweb ) added empty lines around code block
(details / githubweb ) added release notes for Ditto 2.1.0
(details / githubweb ) update Kafka client to 2.8.1
(details / githubweb ) enhanced Ditto 2.1.0 release notes to final state
(details / githubweb ) added Ditto 2.1.0 announcement blogpost
(details / githubweb ) ![[Jenkins]](/ditto/static/acd22e89/images/svgs/logo.svg){kind=logo}
