|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/MongoReconnectSnapshotAdapter.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/MongoThingSnapshotAdapter.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/package-info.java |
 | services/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/persistence/SafeRecovery.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/MongoConnectionSnapshotAdapter.java |
 | services/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorSnapshottingTest.java (diff) |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoSnapshotAdapterTest.java |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotterTest.java (diff) |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/things/TaggedThingJsonSnapshotAdapterTest.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/MongoThingEventAdapter.java |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicySupervisorActor.java (diff) |
 | services/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorTest.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapter.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionMongoSnapshotAdapter.java |
 | services/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/persistence/SnapshotAdapter.java |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapterTest.java |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/MongoPolicyEventAdapter.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoSnapshotAdapter.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff) |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActorSnapshottingTest.java (diff) |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/AbstractPoliciesService.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff) |
 | services/things/starter/src/main/resources/things.conf (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/SafeRecovery.java |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/policies/MongoPolicySnapshotAdapter.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/package-info.java |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/MongoThingEventAdapterTest.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/TaggedThingJsonSnapshotAdapter.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/ThingWithSnapshotTag.java |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoSnapshotAdapter.java |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoEventAdapter.java |
 | services/policies/persistence/src/test/resources/test.conf (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/SnapshotAdapter.java |
 | services/policies/starter/src/main/resources/policies.conf (diff) |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/package-info.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/package-info.java |
 | services/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/AbstractThingsService.java (diff) |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/things/ThingWithSnapshotTagTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/SnapshotTag.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/package-info.java |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingWithSnapshotTagTest.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotter.java (diff) |
 | services/things/persistence/src/test/resources/test.conf (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/package-info.java |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingWithSnapshotTag.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/AbstractMongoSnapshotAdapter.java |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff) |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesService.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/SnapshotterState.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/SnapshotTag.java |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
|
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotter.java (diff) |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff) |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesService.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/AbstractMongoSnapshotAdapter.java (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicySupervisorActor.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff) |
 | services/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotterTest.java (diff) |
|
 | services/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorTest.java (diff) |
 | services/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorSnapshottingTest.java (diff) |
|
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRepresentation.java |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff) |
 | services/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff) |
 | services/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/ClusterPersistenceHealth.java |
 | services/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff) |
|
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceClusterHealth.java |
 | services/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff) |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java (diff) |
 | services/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/ClusterPersistenceHealth.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff) |
 | services/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff) |
|
 | services/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff) |
|
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff) |
|
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff) |
|
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff) |
Commit
3e1ddbb1f9a33ca3051e3b1f453a2989c6b13d8b
by daniel.fesenmeyermove (Mongo-)IndexInitializer from thingsearch to ditto-services-utils-persistence for reuse in other modules - move definition of indices from typesafe-config code (by using the newly implemented IndexModelFactory) - also move Bson-utils and Bson-assertions from thingsearch to ditto-services-utils-persistence (cause they are both needed in thingsearch and extended ditto-services-utils-persistence) - add integration test IndexInitializerIT and several basic unit tests - add MongoIndexAssertions which can be used also from other modules (thingsearch) for assertions on the indices of a collection - make it possible to specify a custom port (instead of free random port) in MongoDbResource - adjust thingsearch to used the new (Mongo-)IndexInitializer from ditto-services-utils-persistence Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexFactoryTest.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/MongoQueryTest.java (diff) |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexOperationsTest.java |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/IndexInitializer.java |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/Indices.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexFactory.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/BsonAssert.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/BsonCollectionAssert.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/MongoIndexAssertions.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/BsonAssertions.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/IndexInitializationIT.java |
 | services/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchRootActor.java (diff) |
 | services/thingsearch/starter/src/main/resources/things-search.conf (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/package-info.java |
 | bom/pom.xml (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/PolicyRestrictedMongoSearchAggregation.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/InPredicateImplTest.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/ThingsSearchPersistence.java (diff) |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexTest.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/write/impl/PolicyUpdateFactoryTest.java (diff) |
 | services/thingsearch/persistence/pom.xml (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/FeatureIdPropertyExpressionBsonTest.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/FeaturePropertyExpressionBsonTest.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/AbstractThingSearchPersistenceITBase.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/LikePredicateImplTest.java (diff) |
 | services/utils/persistence/pom.xml (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializer.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/util/MongoSetKeyValidity.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/SimpleFieldExpressionBsonTest.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/FeatureExpressionBsonTest.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/DefaultIndexKey.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/BsonAssert.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/AbstractCriteriaTestBase.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexDirection.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/DefaultIndexKeyTest.java |
 | services/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/mongo/MongoDbResource.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexOperations.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/Index.java |
 | services/utils/persistence/src/test/resources/logback-test.xml |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/AttributeExpressionBsonTest.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/MongoThingsSearchPersistence.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/BsonUtil.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/BsonAssertions.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializerTest.java |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializerIT.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexKey.java |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/AbstractPredicateTest.java (diff) |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/BsonCollectionAssert.java |
|
 | services/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchRootActor.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/MongoThingsSearchPersistence.java (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/AbstractThingSearchPersistenceITBase.java (diff) |
 | services/thingsearch/common/src/main/java/org/eclipse/ditto/services/thingsearch/common/util/ConfigKeys.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/ThingsSearchPersistence.java (diff) |
Commit
3b741a74774438c8bb8b75315e77a6291e6d2149
by daniel.fesenmeyermethod BsonUtil#getDocumentValueAt is no longer needed, because its usage has been replaced with (MongoDB)Document#get(String, Class); introduce BsonUtil#getRequiredDocumentValueAt which throws an NPE if no value is found Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java (diff) |
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java (diff) |
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java (diff) |
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializer.java (diff) |
 | services/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializerIT.java (diff) |
|
 | services/thingsearch/persistence/src/test/resources/test.conf (diff) |
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/MongoHealthCheckIT.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/AbstractJavaScriptPayloadMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperFactory.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperBytesTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornSandboxPayloadMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMustacheTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornPayloadMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperBytesTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/MappingTemplate.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/ImmutableJavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutableMappingTemplate.java |
 | services/amqp-bridge/mapping/pom.xml |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicRhinoPayloadMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutablePayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperSimpleTest.java |
 | services/amqp-bridge/pom.xml (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMappers.java |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornSandboxPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicRhinoPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/AbstractJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperSimpleTest.java (diff) |
Commit
fb3931d22f8cc9d1d827814cfa1a624e4f47de49
by Thomas Jaeckleremoved nashorn implementation PoCs, focused on Rhino impl * included into CommandProcessorActor which triggers the JS mapping * made the CommandProcessorActor a scalable router which scales up/down as needed * still a lot of TODOs inside Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMappers.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicRhinoPayloadMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionData.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CloseConnection.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponseTest.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreatedTest.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnection.java (diff) |
 | bom/pom.xml (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/MappingTemplate.java |
 | services/amqp-bridge/messaging/src/test/resources/logback-test.xml |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornPayloadMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CloseConnectionResponse.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornSandboxPayloadMapper.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/AbstractJavaScriptPayloadMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MappingTemplate.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingScript.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatusesResponse.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingScript.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatuses.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/OpenConnection.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff) |
 | services/amqp-bridge/mapping/pom.xml (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperFactory.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatus.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutableMappingTemplate.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java |
 | services/amqp-bridge/messaging/pom.xml (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/OpenConnectionResponse.java (diff) |
 | model/base/src/main/java/org/eclipse/ditto/model/base/common/DittoConstants.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/ImmutableJavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperBytesTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutablePayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/messaging/src/test/resources/test.conf (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMustacheTest.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatusResponse.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/DeleteConnection.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java |
 | services/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMappingTemplate.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperBytesTest.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/DeleteConnectionResponse.java (diff) |
Commit
e37893600bc798b96e25895200f9e9986349b3d1
by daniel.fesenmeyerprovide the possibility to define combined health statuses - rename HealthStatus to StatusInfo because the health context is also given by the package name and the name HealthStatus was in conflict with the nested type called Status - define several factory methods for StatusInfo: fromStatus (replacement for the former "of"), fromDetails (gives the possibility to calculate the status based on the detail types ERROR, WARN or INFO) and composite (allows to create a combined, aggregated view of several StatusInfos) - enhance StatusInfoTest (former HealthStatusTest), add StatusDetailMessageTest Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff) |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthStatusTest.java |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/health/CachingHealthRoute.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/AbstractStatusHealthHelper.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusDetailMessage.java |
 | services/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceClusterHealth.java (diff) |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusInfoTest.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff) |
 | services/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff) |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusDetailMessageTest.java |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/StatusHealthHelper.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthStatus.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusInfo.java |
Commit
7df50bbb4d94d6ed31bae385d8c512888bc14adb
by daniel.fesenmeyersimplify the definition of already existing combined health statuses (which had to calculate combined health on their own) - replace usage of Health class with StatusInfo.combine(...) - remove no longer needed code (including Health class) Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff) |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff) |
 | services/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff) |
 | services/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceClusterHealth.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMappingTemplate.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MappingTemplate.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandConsumerActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JmsConnectionFactory.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockJmsConnectionFactory.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionType.java |
 | services/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ErrorHandlingActorTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/JmsConnectionFactory.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ConnectionTypeTest.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableConnectionTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/AmqpConnectionBasedJmsConnectionFactory.java |
 | services/amqp-bridge/starter/src/main/resources/amqp-bridge-dev.conf (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQConnectionActor.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/FaultyConnectionActor.java |
 | bom/pom.xml (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java |
 | services/amqp-bridge/messaging/pom.xml (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMappingTemplate.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MappingTemplate.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingScript.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingScript.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | services/amqp-bridge/mapping/pom.xml (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/package-info.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionData.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingScript.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/package-info.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingScript.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java |
|
 | documentation/src/main/resources/openapi/ditto-api-1.yml (diff) |
 | documentation/src/main/resources/openapi/ditto-api-2.yml (diff) |
|
 | signals/commands/live/pom.xml (diff) |
|
 | services/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
|
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponseTest.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionTest.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponseTest.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreatedTest.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
Commit
cb233c3451bebe9eb06d2077532d91b3c9e54c43
by daniel.fesenmeyerSimplify health status aggregation: - use the StatusInfo class instead of low-level Json manipulation where possible - instead of customizing the gateway-health by extending from an abstract class (AbstractStatusHealthHelper), provide a ConfigurableStatusAndHealthProvider class which allows configuration by means of a StatusSupplier (for http resource /status) and StatusHealthSupplier (for http resource /status/health) - provide a ditto default configuration by means of DittoStatusAndHealthProviderFactory - for re-use in custom gateways, provide class ClusterStatusSupplier - for re-use in custom gateways, provide classes ClusterStatusHealthSupplier and CompositeStatusHealthSupplier (for aggregating different health statuses) Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusAndHealthHelper.java |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusSupplier.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusInfo.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/health/CachingHealthRoute.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/CompositeStatusHealthSupplier.java |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusHealthSupplier.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplier.java |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/status/OverallStatusRoute.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ConfigurableStatusAndHealthProvider.java |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusHealthSupplier.java |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/AbstractStatusHealthHelper.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/StatusAndHealthProvider.java |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/DittoStatusHealthHelper.java |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/DittoStatusAndHealthProviderFactory.java |
 | services/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/status/OverallStatusRouteTest.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/CompletableFutureUtils.java |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusInfoTest.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/StatusHealthHelper.java |
Commit
58ede478be5cb7baf13c64441acc0cdf14ff70ff
by daniel.fesenmeyerImprove re-usability and configurability of health status aggregation: - introduce AbstractHealthCheckingActor which handles incoming health requests, manages the current health status and notifies the health requester(s) on status change - provide PersistenceHealthCheckingActor as reusable implementation to check MongoDB status - provide CompositeCachingHealthCheckingActor which delegates to other health-checking actors and caches a composite health status - provide DefaultHealthCheckingActorFactory which provides an appropriately configured CompositeCachingHealthCheckingActor for the ditto services Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff) |
 | services/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceHealthCheckingActor.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/CompositeCachingHealthCheckingActor.java |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/DefaultHealthCheckingActorFactory.java |
 | services/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/ThingsRootActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActorOptions.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusInfo.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff) |
 | services/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchRootActor.java (diff) |
 | services/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/AbstractHealthCheckingActor.java |
 | services/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusInfoTest.java (diff) |
 | services/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff) |
|
 | documentation/src/main/resources/pages/ditto/basic-feature.md (diff) |
Commit
8c5eb3c1aef410ea245349113dd3b51b9e6b00b6
by Thomas Jaeckleadded first draft of presentation to show in VirtualIoT meetup * included presentations in Ditto project site * also added NodeRED to sandbox for demo Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html |
 | docker/sandbox/docker-compose.yml (diff) |
 | documentation/src/main/resources/slides/bg-images/background-demo-small.jpg |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/eclipse landscape.png |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/asset-admin-shell.png |
 | docker/sandbox/nginx.conf (diff) |
 | docker/sandbox/nodered/settings.js |
 | documentation/src/main/resources/slides/bg-images/background-conclusion-small.jpg |
 | documentation/src/main/resources/slides/bg-images/background-twin-small.jpg |
 | documentation/src/main/resources/pages/ditto/presentations.md |
 | docker/sandbox/nodered/flows-ditto.json |
 | docker/sandbox/nodered/package.json |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-class-diagram-v1.png |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-in-action.png |
 | documentation/src/main/resources/slides/bg-images/background-framework-small.jpg |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/eclipse_iot_logo.png |
 | documentation/src/main/resources/slides/bg-images/background-outlook-small.jpg |
 | documentation/src/main/resources/slides/bg-images/background-cloud-small.jpg |
 | documentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff) |
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
 | docker/sandbox/docker-compose.yml (diff) |
 | docker/sandbox/nginx.conf (diff) |
 | docker/sandbox/html/index.html (diff) |
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-class-diagram-v1.png |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/meme-dino.jpg |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/eclipse landscape.png |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-orchestration-examples.png |
 | docker/sandbox/html/index.html (diff) |
|
 | model/things/src/main/java/org/eclipse/ditto/model/things/ImmutableFeatures.java (diff) |
|
 | model/things/src/main/java/org/eclipse/ditto/model/things/ImmutableFeatures.java (diff) |
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
 | documentation/src/main/resources/pages/ditto/release_notes_020M1.md |
 | documentation/src/main/resources/pages/ditto/release_notes_010M4.md |
 | documentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff) |
|
 | documentation/src/main/resources/pages/ditto/release_notes_020M1.md |
 | documentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff) |
 | documentation/src/main/resources/pages/ditto/release_notes_010M4.md |
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
|
 | documentation/src/main/resources/_posts/2018-02-07-milestone-announcement-020-M1.md |
|
 | documentation/src/main/resources/_posts/2018-02-07-milestone-announcement-020-M1.md |
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
|
 | documentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff) |
|
 | documentation/src/main/resources/_posts/2018-02-08-feature-definition.md (diff) |
|
 | documentation/src/main/resources/_posts/2018-02-08-feature-definition.md (diff) |
|
 | documentation/src/main/resources/pages/ditto/basic-feature.md (diff) |
|
 | documentation/src/main/resources/pages/ditto/basic-feature.md (diff) |
|
 | bom/pom.xml (diff) |
|
 | bom/pom.xml (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactoryTest.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactory.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java |
 | services/amqp-bridge/mapping/pom.xml (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoopMapper.java |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactoryTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java (diff) |
|
 | services/gateway/starter/pom.xml (diff) |
 | services/pom.xml (diff) |
 | services/amqp-bridge/starter/pom.xml (diff) |
 | docker/sandbox/docker-compose.yml (diff) |
 | services/policies/starter/pom.xml (diff) |
 | docker/docker-compose.yml (diff) |
 | services/things/starter/pom.xml (diff) |
 | services/thingsearch/starter/pom.xml (diff) |
|
 | services/pom.xml (diff) |
|
 | services/thingsearch/starter/pom.xml (diff) |
 | services/gateway/starter/pom.xml (diff) |
 | services/amqp-bridge/starter/pom.xml (diff) |
 | services/things/starter/pom.xml (diff) |
 | services/policies/starter/pom.xml (diff) |
|
 | services/amqp-bridge/starter/pom.xml (diff) |
 | services/things/starter/pom.xml (diff) |
 | services/thingsearch/starter/pom.xml (diff) |
 | services/gateway/starter/pom.xml (diff) |
 | services/policies/starter/pom.xml (diff) |
|
 | services/pom.xml (diff) |
Commit
e79c6202e1f9fc8f4b003eda233033b8d86285da
by Yufei Caifix snapshotting of policy during activity check -- - Correct name of 'isSnapshotSavedForDeletedPolicy' - Do not call 'isPolicyDeleted()' in closure because it depends on a mutable variable 'policy' - Always make snapshot for deleted policies Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
|
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ConnectionTypeTest.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff) |
 | services/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/FaultyConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff) |
 | bom/pom.xml (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionType.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionFailedException.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableConnectionTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActorTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionFailedExceptionTest.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ErrorHandlingActorTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappingException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoopMapper.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java (diff) |
|
 | docker/sandbox/docker-compose.yml (diff) |
 | services/things/starter/pom.xml (diff) |
 | services/thingsearch/starter/pom.xml (diff) |
 | services/policies/starter/pom.xml (diff) |
 | services/gateway/starter/pom.xml (diff) |
 | docker/docker-compose.yml (diff) |
 | services/amqp-bridge/starter/pom.xml (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappingException.java (diff) |
|
 | services/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQConnectionActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActorTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapperTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractPayloadMapperTest.java |
|
 | services/thingsearch/starter/src/main/resources/things-search.conf (diff) |
 | services/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff) |
 | services/base/src/main/java/org/eclipse/ditto/services/base/DittoService.java (diff) |
 | services/policies/persistence/src/test/resources/test.conf (diff) |
 | services/gateway/endpoints/src/test/resources/test.conf (diff) |
 | services/thingsearch/persistence/src/test/resources/test.conf (diff) |
 | services/utils/distributed-cache/actors/src/main/resources/reference.conf (diff) |
 | services/thingsearch/updater-actors/src/test/resources/test.conf (diff) |
 | services/gateway/proxy/src/test/resources/test.conf (diff) |
 | services/policies/starter/src/main/resources/policies.conf (diff) |
 | services/gateway/starter/src/main/resources/gateway.conf (diff) |
 | services/things/starter/src/main/resources/things.conf (diff) |
 | services/amqp-bridge/messaging/src/test/resources/test.conf (diff) |
 | services/things/persistence/src/test/resources/test.conf (diff) |
|
 | services/policies/starter/src/main/resources/policies.conf (diff) |
 | services/things/starter/src/main/resources/things.conf (diff) |
 | services/thingsearch/updater-actors/src/test/resources/test.conf (diff) |
 | services/thingsearch/persistence/src/test/resources/test.conf (diff) |
 | services/gateway/proxy/src/test/resources/test.conf (diff) |
 | services/things/persistence/src/test/resources/test.conf (diff) |
 | services/gateway/starter/src/main/resources/gateway.conf (diff) |
 | services/policies/persistence/src/test/resources/test.conf (diff) |
 | services/utils/distributed-cache/actors/src/main/resources/reference.conf (diff) |
 | services/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff) |
 | services/gateway/endpoints/src/test/resources/test.conf (diff) |
 | services/thingsearch/starter/src/main/resources/things-search.conf (diff) |
 | services/amqp-bridge/messaging/src/test/resources/test.conf (diff) |
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/streaming/MongoSearchSyncPersistence.java (diff) |
|
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/streaming/MongoSearchSyncPersistence.java (diff) |
|
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeaturePropertiesModifiedTest.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclModifiedTest.java (diff) |
 | signals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/AbstractPolicyEvent.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryModifiedTest.java (diff) |
 | signals/events/policies/src/test/java/org/eclipse/ditto/signals/events/policies/PolicyEntriesModifiedTest.java (diff) |
 | signals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/AbstractThingEvent.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryCreatedTest.java (diff) |
 | signals/events/batch/src/main/java/org/eclipse/ditto/signals/events/batch/AbstractBatchEvent.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/AbstractAmqpBridgeEvent.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryDeletedTest.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeatureDefinitionModifiedTest.java (diff) |
|
 | signals/events/policies/src/test/java/org/eclipse/ditto/signals/events/policies/PolicyEntriesModifiedTest.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeatureDefinitionModifiedTest.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeaturePropertiesModifiedTest.java (diff) |
 | signals/events/batch/src/main/java/org/eclipse/ditto/signals/events/batch/AbstractBatchEvent.java (diff) |
 | signals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/AbstractPolicyEvent.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryDeletedTest.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryCreatedTest.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/AbstractAmqpBridgeEvent.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryModifiedTest.java (diff) |
 | signals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclModifiedTest.java (diff) |
 | signals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/AbstractThingEvent.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java |
 | services/amqp-bridge/mapping/pom.xml (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
|
 | services/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/streaming/AbstractStreamingActor.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ConverterTraceWrapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactoryTest.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoOpMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapperTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactory.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoopMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/pom.xml (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappingException.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractPayloadMapperTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java |
|
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/CreatePolicy.java (diff) |
 | services/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThings.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureProperties.java (diff) |
 | services/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/TakeSnapshot.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/query/ThingQueryCommand.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandImpl.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/DeleteConnection.java (diff) |
 | signals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/query/ThingSearchQueryCommand.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAclEntry.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeature.java (diff) |
 | signals/commands/batch/src/main/java/org/eclipse/ditto/signals/commands/batch/ExecuteBatch.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/query/AbstractQueryLiveCommand.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatures.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandImpl.java (diff) |
 | signals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/AbstractMessageCommand.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatus.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandImpl.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CloseConnection.java (diff) |
 | services/models/policies/src/main/java/org/eclipse/ditto/services/models/policies/commands/sudo/SudoRetrievePolicy.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandImpl.java (diff) |
 | signals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/RetrieveStatistics.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeletePolicy.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeletePolicyEntry.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperties.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandImpl.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyPolicyEntry.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifySubjects.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteSubject.java (diff) |
 | services/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThing.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/query/PolicyQueryCommand.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatuses.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyPolicyId.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteThing.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureDefinition.java (diff) |
 | services/models/thingsearch/src/main/java/org/eclipse/ditto/services/models/thingsearch/commands/sudo/SudoRetrieveNamespaceReport.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifySubject.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAcl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureProperty.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyResources.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAttribute.java (diff) |
 | protocol-adapter/src/test/java/org/eclipse/ditto/protocoladapter/ThingModifyCommandAdapterTest.java (diff) |
 | signals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/Command.java (diff) |
 | signals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/ChangeLogLevel.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeature.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAclEntry.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyPolicy.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAttributes.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnection.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyResource.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/CreateThing.java (diff) |
 | services/models/thingsearch/src/main/java/org/eclipse/ditto/services/models/thingsearch/commands/sudo/SudoCountThings.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperty.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureDefinition.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatures.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyThing.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttributes.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandImpl.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteResource.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandImpl.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyPolicyEntries.java (diff) |
 | services/models/streaming/src/main/java/org/eclipse/ditto/services/models/streaming/SudoStreamModifiedEntities.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/OpenConnection.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttribute.java (diff) |
 | signals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/RetrieveLoggerConfig.java (diff) |
 | signals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/ExecutePiggybackCommand.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/FaultyConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ErrorHandlingActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java |
 | services/amqp-bridge/messaging/src/test/resources/test.conf (diff) |
 | services/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/amqp-bridge/util/src/main/java/org/eclipse/ditto/services/amqpbridge/util/ConfigKeys.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableConnectionTest.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff) |
 | services/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff) |
 | services/models/amqp-bridge/src/main/java/org/eclipse/ditto/services/models/amqpbridge/AmqpBridgeMessagingConstants.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnectionBuilder.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionBuilder.java |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoOpMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
|
 | model/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNode.java (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/CreateThingHandlerActor.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/ThingErrorResponse.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff) |
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusAndHealthHelper.java (diff) |
 | model/things/src/main/java/org/eclipse/ditto/model/things/NullFeatures.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/AbstractProtocolAdapter.java (diff) |
 | model/base/src/main/java/org/eclipse/ditto/model/base/common/HttpStatusCode.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/ThingsRoute.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/HttpRequestActor.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/query/RetrieveThingsResponse.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNodeTest.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureDefinition.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/PolicyRestrictedMongoSearchAggregation.java (diff) |
 | services/policies/util/src/main/java/org/eclipse/ditto/services/policies/util/ConfigKeys.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/utils/UriEncoding.java (diff) |
 | signals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/ThingEventRegistry.java (diff) |
 | signals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/PolicyCreated.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPath.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff) |
 | model/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNode.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ThingModifyCommandResponseAdapter.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseThingsRoute.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff) |
 | services/thingsearch/query/src/main/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitor.java (diff) |
 | services/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff) |
 | services/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff) |
 | bom/pom.xml (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/rql/RqlPredicateParserTest.java (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/EnforcerLookupActor.java (diff) |
 | model/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNode.java (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractPolicyEnforcerActor.java (diff) |
 | json/src/main/java/org/eclipse/ditto/json/JsonCollectors.java (diff) |
 | services/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/starter/service/util/ConfigKeys.java (diff) |
 | services/models/things/src/test/java/org/eclipse/ditto/services/models/things/CommandAndEventJsonExamplesProducer.java (diff) |
 | services/models/things/src/test/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponseTest.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapter.java (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/ModifyThingHandlerActor.java (diff) |
 | services/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponse.java (diff) |
 | services/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff) |
 | model/things/src/main/java/org/eclipse/ditto/model/things/NullFeatureDefinition.java (diff) |
 | model/messages/src/main/java/org/eclipse/ditto/model/messages/MessageFormatInvalidException.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNodeTest.java (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoEventAdapter.java (diff) |
 | services/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff) |
 | model/thingsearch-parser/src/main/scala/org/eclipse/ditto/model/thingsearchparser/parser/RqlPredicateParser.scala (diff) |
 | services/thingsearch/query/src/test/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitorTest.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/Index.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPathBuilder.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingSupervisorActor.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNodeTest.java (diff) |
|
 | services/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusAndHealthHelper.java (diff) |
 | model/things/src/main/java/org/eclipse/ditto/model/things/NullFeatures.java (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/EnforcerLookupActor.java (diff) |
 | services/models/things/src/test/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponseTest.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/utils/UriEncoding.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingSupervisorActor.java (diff) |
 | model/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNode.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/Index.java (diff) |
 | model/thingsearch-parser/src/main/scala/org/eclipse/ditto/model/thingsearchparser/parser/RqlPredicateParser.scala (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/CreateThingHandlerActor.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNodeTest.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/ThingErrorResponse.java (diff) |
 | signals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff) |
 | services/models/things/src/test/java/org/eclipse/ditto/services/models/things/CommandAndEventJsonExamplesProducer.java (diff) |
 | model/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNode.java (diff) |
 | services/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/PolicyRestrictedMongoSearchAggregation.java (diff) |
 | services/thingsearch/query/src/test/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitorTest.java (diff) |
 | signals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/PolicyCreated.java (diff) |
 | signals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/ThingEventRegistry.java (diff) |
 | model/things/src/main/java/org/eclipse/ditto/model/things/NullFeatureDefinition.java (diff) |
 | services/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPathBuilder.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/rql/RqlPredicateParserTest.java (diff) |
 | services/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ThingModifyCommandResponseAdapter.java (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoEventAdapter.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapter.java (diff) |
 | model/base/src/main/java/org/eclipse/ditto/model/base/common/HttpStatusCode.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNodeTest.java (diff) |
 | bom/pom.xml (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractPolicyEnforcerActor.java (diff) |
 | services/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff) |
 | model/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNode.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/HttpRequestActor.java (diff) |
 | model/messages/src/main/java/org/eclipse/ditto/model/messages/MessageFormatInvalidException.java (diff) |
 | services/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/starter/service/util/ConfigKeys.java (diff) |
 | services/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponse.java (diff) |
 | services/thingsearch/query/src/main/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitor.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseThingsRoute.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/query/RetrieveThingsResponse.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPath.java (diff) |
 | protocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/AbstractProtocolAdapter.java (diff) |
 | model/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNodeTest.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff) |
 | services/policies/util/src/main/java/org/eclipse/ditto/services/policies/util/ConfigKeys.java (diff) |
 | json/src/main/java/org/eclipse/ditto/json/JsonCollectors.java (diff) |
 | services/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff) |
 | services/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/ModifyThingHandlerActor.java (diff) |
 | services/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/ThingsRoute.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureDefinition.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff) |
|
 | services/policies/starter/src/main/resources/policies.conf (diff) |
 | services/things/starter/src/main/resources/things.conf (diff) |
 | services/policies/util/src/main/java/org/eclipse/ditto/services/policies/util/ConfigKeys.java (diff) |
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff) |
 | services/policies/persistence/src/test/resources/test.conf (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java |
|
 | services/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/package-info.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/package-info.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionBuilder.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnectionBuilder.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/package-info.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/resources/logback-test.xml (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ConverterTraceWrapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff) |
|
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff) |
|
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionData.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff) |
 | services/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionUriInvalidException.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperOptions.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java (diff) |
|
 | bom/pom.xml (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MutableExternalMessageBuilder.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableExternalMessage.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableExternalMessageTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessageBuilder.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/package-info.java (diff) |
 | bom/pom.xml (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff) |
 | services/amqp-bridge/messaging/pom.xml (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JmsConnectionFactory.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperConfiguration.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMessageMapperMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperMapperOptions.java |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperMapperOptions.java (diff) |
|
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfigurationProperties.java |
 | docker/sandbox/nginx.conf (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperConfiguration.java (diff) |
 | docker/nginx.conf (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperMapperOptions.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfiguration.java |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMessageMapperMapperOptions.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MutableExternalMessageBuilder.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperConfiguration.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperMapperOptions.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
|
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff) |
 | services/thingsearch/starter/src/main/resources/things-search.conf (diff) |
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/SearchUpdaterRootActor.java (diff) |
 | services/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff) |
 | services/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingsUpdaterTest.java (diff) |
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingsUpdater.java (diff) |
 | services/thingsearch/common/src/main/java/org/eclipse/ditto/services/thingsearch/common/util/ConfigKeys.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/IllegalConfigurationException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/NotYetConfiguredException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
|
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff) |
 | signals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/NotYetConfiguredException.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperException.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/IllegalConfigurationException.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
|
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
|
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeature.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttributes.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperty.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandImpl.java (diff) |
 | signals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/AbstractMessageCommand.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandImpl.java (diff) |
 | signals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/Command.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttribute.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperties.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatures.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureDefinition.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/base/AbstractLiveCommand.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandImpl.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteResource.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandImpl.java (diff) |
 | signals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAclEntry.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/query/AbstractQueryLiveCommand.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteSubject.java (diff) |
 | signals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeletePolicyEntry.java (diff) |
|
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperBytesTest.java |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperMustacheTest.java |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperBytesTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfigurationProperties.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperFactory.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java |
|
 | services/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/write/impl/MongoThingsSearchUpdaterPersistenceIT.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/mapping/pom.xml (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionUriInvalidException.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMappingFailedException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/AmqpBridgeErrorRegistry.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
Commit
17ada64495c27c2c2cc6891692db950165dd7019
by daniel.fesenmeyerminor improvement in things-persistence (same behaviour as in policies-persistence): don' unnecessarily schedule a snapshot when entity is in state "deleted" Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
|
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActorInterface.java (diff) |
 | services/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
|
 | services/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff) |
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/SearchUpdaterRootActor.java (diff) |
 | services/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfiguration.java (diff) |
 | signals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/IllegalConfigurationException.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperBytesTest.java (diff) |
 | signals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperBytesTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMapperConfigurationInvalidException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperSimpleTest.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/AmqpBridgeErrorRegistry.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperMustacheTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMappingFailedException.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/NotYetConfiguredException.java |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff) |
|
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandImpl.java (diff) |
 | signals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/Command.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/query/AbstractQueryLiveCommand.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/base/AbstractLiveCommand.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandImpl.java (diff) |
 | signals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/AbstractMessageCommand.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandImpl.java (diff) |
 | signals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandImpl.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
Commit
07d2043da497b773986d5378c9745331c7b83d94
by Thomas Jaecklemade ExternalMessage.getMessageType optional as this only applies for outgoing messages where we know the type * added getContentType() to DittoHeaders as it's already in the definition Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableExternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MutableExternalMessageBuilder.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff) |
 | model/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaders.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff) |
 | model/messages/src/main/java/org/eclipse/ditto/model/messages/ImmutableMessageHeaders.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | model/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeaders.java (diff) |
|
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActorTest.java |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperSimpleTest.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperBytesTest.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMappingFailedException.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff) |
 | model/base/src/main/java/org/eclipse/ditto/model/base/common/DittoConstants.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff) |
|
 | model/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
 | model/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff) |
|
 | bom/pom.xml (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff) |
|
 | services/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff) |
 | services/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff) |
|
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionUnavailableException.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionConflictException.java |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionNotAccessibleException.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionFailedException.java (diff) |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/package-info.java |
 | signals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/AmqpBridgeErrorRegistry.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff) |
|
 | bom/pom.xml (diff) |
|
 | services/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff) |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/AbstractBasicDBMapper.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BasicDBListToJsonObjectMapper.java |
 | services/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BasicDBObjectToJsonObjectMapper.java (diff) |
 | si |