[Jenkins]Jenkins

FailedChanges

Summary

  1. unified snapshot adapters, implemented hook for successful snapshots (details)
  2. fixed compile error in ConnectionActor (details)
  3. move snapshotSuccessFunctions into AbstractMongoSnapshotAdapter (details)
  4. fix test-compile errors (details)
  5. Rename Health-related classes to prepare for simplification (details)
  6. Make Health messages generic and extensible in health components (details)
  7. Fix MappingStrategiesBuilderTest (details)
  8. Document Health (details)
  9. Add method to retrieve specific component health statuses. (details)
  10. fix Health serialization (details)
  11. move (Mongo-)IndexInitializer from thingsearch to (details)
  12. make index-initialization optional for thingsearch (as it was possible (details)
  13. method BsonUtil#getDocumentValueAt is no longer needed, because its (details)
  14. add method BsonUtil#getDocumentWithDefaultAt which circumvents problems (details)
  15. simplify signature of BsonUtil#getDocumentWithDefaultAt (details)
  16. add test that checks that index-initialization does not fail when no (details)
  17. minor test-config improvements in thingsearch-persistence: - load config (details)
  18. PoC of mapping payload via JavaScript engines (details)
  19. added possibility to map raw payloads (details)
  20. removed nashorn implementation PoCs, focused on Rhino impl (details)
  21. provide the possibility to define combined health statuses - rename (details)
  22. simplify the definition of already existing combined health statuses (details)
  23. made mapping template string optional (details)
  24. initial step integrating rabbitmq brigde into amqp bridge (details)
  25. remove duplicate file (details)
  26. simplified! mapping and made CommandProcessorActor dynamically load a (details)
  27. renamed MappingScript interface to MappingContext (details)
  28. adapt response code for fire and forget messages (details)
  29. Update pom.xml (details)
  30. fix duplicate creation of command processor (details)
  31. Fixed amqp bridge unit tests (details)
  32. Fixed amqp bridge unit tests (details)
  33. Simplify health status aggregation: - use the StatusInfo class instead (details)
  34. Improve re-usability and configurability of health status aggregation: - (details)
  35. fixed typo (details)
  36. added first draft of presentation to show in VirtualIoT meetup (details)
  37. reduced sandbox deployment (details)
  38. rewrite ditto section with code samples (details)
  39. further polishing of virtualIoT meetup slides (details)
  40. fixed changed behavior in ImmutableFeatures.toJson (details)
  41. fixed missing import (details)
  42. adjusted release notes for 0.2.0-M1, made slides "fragments" (details)
  43. adjusted release notes for 0.2.0-M1, made slides "fragments" (details)
  44. wrote 0.2.0-M1 blogpost announcement (details)
  45. wrote 0.2.0-M1 blogpost announcement (details)
  46. fixed typo (details)
  47. fixed typo (details)
  48. fixed example json (details)
  49. fixed example json (details)
  50. fixed example json in doc (details)
  51. fixed example json in doc (details)
  52. updated binary-compatibility-check.version (details)
  53. updated binary-compatibility-check.version (details)
  54. New PayloadMapper factory and tests (details)
  55. Adopted local mappers for testing (details)
  56. Mappers licence header (details)
  57. switched to OpenJ9-openjdk9 alpine base image for Ditto + Things (details)
  58. try using openjdk8-openj9 instead of jdk9 (details)
  59. removed weird argument (details)
  60. added "-Xtune:virtualized" openj9 param (details)
  61. adjusted openj9 baseimage to fixed version; introduced "cpus" limit in (details)
  62. fix snapshotting of policy during activity check (details)
  63. Changed internal message, added documentation (details)
  64. change to actor based hierarchy because of issues with JMS client (details)
  65. New default ditto protocol mapper (details)
  66. javadoc, logging, small improvements (details)
  67. adjusted ditto startup settings (details)
  68. Implemented mapping in CommandProcessorActor (details)
  69. rename connectionActor to clientActor to avoid confusion (details)
  70. New protocol mapper tests (details)
  71. adjusted dispatcher configuration and default-dispatcher to be more (details)
  72. adjusted dispatcher configuration (details)
  73. minor logging fix: parameter "collectionName" was missing in debug (details)
  74. minor logging fix: parameter "collectionName" was missing in debug (details)
  75. deprecate Event.JsonFields.ID, serialize Event.JsonFields.TYPE (details)
  76. deprecate Event.JsonFields.ID, serialize Event.JsonFields.TYPE (details)
  77. Internal message knows its type, mapper changed to guava converter api (details)
  78. copyright (details)
  79. add sensible defaults for burst size and batching to (details)
  80. Adapted tests to changed mapper api; added docs and comments (details)
  81. add Command.Category to classify all commands (details)
  82. add router to distribute client actor to cluster nodes (details)
  83. Improved message mapper api and added tests (details)
  84. Adapted tests to message mapper changes (details)
  85. Added access functions to find reverse mapper; Added convenience (details)
  86. Better default mapper configuration (details)
  87. Moved logic from command processing actor to message mapper factory, (details)
  88. fix several sonar issues and delete unused code (details)
  89. fix several sonar issues and delete unused code (details)
  90. made RhinoJavaScriptPayloadMapper safer in sense of sandboxing (details)
  91. unify activity check for Things and Policies (details)
  92. Moved processing logic from CommandProcessorActor to CommandProcessor (details)
  93. schedule next activity check for persistence actor of deleted policy (details)
  94. make sources and target optional, add reply target to configuration, (details)
  95. fix compile errors, add license header (details)
  96. fix logback warning (details)
  97. Code sanitation (details)
  98. move creation of consumers to JMSConnectionHandlingActor for better (details)
  99. Ignored tests for deprecated mapper classes (details)
  100. fix test (details)
  101. fix test (details)
  102. Fixed tests (details)
  103. Ignored tests (details)
  104. Fixed javadoc (details)
  105. fix adding auth subject header to InternalMessage (details)
  106. respond to command after actor behaviour was changed (race condition) (details)
  107. Added merge logic for headers (details)
  108. add messageType to InternalMessage, handle InternalMessage based on (details)
  109. fix test (details)
  110. fix javadoc (details)
  111. Added convenience function for property access (details)
  112. add MESSAGE and ERROR type to InternalMessage (details)
  113. added some TODOs which occurred during review (details)
  114. updated used dependencies (akka, mongo-persistence) (details)
  115. renamed InternalMessage to ExternalMessage, splitted up in interface + (details)
  116. review: added some javadoc; removed @Nullable where it was not nullable; (details)
  117. Changed mapper configuration implementation (details)
  118. Changed default registry implementation and extracted interface (details)
  119. Generated equals and toString (details)
  120. Changed mapper api (details)
  121. Adapted external message (details)
  122. Migrated javascript mappers to new api (details)
  123. Include bulk update size in metrics (details)
  124. changed JS mapper config to follow new naming and interfaces (details)
  125. Removed old classes (details)
  126. Adapted new interface (details)
  127. got JS mapper working again (details)
  128. added missing copyright headers (details)
  129. Limit size of bulk updates in ThingUpdater (details)
  130. Added exceptions to interface (details)
  131. made "mappingContexts" in JSON optional in order to keep backward (details)
  132. Added javadoc for factory interface & serial for exceptions (details)
  133. Added javadoc and sanitation (details)
  134. Adapted to factory interface (details)
  135. Move bulk update size metric from metadata to histogram (details)
  136. Adapted mapper api changes (details)
  137. added new command category 'LIVE' for messages and live commands. (details)
  138. scheduling a maintenanceSnapshot regularly (snapshot interval) (details)
  139. Added factory method for configuration (details)
  140. cleaned up JS mapper (details)
  141. fixed compile errors (details)
  142. Temporary ignoring tests (details)
  143. Adapted factory tests to new API (details)
  144. Added test for content type check wrapper mapper (details)
  145. Adapted new mapper API in tests (details)
  146. improved error handling of message mapping (still not finished) (details)
  147. Fixed bug: mapping of messages without content type (details)
  148. add test for receiving commands/sending events (details)
  149. minor improvement in things-persistence (same behaviour as in (details)
  150. Adapted exception handling in tests (details)
  151. add unit test which checks that sync is triggered when maxBulkSize is (details)
  152. further improved exception handling for mapping (details)
  153. delete 'Live' Category from command because it is not needed anymore. (details)
  154. move replyTo header to ExternalMessage (details)
  155. made ExternalMessage.getMessageType optional as this only applies for (details)
  156. fixed tests (details)
  157. fix AmqpPublisherActor (details)
  158. mapped AMQP content-type which was missing (details)
  159. fixed CommandConsumerActorTest (details)
  160. stabilize AmqpClientActorTest (details)
  161. moved helper methods to MessageMappers (details)
  162. cleaned up the constants mess (details)
  163. fixed MappingContext creation from JSON (details)
  164. use akka dispatcher to process incoming jms messages (details)
  165. fixed error in exception (details)
  166. enhanced mapped messages with headers in (details)
  167. fix amqp uri when failover disabled (details)
  168. update to Akka 2.5.11 which fixes rolling update issue (details)
  169. fixed tests (details)
  170. added ConnectionConflictException for when trying to create an already (details)
  171. fixed closing and re-opening RMQ connections (details)
  172. fix generation of amqp uri once more (details)
  173. fix generation of amqp uri without failover (details)
  174. remove debugging code (details)
  175. downgrade to qpid jms 0.26 (details)
  176. fixed Snapshot serialization for ReconnectionActor (details)
  177. Include bulk update size in metrics (details)
  178. Limit size of bulk updates in ThingUpdater (details)
  179. add unit test which checks that sync is triggered when maxBulkSize is (details)
  180. fixed public /health endpoint + rabbitmq bridge solutionId extraction (details)
  181. added JavaScript mapping functions in order to simplify! JavaScript (details)
  182. added JMH benchmark for JavaScriptMessageMapperRhino (details)
  183. made result of MessageMapper Optionals for messages which should not be (details)
  184. renamed AmqpConnection to Connection and changed all of its use (details)
  185. renamed amqp-bridge service to connectivity service (details)
  186. improve javadoc (details)
  187. allow better control how events/responses are published into RabbitMQ (details)
  188. restricted size of mapping scripts (details)
  189. fixed test (details)
  190. removed connection prefix from connectionId and added a separate (details)
  191. Added class for message header filtering and extended message builder (details)
  192. ensure that a connection has either a source or an event target, remove (details)
  193. Implemented header filter with dynamic configuration (details)
  194. error handling part 1 (details)
  195. adjusted OpenJ9 version to 0.8.0 release + added building OpenJ9 docker (details)
  196. undid building special "-openj9" tag - changed completely to OpenJ9 (details)
  197. Fixed test config (details)
  198. Added javadoc, changed class and method access (details)
  199. Merge branch 'feature/amqp-bridge-extension' into (details)
  200. normalize connection consume/publish configuration, use topic path to (details)
  201. added hotsport _JAVA_OPTIONS again (details)
  202. added amqp-bridge to docker-compose (details)
  203. added missing mapping of /status /stats and /devops routes in nginx.conf (details)
  204. added missing routes in nginx (details)
  205. error handling refactoring: made BaseClientActor an Akka state machine (details)
  206. added connectivity service docker docker-compose.yml (details)
  207. renamed consume + publish of connection (details)
  208. added AddressMetric used in SourceMetrics and TargetMetrics (details)
  209. added "clientCount" configuration to Connection (details)
  210. publish live commands/events in policy/acl enforcer actor, handle live (details)
  211. fixed publishing + simplified MessageMappingProcessorActor creation (details)
  212. add origin to DittoHeaders (details)
  213. fix compile error (details)
  214. add 'origin' header to blacklist (details)
  215. fixed DittoHeader passing for built exceptions preserving (details)
  216. fixed tests (details)
  217. fixed tests (details)
  218. don't enforce matching contentType for fallback mapper (DittoMapper) (details)
  219. fix sending messages via http api (details)
  220. unsubscribe from topic when receiving a command response in (details)
  221. fixed restoring rabbitmq consumers on rabbitmq broker restart (details)
  222. made RabbitMQClientActor better testable, added first tests, fixed (details)
  223. monitor last successful search-sync end-timestamp in /status/health (details)
  224. fixed reconnecting connectios, closing, deleting + re-opening (details)
  225. re-activated fixed rabbitmq unit tests (details)
  226. handle 'response-required=false' in MessageMappingProcessorActor + added (details)
  227. enhanced Connection by "specificConfig" containing configuration for (details)
  228. review: add null checks + some tests and comments (details)
  229. Renamed occurrences of amqp-bridge to connectivity (details)
  230. register for message command responses for v1 api (details)
  231. allow empty contentTypes when not enforcing them (details)
  232. add ditto content type in command/event adapters (details)
  233. fix build (details)
  234. made mappingContexts of a connection instead of a list to a single one (details)
  235. extend TraceUriGenerator for messages traces (details)
  236. Fixed build warning ...filesystem-root relative reference... (details)
  237. correctly set and read AMQP1.0 headers + fixed ConnectionData (details)
  238. do not add non-mapped headers in WrappingMessageMapper (details)
  239. fixed test (details)
  240. small javadoc, sonar fixes (details)
  241. filter headers before message mapping is applied (details)
  242. validate client specific (amqp 1.0/0.9.1) configuration before (details)
  243. fixed javadoc errors (details)
  244. fixed NPE in AmqpClientActor (details)
  245. stop ConnectionActor on validation error + added test, register (details)
  246. added logging the connection-id as MDC entry (details)
  247. Display Ditto SVG correctly again in Readme (details)
  248. fixed let's encrypt renewal (details)
  249. fix ConnectionActorTest (details)
  250. really fix ConnectionActorTest (details)
  251. unsubscribe from registered topics (not only thing events) (details)
  252. fixed sending inline policy with CreateThing and ModifyThing command via (details)
  253. moved mappingContext to connection instead of duplicating it in the (details)
  254. rename and include connection id in metrics generated by (details)
  255. also validate the connection for "TestConnection" commands (details)
  256. upgrade to Akka 2.5.12 (details)
  257. Renamed occurrences of amqp-bridge to connectivity, started connectivity (details)
  258. started with blog post about connectivity service (details)
  259. Placeholder pages for mapping documentaion (details)
  260. only subscribe for responses if required, fix websocket subscriber (details)
  261. changed bytePayload in JS payload mapping to be an ArrayBuffer instead (details)
  262. added documentation chapter about connectivity payload mapping (details)
  263. use cluster aware router with consistent hashing to deliver command (details)
  264. re-structure the connectivity section (details)
  265. stop response actor after forwarding response (details)
  266. finished documenting payload mapping chapter (details)
  267. Completed connection schema (details)
  268. review: create CommandRouter as child actor of BaseClientActor (details)
  269. propagate ditto headers with exception (e.g. containing the required (details)
  270. update header blacklist (details)
  271. added modifying existing connections (details)
  272. stabilize tests (details)
  273. stabilize tests (details)
  274. Updated connection docs (details)
  275. Updated connection docs (details)
  276. Updated connection docs (details)
  277. fixed bug in SseThingsRoute - was no longer working due to cast error (details)
  278. added "connectionStatus" to connection json schema (details)
  279. by default don't map messages if not incoming or outgoing script was (details)
  280. made timeout for ThingsAggregatorActor configurable and configured a (details)
  281. added missing configs (details)
  282. fixed testConnection handling in ConnectionActor (details)
  283. fixed deleting a connection which was not able to connect (details)
  284. fixed test (details)
  285. fixed status of RabbitMQ targetMetrics by checking for existence of all (details)
  286. Changed sources/targets type to object (details)
  287. Updated piggyback command section (details)
  288. Updated connectivity documentation (details)
  289. Finished connectivity documentation (details)
  290. doc review (details)
  291. documentation: fixed dead/broken links in documentation, added some (details)
  292. changed publish date of blog post (details)
  293. added simple socket connection check prior to actually creating or (details)
  294. minor spelling changes (details)
  295. fix tests (details)
  296. minor spelling changes (details)
  297. adjusted kamon trace name for roundtrips: included connectionId (details)
  298. fixed broken links (details)
  299. fixed TL;DR description of mapping (details)
  300. moved JavaScript options like maxScriptSizeBytes to service .conf (details)
  301. Minor corrections (details)
  302. fixed connectivity entries in docker-compose.yml (details)
  303. fix unit tests (details)
  304. updated used 3rd-party dependencies (details)
  305. fixed sonar issues (details)
  306. #140 fixed docker-compose.yml entrypoints (details)
  307. removed -Xtune:virtualized option as only useful for CPU constrained (details)
  308. added release notes + announcement for Ditto 0.3.0-M1 (details)
Commit 92fd53153b22f71b7282049244ad3b3569fadfd0 by johannes.schneider
unified snapshot adapters, implemented hook for successful snapshots
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapter.java
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/ThingWithSnapshotTag.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotter.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotterTest.java (diff)
The file was addedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/AbstractPoliciesService.java
The file was removedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/things/ThingWithSnapshotTagTest.java
The file was modifiedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorSnapshottingTest.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/SnapshotAdapter.java
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/package-info.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/SnapshotTag.java
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActorSnapshottingTest.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoSnapshotAdapter.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/TaggedThingJsonSnapshotAdapter.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/SnapshotterState.java (diff)
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoEventAdapter.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/policies/MongoPolicySnapshotAdapter.java
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoSnapshotAdapter.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/MongoThingEventAdapter.java
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/package-info.java
The file was modifiedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorTest.java (diff)
The file was removedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/MongoThingEventAdapterTest.java
The file was removedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/things/TaggedThingJsonSnapshotAdapterTest.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionMongoSnapshotAdapter.java
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff)
The file was modifiedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff)
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/package-info.java
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/AbstractMongoSnapshotAdapter.java
The file was removedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/persistence/SafeRecovery.java
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/MongoConnectionSnapshotAdapter.java
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
The file was addedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/package-info.java
The file was addedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/package-info.java
The file was addedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapterTest.java
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicySupervisorActor.java (diff)
The file was removedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/persistence/SnapshotAdapter.java
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingWithSnapshotTag.java
The file was addedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoSnapshotAdapterTest.java
The file was addedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/SnapshotTag.java
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/MongoThingSnapshotAdapter.java
The file was addedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/serializer/ThingWithSnapshotTagTest.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/MongoReconnectSnapshotAdapter.java (diff)
The file was modifiedservices/things/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesService.java (diff)
The file was removedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/MongoPolicyEventAdapter.java
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/AbstractThingsService.java (diff)
The file was removedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/things/package-info.java
The file was modifiedservices/policies/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/SafeRecovery.java
Commit 64c08164508ce409d72449fa3cd4c4af821395df by johannes.schneider
fixed compile error in ConnectionActor
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
Commit 9704b5e1d671c37f8fab4ccb662e9c1adbe483be by yufei.cai
move snapshotSuccessFunctions into AbstractMongoSnapshotAdapter
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/AbstractMongoSnapshotAdapter.java (diff)
The file was modifiedservices/things/persistence/src/test/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotterTest.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicySupervisorActor.java (diff)
The file was modifiedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was modifiedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesService.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/DittoThingSnapshotter.java (diff)
Commit cfea4292033a936e414b78a0264c8fe9abfd1f44 by yufei.cai
fix test-compile errors
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorSnapshottingTest.java (diff)
The file was modifiedservices/policies/persistence/src/test/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActorTest.java (diff)
Commit a599bf8835cacaba32589bb273582a77ed77a075 by yufei.cai
Rename Health-related classes to prepare for simplification
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was modifiedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff)
The file was removedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRepresentation.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff)
The file was modifiedservices/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff)
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/ClusterPersistenceHealth.java
Commit b38d3c07ff860428333ac6ba5a211d89711b82a9 by yufei.cai
Make Health messages generic and extensible in health components
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff)
The file was modifiedservices/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff)
The file was removedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/ClusterPersistenceHealth.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff)
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceClusterHealth.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff)
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff)
Commit f8084c19a0484fb85772128cb4e7f4dfe103ea69 by yufei.cai
Fix MappingStrategiesBuilderTest
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff)
Commit afa456b10778e35af9a33b5430cd8cd2293442bb by yufei.cai
Document Health
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff)
Commit 3d0b178709ec2c54f831c417102457647d068f2b by yufei.cai
Add method to retrieve specific component health statuses.
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff)
Commit d9174e1dae2309fad725f1036af35bb645e3d073 by yufei.cai
fix Health serialization
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff)
Commit 3e1ddbb1f9a33ca3051e3b1f453a2989c6b13d8b by daniel.fesenmeyer
move (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>
The file was addedservices/utils/persistence/src/test/resources/logback-test.xml
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexKey.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/InPredicateImplTest.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/package-info.java
The file was removedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/BsonCollectionAssert.java
The file was removedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/BsonAssert.java
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/BsonAssertions.java
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexTest.java
The file was modifiedservices/thingsearch/persistence/pom.xml (diff)
The file was addedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/IndexInitializationIT.java
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/ThingsSearchPersistence.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexDirection.java
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/DefaultIndexKeyTest.java
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/MongoIndexAssertions.java
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexFactoryTest.java
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializer.java
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/DefaultIndexKey.java
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/PolicyRestrictedMongoSearchAggregation.java (diff)
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializerIT.java
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexFactory.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/AttributeExpressionBsonTest.java (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/util/MongoSetKeyValidity.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/FeatureIdPropertyExpressionBsonTest.java (diff)
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/BsonCollectionAssert.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/AbstractPredicateTest.java (diff)
The file was removedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/BsonAssertions.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/AbstractCriteriaTestBase.java (diff)
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/MongoThingsSearchPersistence.java (diff)
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexOperationsTest.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/SimpleFieldExpressionBsonTest.java (diff)
The file was addedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/Indices.java
The file was removedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/BsonUtil.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/criteria/LikePredicateImplTest.java (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/write/impl/PolicyUpdateFactoryTest.java (diff)
The file was removedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/IndexInitializer.java
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/AbstractThingSearchPersistenceITBase.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexOperations.java
The file was modifiedservices/thingsearch/starter/src/main/resources/things-search.conf (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/MongoQueryTest.java (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/FeatureExpressionBsonTest.java (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/query/model/expression/FeaturePropertyExpressionBsonTest.java (diff)
The file was addedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/Index.java
The file was modifiedservices/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchRootActor.java (diff)
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/assertions/BsonAssert.java
The file was modifiedservices/utils/persistence/pom.xml (diff)
The file was addedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializerTest.java
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/utils/test/src/test/java/org/eclipse/ditto/services/utils/test/mongo/MongoDbResource.java (diff)
Commit 8d3a273f7d81a63939b7c6ac3b09ef76a685a1b6 by daniel.fesenmeyer
make index-initialization optional for thingsearch (as it was possible
before the latest changes)
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/thingsearch/common/src/main/java/org/eclipse/ditto/services/thingsearch/common/util/ConfigKeys.java (diff)
The file was modifiedservices/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchRootActor.java (diff)
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/MongoThingsSearchPersistence.java (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/AbstractThingSearchPersistenceITBase.java (diff)
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/ThingsSearchPersistence.java (diff)
Commit 3b741a74774438c8bb8b75315e77a6291e6d2149 by daniel.fesenmeyer
method 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>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java (diff)
Commit 895b3819dff065cbb1ee66b6aaa6e17188d27bf2 by daniel.fesenmeyer
add method BsonUtil#getDocumentWithDefaultAt which circumvents problems
with (Mongo-)Document#get(Object, Object)
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java (diff)
Commit 8538393e7286bb36bcb717a9e256fa604a7ffba4 by daniel.fesenmeyer
simplify signature of BsonUtil#getDocumentWithDefaultAt
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/BsonUtil.java (diff)
Commit 651f9c3674127fcaf418896b2bfd68db2f3aa6d1 by daniel.fesenmeyer
add test that checks that index-initialization does not fail when no
indices are defined; log a warning in this case
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/utils/persistence/src/test/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializerIT.java (diff)
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/IndexInitializer.java (diff)
Commit 3b8916d4b57ecf89394c4e0e0774a44467bbe209 by daniel.fesenmeyer
minor test-config improvements in thingsearch-persistence: - load config
only once in MongoHealthCheckIT - remove no longer index-config from
test.conf
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/thingsearch/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/MongoHealthCheckIT.java (diff)
Commit b54ce15f3eb6ca9e317e706fde96d2d0b122eaeb by Thomas Jaeckle
PoC of mapping payload via JavaScript engines
* trying out Nashorn, Nashorn sandboxed and Rhino as alternatives
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/MappingTemplate.java
The file was modifiedservices/amqp-bridge/pom.xml (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperSimpleTest.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperSimpleTest.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMustacheTest.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMessage.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMappers.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperBytesTest.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutableMappingTemplate.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutablePayloadMapperMessage.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/ImmutableJavaScriptPayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/AbstractJavaScriptPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicRhinoPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperFactory.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornSandboxPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperBytesTest.java
The file was addedservices/amqp-bridge/mapping/pom.xml
Commit f3060866b5137eb44752b518221c8c2c594d1dc1 by Thomas Jaeckle
added possibility to map raw payloads
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornSandboxPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/AbstractJavaScriptPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicRhinoPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperBytesTest.java (diff)
Commit fb3931d22f8cc9d1d827814cfa1a624e4f47de49 by Thomas Jaeckle
removed 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>
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff)
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java
The file was modifiedservices/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/DeleteConnectionResponse.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CloseConnectionResponse.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornPayloadMapper.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperSimpleTest.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMessage.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingScript.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java
The file was modifiedservices/amqp-bridge/messaging/pom.xml (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatuses.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/OpenConnection.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapper.java
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/resources/test.conf (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandConsumerActor.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/AbstractJavaScriptPayloadMapper.java
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/OpenConnectionResponse.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatusResponse.java (diff)
The file was modifiedservices/amqp-bridge/mapping/pom.xml (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponseTest.java (diff)
The file was addedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/DittoConstants.java
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicNashornSandboxPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperBytesTest.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/ProtocolToRawMapperSimpleTest.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionData.java (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatus.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMappingTemplate.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CloseConnection.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/JavaScriptPayloadMapperFactory.java
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingScript.java
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreatedTest.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/MappingTemplate.java
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was addedservices/amqp-bridge/messaging/src/test/resources/logback-test.xml
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperMustacheTest.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMapperBytesTest.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/DynamicRhinoPayloadMapper.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/javascript/ImmutableJavaScriptPayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MappingTemplate.java
The file was modifiedbom/pom.xml (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/DeleteConnection.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutablePayloadMapperMessage.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/PayloadMappers.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/ImmutableMappingTemplate.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatusesResponse.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnection.java (diff)
Commit e37893600bc798b96e25895200f9e9986349b3d1 by daniel.fesenmeyer
provide 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>
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff)
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusDetailMessage.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff)
The file was removedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthStatusTest.java
The file was modifiedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java (diff)
The file was modifiedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/StatusHealthHelper.java (diff)
The file was removedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthStatus.java
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusInfo.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceClusterHealth.java (diff)
The file was modifiedservices/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff)
The file was modifiedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/AbstractStatusHealthHelper.java (diff)
The file was addedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusDetailMessageTest.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/health/CachingHealthRoute.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was addedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusInfoTest.java
Commit 7df50bbb4d94d6ed31bae385d8c512888bc14adb by daniel.fesenmeyer
simplify 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>
The file was removedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/HealthTest.java
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/EndpointTestBase.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was modifiedservices/utils/cluster/src/test/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilderTest.java (diff)
The file was removedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceClusterHealth.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff)
The file was removedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/Health.java
The file was modifiedservices/utils/cluster/src/main/java/org/eclipse/ditto/services/utils/cluster/MappingStrategiesBuilder.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff)
Commit a99347ecd685ed5a5d2f1fa17e2d597255738a5b by Thomas Jaeckle
made mapping template string optional
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MappingTemplate.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMappingTemplate.java (diff)
Commit 27412af36436ce8e6f9a8872174641bb8ceb7e42 by dominik.guggemos
initial step integrating rabbitmq brigde into amqp bridge
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionType.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableConnectionTest.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ErrorHandlingActorTest.java
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff)
The file was removedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockJmsConnectionFactory.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was addedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ConnectionTypeTest.java
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java
The file was modifiedbom/pom.xml (diff)
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/JmsConnectionFactory.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JmsConnectionFactory.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/AmqpConnectionBasedJmsConnectionFactory.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQConnectionActor.java
The file was modifiedservices/amqp-bridge/starter/src/main/resources/amqp-bridge-dev.conf (diff)
The file was modifiedservices/amqp-bridge/messaging/pom.xml (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff)
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/FaultyConnectionActor.java
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandConsumerActor.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
Commit 8ba23175ffad4e5b477a00829bfb67f984b6b37e by dominik.guggemos
remove duplicate file
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff)
Commit b30d1b5e01c0f6733be50151b0e6e5d532bbb54d by Thomas Jaeckle
simplified! mapping and made CommandProcessorActor dynamically load a
class it interprets from the configured "mappingEngine"
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff)
The file was addedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/pom.xml (diff)
The file was removedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMappingTemplate.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingScript.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MappingTemplate.java
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingScript.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java (diff)
Commit 13261775df0d62754091739d644ba509aff0d144 by Thomas Jaeckle
renamed MappingScript interface to MappingContext
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff)
The file was removedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingScript.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/package-info.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was removedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingScript.java
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionData.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/package-info.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff)
Commit 33c7c31ff518a493fbbefe385fb81b37fbda5699 by Stefan Maute
adapt response code for fire and forget messages
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifieddocumentation/src/main/resources/openapi/ditto-api-1.yml (diff)
The file was modifieddocumentation/src/main/resources/openapi/ditto-api-2.yml (diff)
Commit 1bb331c342e3a31916e6349585d0bbe9453a59c2 by noreply
Update pom.xml
Excluded package for JSR305-annotation from OSGi imports as this
annotations are not required at runtime.
The file was modifiedsignals/commands/live/pom.xml (diff)
Commit 42ed6a9bde409f2490873b35de6ea36154d11b89 by dominik.guggemos
fix duplicate creation of command processor
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
Commit 82b03cdc70644bd872a8392990822c8dbdb759d8 by Philipp.Michalski
Fixed amqp bridge unit tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponseTest.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionTest.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponseTest.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreatedTest.java (diff)
Commit 27cf21f04603db3b90adbffec5eec56b5965888c by Philipp.Michalski
Fixed amqp bridge unit tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit cb233c3451bebe9eb06d2077532d91b3c9e54c43 by daniel.fesenmeyer
Simplify 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>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/health/CachingHealthRoute.java (diff)
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusAndHealthHelper.java
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/StatusAndHealthProvider.java
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusHealthSupplier.java
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusHealthSupplier.java
The file was removedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/StatusHealthHelper.java
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ConfigurableStatusAndHealthProvider.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java (diff)
The file was modifiedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusInfoTest.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff)
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusSupplier.java
The file was removedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/AbstractStatusHealthHelper.java
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/DittoStatusAndHealthProviderFactory.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusInfo.java (diff)
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/CompositeStatusHealthSupplier.java
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplier.java
The file was removedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/DittoStatusHealthHelper.java
The file was addedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/CompletableFutureUtils.java
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/status/OverallStatusRoute.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/java/org/eclipse/ditto/services/gateway/endpoints/routes/status/OverallStatusRouteTest.java (diff)
Commit 58ede478be5cb7baf13c64441acc0cdf14ff70ff by daniel.fesenmeyer
Improve 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>
The file was modifiedservices/thingsearch/starter/src/main/java/org/eclipse/ditto/services/thingsearch/starter/actors/SearchRootActor.java (diff)
The file was modifiedservices/policies/starter/src/main/java/org/eclipse/ditto/services/policies/starter/PoliciesRootActor.java (diff)
The file was removedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActor.java
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/CompositeCachingHealthCheckingActor.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthRouteSupplier.java (diff)
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/AbstractHealthCheckingActor.java
The file was modifiedservices/utils/health/src/test/java/org/eclipse/ditto/services/utils/health/StatusInfoTest.java (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/StatusInfo.java (diff)
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/status/StatusSupplierActor.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/things/starter/src/main/java/org/eclipse/ditto/services/things/starter/ThingsRootActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/RootRoute.java (diff)
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/PersistenceHealthCheckingActor.java
The file was modifiedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/HealthCheckingActorOptions.java (diff)
The file was addedservices/utils/health/src/main/java/org/eclipse/ditto/services/utils/health/DefaultHealthCheckingActorFactory.java
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-feature.md (diff)
Commit 8c5eb3c1aef410ea245349113dd3b51b9e6b00b6 by Thomas Jaeckle
added 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>
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-class-diagram-v1.png
The file was addeddocumentation/src/main/resources/slides/bg-images/background-framework-small.jpg
The file was addeddocumentation/src/main/resources/slides/bg-images/background-twin-small.jpg
The file was addeddocumentation/src/main/resources/slides/bg-images/background-conclusion-small.jpg
The file was addeddocker/sandbox/nodered/settings.js
The file was addeddocumentation/src/main/resources/slides/bg-images/background-cloud-small.jpg
The file was addeddocker/sandbox/nodered/flows-ditto.json
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/eclipse landscape.png
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-in-action.png
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html
The file was addeddocumentation/src/main/resources/slides/bg-images/background-outlook-small.jpg
The file was modifieddocumentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/presentations.md
The file was addeddocumentation/src/main/resources/slides/bg-images/background-demo-small.jpg
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/asset-admin-shell.png
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/eclipse_iot_logo.png
The file was modifieddocker/sandbox/nginx.conf (diff)
The file was modifieddocker/sandbox/docker-compose.yml (diff)
The file was addeddocker/sandbox/nodered/package.json
Commit e742cce3e6bd863d79e2efef3f7bc37620dfec16 by Thomas Jaeckle
reduced sandbox deployment
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocker/sandbox/docker-compose.yml (diff)
The file was modifieddocker/sandbox/html/index.html (diff)
The file was modifieddocker/sandbox/nginx.conf (diff)
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
Commit 75f6eed24c0563666bc40eb05246cbe4ef5a1644 by Thomas Jaeckle
rewrite ditto section with code samples
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was removeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/eclipse landscape.png
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/meme-dino.jpg
The file was removeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-class-diagram-v1.png
Commit bc89a7653ad1670f253c9b2dfd8bc394c37cb455 by Thomas Jaeckle
further polishing of virtualIoT meetup slides
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
The file was modifieddocker/sandbox/html/index.html (diff)
The file was addeddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/ditto-orchestration-examples.png
Commit 34a0e70217fe75ab0e723646dd60bb4ed90df99d by noreply
fixed changed behavior in ImmutableFeatures.toJson
back to previous behavior
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/ImmutableFeatures.java (diff)
Commit b555c09d27e27814acc83eaef1603852f32140b5 by noreply
fixed missing import
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/ImmutableFeatures.java (diff)
Commit 3c8f339093996fb456180f87f8058c098c518bbf by Thomas Jaeckle
adjusted release notes for 0.2.0-M1, made slides "fragments"
configurable
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was removeddocumentation/src/main/resources/pages/ditto/release_notes_010M4.md
The file was modifieddocumentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
The file was addeddocumentation/src/main/resources/pages/ditto/release_notes_020M1.md
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
Commit e59aa4511b60705f2f7090606569acfd2ab1d7d5 by Thomas Jaeckle
adjusted release notes for 0.2.0-M1, made slides "fragments"
configurable
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addeddocumentation/src/main/resources/pages/ditto/release_notes_020M1.md
The file was removeddocumentation/src/main/resources/pages/ditto/release_notes_010M4.md
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
The file was modifieddocumentation/src/main/resources/_data/sidebars/ditto_sidebar.yml (diff)
Commit 07e16a8b3915b2cb0c3be4370cddb7289af7020a by Thomas Jaeckle
wrote 0.2.0-M1 blogpost announcement
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addeddocumentation/src/main/resources/_posts/2018-02-07-milestone-announcement-020-M1.md
Commit 79c93c22bac8b6c9b726c06074d6fe51caaeb1dd by Thomas Jaeckle
wrote 0.2.0-M1 blogpost announcement
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addeddocumentation/src/main/resources/_posts/2018-02-07-milestone-announcement-020-M1.md
Commit de4ab91e179b3a1599c9bfa55fb32515b759509e by Thomas Jaeckle
fixed typo
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
Commit 70e6c4a4a544dcf578b1dc45b2a4e1b64b4bef96 by Thomas Jaeckle
fixed typo
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocumentation/src/main/resources/slides/2018_02_07-virtualiot-meetup/index.html (diff)
The file was modifieddocumentation/src/main/resources/_posts/2018-02-08-feature-definition.md (diff)
The file was modifieddocumentation/src/main/resources/_posts/2018-02-08-feature-definition.md (diff)
Commit c2b878732acc8e615d78733fa3a9e88cb341dbc4 by noreply
fixed example json in doc
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-feature.md (diff)
Commit 03207806e151e7ccb1bc62009663d5f32f16422c by noreply
fixed example json in doc
The file was modifieddocumentation/src/main/resources/pages/ditto/basic-feature.md (diff)
Commit dcb935159dbac25528a39b13d3c0d9f0ee8850b8 by noreply
updated binary-compatibility-check.version
to 0.2.0-M1
The file was modifiedbom/pom.xml (diff)
Commit 2a3c161aa85724d2e86e37957992da9f135227b8 by noreply
updated binary-compatibility-check.version
to 0.2.0-M1
The file was modifiedbom/pom.xml (diff)
Commit ce8640e90e96f064f4c2223584e8f92e9e14d3c9 by Philipp.Michalski
New PayloadMapper factory and tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactoryTest.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/pom.xml (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactory.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoopMapper.java
Commit 635cb06e645c38e975d95bee013e1034b828e4da by Philipp.Michalski
Adopted local mappers for testing
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactoryTest.java (diff)
Commit eb3c02fb9d48012f47211187fb9de0a43554f975 by Philipp.Michalski
Mappers licence header
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java (diff)
Commit 3a2a6d3d94054a98b7542b053b623d850519caeb by Thomas Jaeckle
switched to OpenJ9-openjdk9 alpine base image for Ditto + Things
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/policies/starter/pom.xml (diff)
The file was modifiedservices/pom.xml (diff)
The file was modifiedservices/things/starter/pom.xml (diff)
The file was modifiedservices/amqp-bridge/starter/pom.xml (diff)
The file was modifieddocker/docker-compose.yml (diff)
The file was modifieddocker/sandbox/docker-compose.yml (diff)
The file was modifiedservices/thingsearch/starter/pom.xml (diff)
The file was modifiedservices/gateway/starter/pom.xml (diff)
Commit a4dc3051f4eeb37c23191ce23ed1f0c0c62d88ad by Thomas Jaeckle
try using openjdk8-openj9 instead of jdk9
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/pom.xml (diff)
Commit 30b90c7c06713f92dbad6286867ad93f016c94bf by Thomas Jaeckle
removed weird argument
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/things/starter/pom.xml (diff)
The file was modifiedservices/policies/starter/pom.xml (diff)
The file was modifiedservices/thingsearch/starter/pom.xml (diff)
The file was modifiedservices/gateway/starter/pom.xml (diff)
The file was modifiedservices/amqp-bridge/starter/pom.xml (diff)
Commit 69a79e4d84fd0346d5b976ae3dbdf86a560b3413 by Thomas Jaeckle
added "-Xtune:virtualized" openj9 param
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/starter/pom.xml (diff)
The file was modifiedservices/things/starter/pom.xml (diff)
The file was modifiedservices/gateway/starter/pom.xml (diff)
The file was modifiedservices/policies/starter/pom.xml (diff)
The file was modifiedservices/thingsearch/starter/pom.xml (diff)
Commit 3d90f90309b21fb7d97c7e7629058f180a5fd038 by Thomas Jaeckle
adjusted openj9 baseimage to fixed version; introduced "cpus" limit in
docker compose
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/pom.xml (diff)
Commit e79c6202e1f9fc8f4b003eda233033b8d86285da by yufei.cai
fix 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>
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
Commit 1279eaacf486ac66b6fb44ec0b9bca16389c8960 by Philipp.Michalski
Changed internal message, added documentation
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff)
Commit 7feaf23d6c0a12d71a9a0142740d3def3f53dbb9 by dominik.guggemos
change to actor based hierarchy because of issues with JMS client
(blocking)
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java (diff)
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActorTest.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff)
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ConnectionTypeTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java
The file was modifiedservices/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff)
The file was addedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionFailedExceptionTest.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ErrorHandlingActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionFailedException.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/FaultyConnectionActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionType.java (diff)
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableConnectionTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff)
The file was modifiedbom/pom.xml (diff)
Commit 50e07e2fa546cecbe68276e0a3addc9ce96cb97f by Philipp.Michalski
New default ditto protocol mapper
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoopMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappingException.java
Commit 44e7418ac1811679d794e1f1cc7b060b1ae7c5f9 by dominik.guggemos
javadoc, logging, small improvements
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java (diff)
Commit 960644b0f350ef9f5ed5e356ba4e5326b45a1fb7 by Thomas Jaeckle
adjusted ditto startup settings
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifieddocker/docker-compose.yml (diff)
The file was modifiedservices/policies/starter/pom.xml (diff)
The file was modifiedservices/amqp-bridge/starter/pom.xml (diff)
The file was modifiedservices/gateway/starter/pom.xml (diff)
The file was modifiedservices/things/starter/pom.xml (diff)
The file was modifiedservices/thingsearch/starter/pom.xml (diff)
The file was modifieddocker/sandbox/docker-compose.yml (diff)
Commit e29644d46d2c56acfbcf190d6e99ae29214373fa by Philipp.Michalski
Implemented mapping in CommandProcessorActor
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappingException.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff)
Commit a548f60b43f630147bbb7764509e53aa0a6479a2 by dominik.guggemos
rename connectionActor to clientActor to avoid confusion
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQConnectionActor.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff)
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActor.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff)
The file was removedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionActorTest.java
Commit 16836a46d42b041f9fcb6b67740f77bb43349bb3 by Philipp.Michalski
New protocol mapper tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapperTest.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractPayloadMapperTest.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java (diff)
Commit a8f353e5a1dc09983cb2413b45d7be5010b8f013 by Thomas Jaeckle
adjusted dispatcher configuration and default-dispatcher to be more
moderate
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedservices/things/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/gateway/proxy/src/test/resources/test.conf (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/resources/test.conf (diff)
The file was modifiedservices/policies/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/thingsearch/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/utils/distributed-cache/actors/src/main/resources/reference.conf (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/base/src/main/java/org/eclipse/ditto/services/base/DittoService.java (diff)
The file was modifiedservices/gateway/endpoints/src/test/resources/test.conf (diff)
The file was modifiedservices/thingsearch/starter/src/main/resources/things-search.conf (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff)
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
Commit 9c27a32b59511cf741c79e79afe9609c6739e474 by Thomas Jaeckle
adjusted dispatcher configuration
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/policies/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/things/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/thingsearch/persistence/src/test/resources/test.conf (diff)
The file was modifiedservices/gateway/proxy/src/test/resources/test.conf (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff)
The file was modifiedservices/gateway/starter/src/main/resources/gateway.conf (diff)
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
The file was modifiedservices/gateway/endpoints/src/test/resources/test.conf (diff)
The file was modifiedservices/thingsearch/starter/src/main/resources/things-search.conf (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/resources/test.conf (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
The file was modifiedservices/utils/distributed-cache/actors/src/main/resources/reference.conf (diff)
Commit 861cab6a1fffdbe77de851e040c8abb66953950c by Thomas Jaeckle
minor logging fix: parameter "collectionName" was missing in debug
output
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/streaming/MongoSearchSyncPersistence.java (diff)
Commit 78fdd972b350e9c7e60a10165ff885fa6fc0a3e1 by Thomas Jaeckle
minor logging fix: parameter "collectionName" was missing in debug
output
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/streaming/MongoSearchSyncPersistence.java (diff)
Commit 18110412793853213170a14f0b08a9da26fcff0f by Thomas Jaeckle
deprecate Event.JsonFields.ID, serialize Event.JsonFields.TYPE
unconditionally
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff)
The file was modifiedsignals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/AbstractPolicyEvent.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryCreatedTest.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeatureDefinitionModifiedTest.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/AbstractAmqpBridgeEvent.java (diff)
The file was modifiedsignals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/AbstractThingEvent.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryModifiedTest.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclModifiedTest.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryDeletedTest.java (diff)
The file was modifiedsignals/events/batch/src/main/java/org/eclipse/ditto/signals/events/batch/AbstractBatchEvent.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeaturePropertiesModifiedTest.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff)
The file was modifiedsignals/events/policies/src/test/java/org/eclipse/ditto/signals/events/policies/PolicyEntriesModifiedTest.java (diff)
Commit c3d5798408bb37f2e9bf3e0adeb967aa4345467a by Thomas Jaeckle
deprecate Event.JsonFields.ID, serialize Event.JsonFields.TYPE
unconditionally
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryDeletedTest.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff)
The file was modifiedsignals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/AbstractPolicyEvent.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclModifiedTest.java (diff)
The file was modifiedsignals/events/batch/src/main/java/org/eclipse/ditto/signals/events/batch/AbstractBatchEvent.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeatureDefinitionModifiedTest.java (diff)
The file was modifiedsignals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/AbstractThingEvent.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryModifiedTest.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/AbstractAmqpBridgeEvent.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/FeaturePropertiesModifiedTest.java (diff)
The file was modifiedsignals/events/things/src/test/java/org/eclipse/ditto/signals/events/things/AclEntryCreatedTest.java (diff)
The file was modifiedsignals/events/policies/src/test/java/org/eclipse/ditto/signals/events/policies/PolicyEntriesModifiedTest.java (diff)
Commit b951ede2d02b3245945216533fa140d3411ab2be by Philipp.Michalski
Internal message knows its type, mapper changed to guava converter api
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/pom.xml (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java (diff)
Commit 6d05781d18e7147d1faa895d75616255fe9869a6 by Philipp.Michalski
copyright
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
Commit c092d95c6c4f5a3c553286bc75dedcd6e2bda0fa by yufei.cai
add sensible defaults for burst size and batching to
AbstractStreamingActor
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/utils/akka/src/main/java/org/eclipse/ditto/services/utils/akka/streaming/AbstractStreamingActor.java (diff)
Commit 1e9326d98066487ce236b604825ad051d329e90f by Philipp.Michalski
Adapted tests to changed mapper api; added docs and comments
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapper.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoProtocolMapperTest.java
The file was removedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/InternalMessage.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappingException.java
The file was modifiedservices/amqp-bridge/mapping/pom.xml (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractPayloadMapperTest.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoOpMapper.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactoryTest.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ConverterTraceWrapper.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoopMapper.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperFactory.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff)
Commit 8ffc0a0af41be89853a43d1d3c815d1a15a9f59c by yufei.cai
add Command.Category to classify all commands
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyResource.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyPolicy.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/query/PolicyQueryCommand.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThings.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeature.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/DeleteConnection.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatuses.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAttributes.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeletePolicy.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatures.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteThing.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureDefinition.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttributes.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteSubject.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAclEntry.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatus.java (diff)
The file was modifiedsignals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/RetrieveLoggerConfig.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteResource.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatures.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAcl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/query/ThingQueryCommand.java (diff)
The file was modifiedsignals/commands/batch/src/main/java/org/eclipse/ditto/signals/commands/batch/ExecuteBatch.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeletePolicyEntry.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/OpenConnection.java (diff)
The file was modifiedsignals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/AbstractMessageCommand.java (diff)
The file was modifiedservices/models/thingsearch/src/main/java/org/eclipse/ditto/services/models/thingsearch/commands/sudo/SudoRetrieveNamespaceReport.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyResources.java (diff)
The file was modifiedsignals/commands/thingsearch/src/main/java/org/eclipse/ditto/signals/commands/thingsearch/query/ThingSearchQueryCommand.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureProperties.java (diff)
The file was modifiedservices/models/policies/src/main/java/org/eclipse/ditto/services/models/policies/commands/sudo/SudoRetrievePolicy.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyPolicyEntries.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifySubject.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyThing.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureDefinition.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureProperty.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyPolicyId.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CloseConnection.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifySubjects.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/CreateThing.java (diff)
The file was modifiedservices/models/thingsearch/src/main/java/org/eclipse/ditto/services/models/thingsearch/commands/sudo/SudoCountThings.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff)
The file was modifiedprotocol-adapter/src/test/java/org/eclipse/ditto/protocoladapter/ThingModifyCommandAdapterTest.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeature.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyAttribute.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/query/AbstractQueryLiveCommand.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperty.java (diff)
The file was modifiedsignals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/RetrieveStatistics.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/Command.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/TakeSnapshot.java (diff)
The file was modifiedservices/models/streaming/src/main/java/org/eclipse/ditto/services/models/streaming/SudoStreamModifiedEntities.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandImpl.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThing.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/ModifyPolicyEntry.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/CreatePolicy.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAclEntry.java (diff)
The file was modifiedsignals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/ExecutePiggybackCommand.java (diff)
The file was modifiedsignals/commands/devops/src/main/java/org/eclipse/ditto/signals/commands/devops/ChangeLogLevel.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnection.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperties.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttribute.java (diff)
Commit e72bd650f8568bb4eeaee9e99823e0ae424e6d67 by dominik.guggemos
add router to distribute client actor to cluster nodes
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/models/amqp-bridge/src/main/java/org/eclipse/ditto/services/models/amqpbridge/AmqpBridgeMessagingConstants.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/java/org/eclipse/ditto/services/amqpbridge/actors/AmqpBridgeRootActor.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionBuilder.java
The file was addedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff)
The file was removedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableConnectionTest.java
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/FaultyConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/resources/test.conf (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/MockConnectionActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/DefaultConnectionActorPropsFactory.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnectionBuilder.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorPropsFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ErrorHandlingActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/resources/amqp-bridge.conf (diff)
The file was modifiedservices/amqp-bridge/util/src/main/java/org/eclipse/ditto/services/amqpbridge/util/ConfigKeys.java (diff)
Commit b61709a694552c39f77209fe2d9a271bf29d06b3 by Philipp.Michalski
Improved message mapper api and added tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/NoOpMapper.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/Mappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
Commit 3f628626fd557a9c05fb718beddba72fe182e583 by Philipp.Michalski
Adapted tests to message mapper changes
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
Commit 7e439d3d4fe4e2f7d639374af9fd90381ec6e215 by Philipp.Michalski
Added access functions to find reverse mapper; Added convenience
functions
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
Commit 3b9e48faac99cc04417fb32bc9b9217f4cf91ced by Philipp.Michalski
Better default mapper configuration
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit 79006ba6cf410996936babc2a86976a76da44091 by Philipp.Michalski
Moved logic from command processing actor to message mapper factory,
implemented reverse mapping in command processing actor
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
Commit eb0200d7bae402b087a5549d7b2917c5005f64e3 by daniel.fesenmeyer
fix several sonar issues and delete unused code
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/ThingErrorResponse.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/ModifyThingHandlerActor.java (diff)
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/Index.java (diff)
The file was modifiedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusAndHealthHelper.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoEventAdapter.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/NullFeatureDefinition.java (diff)
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedservices/policies/util/src/main/java/org/eclipse/ditto/services/policies/util/ConfigKeys.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/PolicyRestrictedMongoSearchAggregation.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNode.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ThingModifyCommandResponseAdapter.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/EnforcerLookupActor.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/rql/RqlPredicateParserTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/HttpStatusCode.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessageFormatInvalidException.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureDefinition.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractPolicyEnforcerActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/HttpRequestActor.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/AbstractProtocolAdapter.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPathBuilder.java (diff)
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonCollectors.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNodeTest.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedservices/models/things/src/test/java/org/eclipse/ditto/services/models/things/CommandAndEventJsonExamplesProducer.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapter.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/query/RetrieveThingsResponse.java (diff)
The file was modifiedservices/thingsearch/query/src/main/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitor.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPath.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/NullFeatures.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNodeTest.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/ThingsRoute.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingSupervisorActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseThingsRoute.java (diff)
The file was modifiedservices/models/things/src/test/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponseTest.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNode.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/CreateThingHandlerActor.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/utils/UriEncoding.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNode.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponse.java (diff)
The file was modifiedservices/thingsearch/query/src/test/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitorTest.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNodeTest.java (diff)
The file was modifiedsignals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/PolicyCreated.java (diff)
The file was modifiedsignals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/ThingEventRegistry.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/scala/org/eclipse/ditto/model/thingsearchparser/parser/RqlPredicateParser.scala (diff)
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/starter/service/util/ConfigKeys.java (diff)
Commit 57bc34bea36cb5c4550fee273a8bf46dfb12a088 by daniel.fesenmeyer
fix several sonar issues and delete unused code
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/HttpRequestActor.java (diff)
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/indices/Index.java (diff)
The file was modifiedservices/models/things/src/test/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponseTest.java (diff)
The file was modifiedservices/thingsearch/query/src/test/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitorTest.java (diff)
The file was modifiedservices/gateway/health/src/main/java/org/eclipse/ditto/services/gateway/health/ClusterStatusAndHealthHelper.java (diff)
The file was modifiedjson/src/main/java/org/eclipse/ditto/json/JsonCollectors.java (diff)
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingSupervisorActor.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/MessageFormatInvalidException.java (diff)
The file was modifiedservices/models/things/src/main/java/org/eclipse/ditto/services/models/things/commands/sudo/SudoRetrieveThingResponse.java (diff)
The file was modifiedservices/thingsearch/query/src/main/java/org/eclipse/ditto/services/thingsearch/query/actors/ParameterPredicateVisitor.java (diff)
The file was modifiedsignals/events/policies/src/main/java/org/eclipse/ditto/signals/events/policies/PolicyCreated.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/EventJsonDeserializer.java (diff)
The file was modifiedservices/thingsearch/persistence/src/main/java/org/eclipse/ditto/services/thingsearch/persistence/read/query/PolicyRestrictedMongoSearchAggregation.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/rql/RqlPredicateParserTest.java (diff)
The file was modifiedsignals/events/base/src/main/java/org/eclipse/ditto/signals/events/base/Event.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/scala/org/eclipse/ditto/model/thingsearchparser/parser/RqlPredicateParser.scala (diff)
The file was modifiedservices/gateway/util/src/main/java/org/eclipse/ditto/services/gateway/starter/service/util/ConfigKeys.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/things/ThingsRoute.java (diff)
The file was modifiedservices/policies/util/src/main/java/org/eclipse/ditto/services/policies/util/ConfigKeys.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPathBuilder.java (diff)
The file was modifiedservices/gateway/starter/src/main/java/org/eclipse/ditto/services/gateway/starter/GatewayRootActor.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/query/RetrieveThingsResponse.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNode.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/ThingErrorResponse.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/AbstractPolicyEnforcerActor.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNodeTest.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/NullFeatureDefinition.java (diff)
The file was modifiedservices/gateway/streaming/src/main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/ModifyThingHandlerActor.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/AbstractProtocolAdapter.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNode.java (diff)
The file was modifiedmodel/things/src/main/java/org/eclipse/ditto/model/things/NullFeatures.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/sse/SseThingsRoute.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/serializer/ThingMongoEventAdapter.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/utils/UriEncoding.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ThingModifyCommandResponseAdapter.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/MultiComparisonNodeTest.java (diff)
The file was modifiedservices/models/things/src/test/java/org/eclipse/ditto/services/models/things/CommandAndEventJsonExamplesProducer.java (diff)
The file was modifiedservices/gateway/endpoints/src/main/java/org/eclipse/ditto/services/gateway/endpoints/routes/websocket/WebsocketRoute.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/EnforcerLookupActor.java (diff)
The file was modifiedprotocol-adapter/src/main/java/org/eclipse/ditto/protocoladapter/ImmutableTopicPath.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/ModifyFeatureDefinition.java (diff)
The file was modifiedmodel/thingsearch-parser/src/main/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/SingleComparisonNode.java (diff)
The file was modifiedservices/gateway/proxy/src/main/java/org/eclipse/ditto/services/gateway/proxy/actors/handlers/CreateThingHandlerActor.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/serializer/PolicyMongoEventAdapter.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/HttpStatusCode.java (diff)
The file was modifiedmodel/thingsearch-parser/src/test/java/org/eclipse/ditto/model/thingsearchparser/predicates/ast/LogicalNodeTest.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff)
The file was modifiedbom/pom.xml (diff)
The file was modifiedsignals/events/things/src/main/java/org/eclipse/ditto/signals/events/things/ThingEventRegistry.java (diff)
Commit cf5d12b1bef953b87213127dfa5216f0b4d5db1b by Thomas Jaeckle
made RhinoJavaScriptPayloadMapper safer in sense of sandboxing
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff)
Commit f2ed7ef0ddf47384d643d4f3cd392513a75acee4 by yufei.cai
unify activity check for Things and Policies
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/policies/starter/src/main/resources/policies.conf (diff)
The file was modifiedservices/policies/util/src/main/java/org/eclipse/ditto/services/policies/util/ConfigKeys.java (diff)
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
The file was modifiedservices/things/starter/src/main/resources/things.conf (diff)
The file was modifiedservices/policies/persistence/src/test/resources/test.conf (diff)
Commit 25471d43a8493e67d6ee0c6acc83e294cf4d4ee8 by Philipp.Michalski
Moved processing logic from CommandProcessorActor to CommandProcessor
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit 7389cb114e08c54775d8edc9600b465fac98d6a9 by yufei.cai
schedule next activity check for persistence actor of deleted policy
after obligatory snapshotting
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/policies/persistence/src/main/java/org/eclipse/ditto/services/policies/persistence/actors/policy/PolicyPersistenceActor.java (diff)
Commit f24ec1cda8a3abc75c66c0931add09f882952a61 by dominik.guggemos
make sources and target optional, add reply target to configuration,
implement publishing of thing events, add nullable annotations
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionBuilder.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/package-info.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnectionBuilder.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/package-info.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff)
The file was addedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/package-info.java
Commit e2cbc54420183e37cbbe1439fb712cc591f165d3 by dominik.guggemos
fix compile errors, add license header
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
Commit 63b1e5ebb6fa96eeb72587d7a1d2333f8a276bc8 by dominik.guggemos
fix logback warning
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/resources/logback-test.xml (diff)
Commit c2877b7fd41414a9ff1b2464dd48c141614eb289 by Philipp.Michalski
Code sanitation
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ConverterTraceWrapper.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff)
Commit e599e218674ed52c553fef7d93fb4c4ed2d35856 by dominik.guggemos
move creation of consumers to JMSConnectionHandlingActor for better
error handling, add/clean up tests
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
Commit d8e7cda0d9270809414e9620a71287863a8527ef by Philipp.Michalski
Ignored tests for deprecated mapper classes
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff)
Commit ecb65772855479bd6ba7207d6cbe1a54fa753bf6 by dominik.guggemos
fix test
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff)
Commit bc7e08589ad57151248bba19663f01a11b0a3051 by dominik.guggemos
fix test
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/TestConstants.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
Commit 5edb71e49963ba3d1b51c501d25a80b709bfd25d by Philipp.Michalski
Fixed tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
Commit da9e0314269d63bc315900a7ec98485ee2022d2c by Philipp.Michalski
Ignored tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit 9ea3890b6ede24ca6c51f2d73bb261eed2f95178 by Philipp.Michalski
Fixed javadoc
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/persistence/ConnectionData.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionSupervisorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff)
Commit 8f2364d3af73f60df27de62cb1e191acfc3ceadf by dominik.guggemos
fix adding auth subject header to InternalMessage
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/utils/devops/src/main/java/org/eclipse/ditto/services/utils/devops/DevOpsCommandsActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
Commit 4ec6bdbd21f5d4eb6bb08e4fec76720fa7e5f7de by dominik.guggemos
respond to command after actor behaviour was changed (race condition)
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit 824a5de2bc4508a01c03cd321953dce4d4f3f3cb by Philipp.Michalski
Added merge logic for headers
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
Commit f85813613e1ceb47f79d2e1371fd9d043ef2acd3 by dominik.guggemos
add messageType to InternalMessage, handle InternalMessage based on
messageType in publisher actors
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionUriInvalidException.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActorTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpConnection.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit 64e1607998f4b847753079e247753fc3803a20a0 by dominik.guggemos
fix test
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff)
Commit a0686411248b01b02c32f306782f97550727fd9f by dominik.guggemos
fix javadoc
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
Commit 8564fc573abb9470aa2eee2c00d6c70a78eaf40a by Philipp.Michalski
Added convenience function for property access
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
Commit 8ea267b846b775e0c386f6992523d0bb2a70cc6e by dominik.guggemos
add MESSAGE and ERROR type to InternalMessage
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
Commit 7711e18834e2355786e638e6bbddc7d2e6391218 by Thomas Jaeckle
added some TODOs which occurred during review
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperOptions.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
Commit a4c8e45cde32e927b15d8c84616dab481183d35f by Thomas Jaeckle
updated used dependencies (akka, mongo-persistence)
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedbom/pom.xml (diff)
Commit 5a5c99ab0c6a45689649bd59dcc3478af6d60747 by Thomas Jaeckle
renamed InternalMessage to ExternalMessage, splitted up in interface +
impl, extracted builder
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was removedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/InternalMessage.java
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableExternalMessage.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was addedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableExternalMessageTest.java
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MutableExternalMessageBuilder.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessageBuilder.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
Commit 35beca1ddc2d58baccf4e73a59ea2594a2f2c38e by Thomas Jaeckle
review: added some javadoc; removed @Nullable where it was not nullable;
moved dependency management for rabbit client to bom
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/package-info.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/pom.xml (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JMSConnectionHandlingActor.java (diff)
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/JmsConnectionFactory.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/AmqpConnectionBasedRabbitConnectionFactory.java (diff)
Commit 2269801537b4d94937d63e8e8691866c6b11f4ec by Philipp.Michalski
Changed mapper configuration implementation
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperConfiguration.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperOptions.java
Commit d3036d08c5733e5548051143bbb3abf92377ecb7 by Philipp.Michalski
Changed default registry implementation and extracted interface
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperRegistry.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java
Commit 8ba272b8b8171acb7ca47a50c6350292bcf45962 by Philipp.Michalski
Generated equals and toString
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff)
Commit 4079cb0a5214d6909a95e14bb9ab7db78d4217cc by Philipp.Michalski
Changed mapper api
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperMapperOptions.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptPayloadMapperOptions.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperMapperOptions.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMessageMapperMapperOptions.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperOptions.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
Commit 3e257076527b6ff1d536df1e63e11e55df4582f0 by Philipp.Michalski
Adapted external message
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
Commit e869f95326e997e3520dad3112e968ab231a141a by Philipp.Michalski
Migrated javascript mappers to new api
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
Commit fb071b13f65bf813f62549d4db38a469723af7ba by yufei.cai
Include bulk update size in metrics
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff)
Commit ecac12a8ae7bebcfc06a77723b13074c93a719c4 by Thomas Jaeckle
changed JS mapper config to follow new naming and interfaces
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfigurationProperties.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperMapperOptions.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfiguration.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifieddocker/sandbox/nginx.conf (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java (diff)
The file was modifieddocker/nginx.conf (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperMapperOptions.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff)
Commit 932df7f6fa489cadda40e5a89d27ef4443e8bb2b by Philipp.Michalski
Removed old classes
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutableMessageMapperMapperOptions.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ImmutablePayloadMapperMessage.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapper.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMappers.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMessage.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff)
Commit 01c8ce1049c024e4eb7c1e8ac12ab9c1280c1bc5 by Philipp.Michalski
Adapted new interface
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
Commit e15a797a2e188aaf28f5affa19657590cb6d9fd2 by Thomas Jaeckle
got JS mapper working again
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperConfiguration.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MutableExternalMessageBuilder.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperMapperOptions.java
Commit 07d6870019c6bff32b87ce1216d6e25b83c6252c by Thomas Jaeckle
added missing copyright headers
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
Commit 3ed44671ca0b007c5522f3f263479feb41b2ec56 by yufei.cai
Limit size of bulk updates in ThingUpdater
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/thingsearch/starter/src/main/resources/things-search.conf (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingsUpdaterTest.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingsUpdater.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff)
The file was modifiedservices/thingsearch/common/src/main/java/org/eclipse/ditto/services/thingsearch/common/util/ConfigKeys.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/SearchUpdaterRootActor.java (diff)
Commit c52c84a7deec9bd198ea07322a744311efa0d383 by Philipp.Michalski
Added exceptions to interface
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperException.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/IllegalConfigurationException.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/NotYetConfiguredException.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
Commit a58d2faf246d13b746a6f7f61d7f756d609f37eb by Thomas Jaeckle
made "mappingContexts" in JSON optional in order to keep backward
compatible to DB
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedsignals/events/amqp-bridge/src/main/java/org/eclipse/ditto/signals/events/amqpbridge/ConnectionCreated.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnection.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/modify/CreateConnectionResponse.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionResponse.java (diff)
Commit 24b742ca154e06f4dfc49362e04b41fa1e9d1bda by Philipp.Michalski
Added javadoc for factory interface & serial for exceptions
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/IllegalConfigurationException.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperException.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/NotYetConfiguredException.java (diff)
Commit 81ca4357ac6acf2b5871a93b7d2483ac774eb3f3 by Philipp.Michalski
Added javadoc and sanitation
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/AbstractMessageMapper.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff)
Commit 2af38a55921deba8ae9f5cba940b5ce9fbc6b170 by Philipp.Michalski
Adapted to factory interface
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
Commit 6a8e773a67ca096b4af82e71136eadb1f2304d5e by yufei.cai
Move bulk update size metric from metadata to histogram
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff)
Commit 0290b764bf2171f72b2b983946e9a861148bccbc by Philipp.Michalski
Adapted mapper api changes
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit ef6e3c944ed78bbdb9de7c4bd3abc26e15bb4d01 by Stefan Maute
added new command category 'LIVE' for messages and live commands.
adapted command category for delete commands from MODIFY to DELETE.
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatures.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureDefinition.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteResource.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAclEntry.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/query/AbstractQueryLiveCommand.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/AbstractMessageCommand.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeletePolicyEntry.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/Command.java (diff)
The file was modifiedsignals/commands/policies/src/main/java/org/eclipse/ditto/signals/commands/policies/modify/DeleteSubject.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttribute.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteAttributes.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperty.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeatureProperties.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/things/src/main/java/org/eclipse/ditto/signals/commands/things/modify/DeleteFeature.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/base/AbstractLiveCommand.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandImpl.java (diff)
Commit e9173de40e2bfc0fdd4d68d2fc1c1d88f63b4ecb by Stefan Maute
scheduling a maintenanceSnapshot regularly (snapshot interval)
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff)
Commit 99d3cbc609ad0c30a5fbc6e55f7f2859e4a33242 by Philipp.Michalski
Added factory method for configuration
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
Commit 3c3ac58568b66c64b00e2969b1ef67e3fff18155 by Thomas Jaeckle
cleaned up JS mapper
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperSimpleTest.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfigurationProperties.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperSimpleTest.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfiguration.java (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperSimpleTest.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoContextFactory.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperBytesTest.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperSimpleTest.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptPayloadMapperFactory.java
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperBytesTest.java
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ProtocolToRawMapperBytesTest.java
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
The file was addedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperFactory.java
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/RhinoJavaScriptPayloadMapper.java
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperBytesTest.java
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperMustacheTest.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ImmutableJavaScriptMessageMapperConfiguration.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/PayloadMapperMustacheTest.java
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
Commit 6d92e00255df17ccd92d286b82302e0674f2fb18 by Thomas Jaeckle
fixed compile errors
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/thingsearch/persistence/src/test/java/org/eclipse/ditto/services/thingsearch/persistence/write/impl/MongoThingsSearchUpdaterPersistenceIT.java (diff)
Commit 020892f4dd223fa59f1ec116ef69d0cea3ffca45 by Philipp.Michalski
Temporary ignoring tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
Commit b46c7294381ec4395cd8494aa3e7bef3c9e2f69c by Philipp.Michalski
Adapted factory tests to new API
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/pom.xml (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff)
Commit c7193952a63b585ea6d54167ea9ccdd17ad3314f by Philipp.Michalski
Added test for content type check wrapper mapper
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was addedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java
Commit 158ae858e2ef88cbfb3d2d248f4207f6e38d4d62 by Philipp.Michalski
Adapted new mapper API in tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was removedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperTest.java
Commit afcb0645d7708a5b9ca73b160029245ce83005c9 by Thomas Jaeckle
improved error handling of message mapping (still not finished)
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/AmqpBridgeErrorRegistry.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionUriInvalidException.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ReconnectActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMappingFailedException.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
Commit c58db54d797e079fbe4157bc7512d83d85b92428 by Philipp.Michalski
Fixed bug: mapping of messages without content type
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
Commit 7ea4c45658ea9097a242f70045f41f18890d7f55 by dominik.guggemos
add test for receiving commands/sending events
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/TestConstants.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/BaseClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActor.java (diff)
Commit 17ada64495c27c2c2cc6891692db950165dd7019 by daniel.fesenmeyer
minor 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>
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/snapshotting/ThingSnapshotter.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActor.java (diff)
The file was modifiedservices/things/persistence/src/main/java/org/eclipse/ditto/services/things/persistence/actors/ThingPersistenceActorInterface.java (diff)
Commit e0721f0caa726cf067bf72aca3b13ba45735f338 by Philipp.Michalski
Adapted exception handling in tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff)
Commit 00a972112bee46e1146277b0e1d45e0fb6d1680f by daniel.fesenmeyer
add unit test which checks that sync is triggered when maxBulkSize is
exceeded
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdater.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/main/java/org/eclipse/ditto/services/thingsearch/updater/actors/SearchUpdaterRootActor.java (diff)
The file was modifiedservices/thingsearch/updater-actors/src/test/java/org/eclipse/ditto/services/thingsearch/updater/actors/ThingUpdaterTest.java (diff)
Commit ddea732f039d626f9fc036cc177f29d7406203ba by Thomas Jaeckle
further improved exception handling for mapping
* removed almost all IllegalStateExceptions
* made content-type required
* validate configuration
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMappingFailedException.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MockMapper.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/AmqpBridgeErrorRegistry.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperMustacheTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/test/java/org/eclipse/ditto/signals/commands/amqpbridge/TestConstants.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/NotYetConfiguredException.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperRegistry.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperBytesTest.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/IllegalConfigurationException.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MappingContext.java (diff)
The file was addedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMapperConfigurationInvalidException.java
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/PayloadMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff)
The file was modifiedsignals/events/amqp-bridge/src/test/java/org/eclipse/ditto/signals/events/amqpbridge/examplejson/JsonExamplesProducer.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
Commit a7c4c7ea86c4acf7bd3652d21c14bb6346b0e831 by Stefan Maute
delete 'Live' Category from command because it is not needed anymore.
Adapt category for modify and delete LiveCommands.
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertyLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertyLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/base/src/main/java/org/eclipse/ditto/signals/commands/base/Command.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturePropertiesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureDefinitionLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturePropertiesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeaturesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeaturesLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/messages/src/main/java/org/eclipse/ditto/signals/commands/messages/AbstractMessageCommand.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/base/AbstractLiveCommand.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteFeatureLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/query/AbstractQueryLiveCommand.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/DeleteAttributeLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/CreateThingLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyAttributeLiveCommandImpl.java (diff)
The file was modifiedsignals/commands/live/src/main/java/org/eclipse/ditto/signals/commands/live/modify/ModifyFeatureDefinitionLiveCommandImpl.java (diff)
Commit d898d611f30d785fd9708db79ce9f7ad5ce8e708 by dominik.guggemos
move replyTo header to ExternalMessage
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
Commit 07d2043da497b773986d5378c9745331c7b83d94 by Thomas Jaeckle
made 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>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableExternalMessage.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MutableExternalMessageBuilder.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/AbstractDittoHeaders.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/AmqpBridgeModelFactory.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/headers/DittoHeaders.java (diff)
The file was modifiedmodel/messages/src/main/java/org/eclipse/ditto/model/messages/ImmutableMessageHeaders.java (diff)
Commit 5767c4c9b20cf416b5fabb2b2538d3de35d21695 by Thomas Jaeckle
fixed tests
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperFactoryTest.java (diff)
Commit 34da389283ac08c83539d593d11b942eecdde628 by dominik.guggemos
fix AmqpPublisherActor
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
Commit 9aeb33e674cdfbaf08624aecba18a77229b5a404 by Thomas Jaeckle
mapped AMQP content-type which was missing
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
Commit aa05456972918cdbe6d2deaeed041f356f50ea74 by Thomas Jaeckle
fixed CommandConsumerActorTest
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was removedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActorTest.java
The file was addedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActorTest.java
Commit d002c1cfd424e8e8179fc9cedc50768a51e74cc2 by dominik.guggemos
stabilize AmqpClientActorTest
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/test/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpClientActorTest.java (diff)
Commit f0c7a253276c10d339ba32611e8ae37edc073b6c by Thomas Jaeckle
moved helper methods to MessageMappers
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DefaultMessageMapperFactory.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
Commit 4405f063911fd31cdb32e76abbb72b855bbbb061 by Thomas Jaeckle
cleaned up the constants mess
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/CommandConsumerActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperBytesTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/test/MappingContexts.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMappers.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapper.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was removedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfigurationProperties.java
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/DittoMessageMapperTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ExternalMessage.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/MessageMapperConfiguration.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/ProtocolToRawMapperSimpleTest.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
Commit c7cca938abef5640180c5a637d1cf66e2bb229e3 by Thomas Jaeckle
fixed MappingContext creation from JSON
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableMappingContext.java (diff)
Commit 31367b5ce13f916f9a9b9c3985df57337b61ed04 by dominik.guggemos
use akka dispatcher to process incoming jms messages
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/CommandConsumerActor.java (diff)
Commit 5461d34183cad3c7e538a22f85693b10d74282f1 by Thomas Jaeckle
fixed error in exception
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessorActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/MessageMappingFailedException.java (diff)
Commit 637ffb292e0608fab20f9818e98af47374a94d99 by Thomas Jaeckle
enhanced mapped messages with headers in
ContentTypeRestrictedMessageMapper
* allowed to send back empty payload for both amqp and rabbit
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapper.java (diff)
The file was modifiedmodel/base/src/main/java/org/eclipse/ditto/model/base/common/DittoConstants.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/CommandProcessor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
Commit c85ad314bbd0547104c20c48587a34f5071d3388 by dominik.guggemos
fix amqp uri when failover disabled
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
The file was modifiedmodel/amqp-bridge/src/test/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnectionTest.java (diff)
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ImmutableAmqpConnection.java (diff)
Commit ea85a02bd4bf368a857f9a83495bb06559c29dda by Thomas Jaeckle
update to Akka 2.5.11 which fixes rolling update issue
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedbom/pom.xml (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpPublisherActor.java (diff)
Commit 03b45af978adfb2893039ad85591f1490ebc61d6 by Thomas Jaeckle
fixed tests
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/mapping/src/test/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/ContentTypeRestrictedMessageMapperTest.java (diff)
The file was modifiedservices/amqp-bridge/mapping/src/main/java/org/eclipse/ditto/services/amqpbridge/mapping/mapper/javascript/JavaScriptMessageMapperRhino.java (diff)
Commit 4d38773a74051bf5410c5f8b37ae92a5945ba5a7 by Thomas Jaeckle
added ConnectionConflictException for when trying to create an already
existing connection
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was addedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/package-info.java
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/AmqpBridgeErrorRegistry.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionFailedException.java (diff)
The file was addedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionConflictException.java
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionNotAccessibleException.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/exceptions/ConnectionUnavailableException.java (diff)
Commit 0c39fe20531f3141c2c9eb4da3c0f0feeaee0750 by Thomas Jaeckle
fixed closing and re-opening RMQ connections
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/ConnectionActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQClientActor.java (diff)
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/rabbitmq/RabbitMQPublisherActor.java (diff)
Commit c7ee9d5e901178888480ac0261a13aa6b27b485d by dominik.guggemos
fix generation of amqp uri once more
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
Commit e9c38f8f073f080470600fe02c318aa9b5014bbd by dominik.guggemos
fix generation of amqp uri without failover
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
Commit 9daca335d261453ac8686bd095f9f167d7d64fb7 by dominik.guggemos
remove debugging code
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedservices/amqp-bridge/messaging/src/main/java/org/eclipse/ditto/services/amqpbridge/messaging/amqp/AmqpConnectionBasedJmsConnectionFactory.java (diff)
Commit ff639ee6febbdeb37d8594cd791358f11f06bd8c by dominik.guggemos
downgrade to qpid jms 0.26
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
The file was modifiedbom/pom.xml (diff)
Commit 87eedb52dabd4f2085a57edd32511bc65142fe29 by Thomas Jaeckle
fixed Snapshot serialization for ReconnectionActor
* improved exception handling + error reporting for RMQ client actor
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
The file was modifiedmodel/amqp-bridge/src/main/java/org/eclipse/ditto/model/amqpbridge/ConnectionStatus.java (diff)
The file was modifiedservices/amqp-bridge/starter/src/main/resources/amqp-bridge-dev.conf (diff)
The file was modifiedservices/utils/persistence/src/main/java/org/eclipse/ditto/services/utils/persistence/mongo/DittoBsonJson.java (diff)
The file was modifiedsignals/commands/amqp-bridge/src/main/java/org/eclipse/ditto/signals/commands/amqpbridge/query/RetrieveConnectionStatusResponse.java (diff)
The file was modified