Changes

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)

unified snapshot adapters, implemented hook for successful snapshots
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

fixed compile error in ConnectionActor
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

move snapshotSuccessFunctions into AbstractMongoSnapshotAdapter
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

fix test-compile errors
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Rename Health-related classes to prepare for simplification
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Make Health messages generic and extensible in health components
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Fix MappingStrategiesBuilderTest
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Document Health
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Add method to retrieve specific component health statuses.
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

fix Health serialization
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

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>

make index-initialization optional for thingsearch (as it was possible
before the latest changes)
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>

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>

add method BsonUtil#getDocumentWithDefaultAt which circumvents problems
with (Mongo-)Document#get(Object, Object)
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>

simplify signature of BsonUtil#getDocumentWithDefaultAt
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>

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>

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>

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>

added possibility to map raw payloads
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

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>

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>

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>

made mapping template string optional
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

initial step integrating rabbitmq brigde into amqp bridge
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

remove duplicate file
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

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>

renamed MappingScript interface to MappingContext
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

adapt response code for fire and forget messages
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>

Update pom.xml
Excluded package for JSR305-annotation from OSGi imports as this
annotations are not required at runtime.

fix duplicate creation of command processor
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

Fixed amqp bridge unit tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

Fixed amqp bridge unit tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

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>

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>

fixed typo

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>

reduced sandbox deployment
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

rewrite ditto section with code samples
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

further polishing of virtualIoT meetup slides
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed changed behavior in ImmutableFeatures.toJson
back to previous behavior

fixed missing import

adjusted release notes for 0.2.0-M1, made slides "fragments"
configurable
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

adjusted release notes for 0.2.0-M1, made slides "fragments"
configurable
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

wrote 0.2.0-M1 blogpost announcement
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

wrote 0.2.0-M1 blogpost announcement
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed typo
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed typo
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed example json

fixed example json

fixed example json in doc

fixed example json in doc

updated binary-compatibility-check.version
to 0.2.0-M1

updated binary-compatibility-check.version
to 0.2.0-M1

New PayloadMapper factory and tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

Adopted local mappers for testing
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

Mappers licence header
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

switched to OpenJ9-openjdk9 alpine base image for Ditto + Things
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

try using openjdk8-openj9 instead of jdk9
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

removed weird argument
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

added "-Xtune:virtualized" openj9 param
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

adjusted openj9 baseimage to fixed version; introduced "cpus" limit in
docker compose
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

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>

Changed internal message, added documentation
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

change to actor based hierarchy because of issues with JMS client
(blocking)
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

New default ditto protocol mapper
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

javadoc, logging, small improvements
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

adjusted ditto startup settings
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Implemented mapping in CommandProcessorActor
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

rename connectionActor to clientActor to avoid confusion
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

New protocol mapper tests
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

adjusted dispatcher configuration and default-dispatcher to be more
moderate
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

adjusted dispatcher configuration
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

minor logging fix: parameter "collectionName" was missing in debug
output
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>

minor logging fix: parameter "collectionName" was missing in debug
output
Signed-off-by: Daniel Fesenmeyer <daniel.fesenmeyer@bosch-si.com>

deprecate Event.JsonFields.ID, serialize Event.JsonFields.TYPE
unconditionally
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

deprecate Event.JsonFields.ID, serialize Event.JsonFields.TYPE
unconditionally
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Internal message knows its type, mapper changed to guava converter api
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

copyright
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

add sensible defaults for burst size and batching to
AbstractStreamingActor
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>

Adapted tests to changed mapper api; added docs and comments
Signed-off-by: Philipp Michalski <Philipp.Michalski@bosch-si.com>

add Command.Category to classify all commands
Signed-off-by: Yufei Cai <Yufei.Cai@bosch-si.com>