Changes

Summary

1. refactoring in order to enable using RQL filters for event filtering in (details)
2. fixed javadocs (details)
3. removed still remaining classes (details)
4. fixed bug in SseThingsRoute - was no longer working due to cast error (details)
5. fixed after merge from master (details)
6. fixed build after merge from latest "master" (details)
7. configure + apply event filter in connection targets (details)
8. fixed applying event filter in connection targets (details)
9. updated jjwt library to 0.10.1 (details)
10. use ditto-json instead of minimal-json + Ditto ConditionChecker (details)
11. worked in improvements suggested by @jufickel-b (details)
12. initial version of mqtt connectivity (details)
13. updated cqs.md (details)
14. let filter be specified by adding "?filter=..." to websocket protocol (details)
15. add mqtt[s] protocol to connections model; remove [:] from username (details)
16. fix compile error (details)
17. read provided username/password from configuration and apply to mqtt (details)
18. add protocol-specific config to connection source & target (details)
19. Connection: remove URI regexes & permit all valid URI at construction (details)
20. respond to metrics requests in mqtt actors (details)
21. fix unit tests after merge (details)
22. reduce unit test execution time (details)
23. avoid actor name conflicts when creating consumer/publisher actors in (details)
24. move URI scheme validation to protocol level (details)
25. initialize mqtt connection with default ssl context (details)
26. validate specific configs of MQTT sources and targets (details)
27. translate SocketFactoryExtension from scala to java (details)
28. use ssl context only for secure connections (details)
29. - move creation of MqttConnectionSettings to factory - add trust manager (details)
30. fix initialization of custom ssl context (details)
31. use async client in MQTT connection test to not block actor; use open (details)
32. increment message counters in MqttClientActor thread (details)
33. adjust formatting; enter moquette version in ditto-bom (details)
34. fix some sonar findings (details)
35. delete unused Connection.UriRegex (details)
36. validate configured mqtt topics (details)
37. split protocol-specific source & target validation; configure Mqtt (details)
38. set QoS in MqttPublisherActor & start streams as children in (details)
39. set QoS of MQTT-Subscribe messages by source config (details)
40. move MQTT sink stream to MqttPublisherActor; delay ClientConnected until (details)
41. fixed TODO in installation-operating.md - documenting the Prometheus (details)
42. fixed placeholder (details)
43. MqttClientActor: add javadoc & start 1 stream per source instead of per (details)
44. MqttClientActor: do not start stream if consumer count <= 0 (details)
45. fixes  - recovery of connection actors (send open instead of create)  - (details)
46. removed shortcut for acking event subscriptions as it was not working in (details)
47. test MqttValidator on target address with placeholder (details)
48. MqttConsumerActor: add back pressure by acknowledgement (details)
49. remove 'source' from reserved header list (details)
50. replace specificConfig in Source and Target with specific (details)
51. allow qos=2 for sources (test pending) (details)
52. apply enforcement of thing id after payload mapping, added new exception (details)
53. improve logging of unresolved placeholders (details)
54. clean up, javadoc (details)
55. fix docker-compose.yml for sandbox by adding max memory to be used (details)
56. made sandbox more robust (details)
57. fix ImmutableExternalMessageTest (details)
58. fix incorrect I.MqttSource constructor call due to overloading (details)
59. disable binary compatibility check for now (details)
60. ConnectionActor: don't flush pending ACK messages on signal arrival (details)
61. rename ImmutableExternalMessage to UnmodifiableE.M. and document correct (details)
62. ReconnectActor: stop pinging corrupted & nonexistent connections (details)
63. replaced deprecated class JavaConversions with JavaConverters; adapt (details)
64. add InternalRetrieveStatistics command to report Hot Entities to (details)
65. unify required docker & docker-compose versions (details)
66. Replaced "unknown" Policy SubjectType with "generated" as the default if (details)
67. Reviewed JjwtDeserializer (details)
68. fix unintended disconnect of freshly created connections (details)
69. give MQTT source default QOS=0 for convenience; improve comment (details)
70. corrected wrongly renamed javadoc (details)
71. unify connection establishment and testing; removed 1 deadletter from (details)
72. fixed unit test (details)
73. add Target.withAddress; remove unnecessary collection of responses in (details)
74. MQTT: remove moquette dependency & dead code; increment message counters (details)
75. validate MQTT source topic filters (details)
76. fixed errors after last merge from master (details)
77. optimized imports (details)
78. MQTT: fix TODOs (details)
79. optimized imports (details)
80. reduced max. message size in cluster to 128 KiB (details)
81. make ask timeout a constant (details)
82. fixed javadoc (details)
83. fixed Search response which was in wrong format after modifications (details)
84. fixed corner cases - selecting _policy in fieldselector + classcast (details)
85. fixed NPE in stream (details)
86. reduced max parallelism to 20 (details)
87. fixed concurrent thingId pattern matching (details)
88. fixed that exceptions in search were not returned (details)
89. fixed toJson of thing in QueryThingsPerRequestActor (details)
90. fixed result production in QueryThingsPerRequestActor (details)
91. added ditto-limits.conf where entity sizes and max paging sizes are (details)
92. added exceptions for when entity gets too large (details)
93. fixed tests (details)
94. deleted non-useful test (details)
95. added unit tests for testing size limitation on: * modify commands * (details)
96. correctly set the DittoHeaders when throwing *TooLargeExceptions (details)
97. made remote sizes configurable via environment variables (details)
98. fixed error handling for live messages + improved thingId calculation (details)
99. Introduced max size guard function for message, policy and things modify (details)
100. Moved size checking logic from command interfaces into dedicated classes (details)
101. added javadoc (details)
102. fixed WebsocketRoute error building which threw exceptions (details)
103. fixed some issues after review (details)
104. added "namespaces" filter for websocket, SSE, connectivity (details)
105. MQTT: remove RestartSource because auto-reconnect of Paho should be (details)
106. fix connectivity.conf (details)
107. fixed applying namespace filter in WebsocketRoute * and fixed (details)
108. fixed imports after merge from master (details)
109. document MQTT 3.1.1 connections (details)
110. improved readability (details)
111. set default qos of MQTT source to 2 so that Ditto get all messages (details)
112. reviewed Ditto MQTT docu (details)
113. fix timeout retrieving metrics of connections with empty source or (details)
114. fix MqttClientActorTest (details)
115. improve error message of topic filter mismatch; do not disclose topic (details)
116. added URL decoding for "namespaces" and "filter" params on Websocket and (details)
117. added documentation about namespace and RQL expression based filtering (details)
118. fix jekyll errors (details)
119. document that events are not published on origin connection (details)
120. added some tests for model classes (details)
121. improve description of no-same-origin policy (details)
122. Reconnect all known open connections in a configurable interval. (details)
123. Include stack trace of exception in the log message if something bad (details)
124. add conditional-headers ("If-Match" and "If-None-Match") and "ETag" to (details)
125. [wip] provide hooks for custom extensions for the ditto gateway - add (details)
126. Merge remote-tracking branch 'remotes/origin/master' into (details)
127. Merge remote-tracking branch 'remotes/origin/master' into (details)
128. fail fast (on application startup) if required protocol-parameters are (details)
129. Appends ETag header to command responses that contain entities (details)
130. just improve variable naming (details)
131. add debug-logging for header-translation (details)
132. minimal logging improvement (details)
133. fix: always make the headers of the websocket-upgrade-request available (details)
134. exclude "false positive" methods from binary-compatibility-check: they (details)
135. remove redundancy in poms: move common configuration of (details)
136. Adds ETag Header to policies and subresources of policies (details)
137. Adds unit tests for ETagValueGenerator (details)
138. just add missing license headers (details)
139. reduce (build-)dependencies of module (details)
140. minor code improvement: follow "same level of abstraction" rule (details)
141. Remove Nonnull annotation in DittoHeaderDefinition (details)
142. Update version of maven surefire plugin to 2.22.0 (details)
143. Bring back toInlinedJson method to not break the api (details)
144. Adds ifMatch and ifNoneMatch to DittoHeadersBuilder (details)
145. Renames GatewayAuthenticationDirectiveBuilder and appends JavaDoc (details)
146. minor: centralize dependency to ETagValueGenerator in (details)
147. [wip] prepare conditional-headers check: calculate the ETag always based (details)
148. [wip] add method Entity#isDeleted and implement it in all Entity (details)
149. implement method toString() in DittoRuntimeException for easier error (details)
150. fix unit tests: - add assertion helper methods in (details)
151. extract CreateThingStrategy from ThingPersistenceActor in order to (details)
152. minor: improve toString() of ResultFactoryMutationResult (details)
153. [wip] prepare conditional-headers check for policies: calculate the ETag (details)
154. Adds validation of If-None-Match and If-Match headers (details)
155. Adds prefixes hash: and rev: for entityTagValue (details)
156. provide the ETag as Http response header - use HeaderTranslator to map (details)
157. add conditional headers "If-Match" and "If-None-Match" to (details)
158. extend OpenAPI doc for api v2: - document ETag - conditional-headers (details)
159. fix typo (details)
160. add "Conditional Requests" section to HTTP API Concepts (details)
161. add "Conditional Headers" to Ditto Protocol specification, add links to (details)
162. Finished handling of if-match and if-none-match header for things (details)
163. centralize both logging and completion of DittoRuntimeException in (details)
164. adjust HTTP API Concepts according to the review of our technical writer (details)
165. provide a single, easy-to-use instance of the "*" entity-tag value (details)
166. Don't allow quotes around the asterisk for entity-tag (details)
167. Remove headersContainConditionalHeaders method (details)
168. Allows PreconditionHeader to match a generic type (details)
169. Returns 404 for entities that does not exist in case of query or delete (details)
170. Extracts building of precondition exceptions to methods (details)
171. fix typo (details)
172. Reverts chaining of optionals (details)
173. Converts generated hashCode to hex string (details)
174. Adds generic parameters to avoid suppressing unchecked warning (details)
175. just variable naming and Javadoc (details)
176. remove incomplete, unnecessary detailed Javadoc (details)
177. javadoc only (details)
178. renamed exceptions ThingPreconditionFailed and (details)
179. make sure that DittoHeaderInvalidException can be (de)serialized in the (details)
180. several improvements: - make EntityTag immutable, add tests for equality (details)
181. Introduces EntityTagMatchers instead of EntityTags (details)
182. Extracts logic for conditional header checking to separate class (details)
183. Change line break behaviour for the following templates: (details)
184. Removed header description for post request to /things (details)
185. minor: align exception message with other exception message which spell (details)
186. move logic for conditional headers validation to class (details)
187. add conditional headers validation to policies root resource and (details)
188. add test for PoliciesConditionalHeadersValidatorProvider (details)
189. add basic test for ConditionalHeadersValidator, mark it as @Immutable (details)
190. add missing license header (details)
191. add some missing ETag response headers (details)
192. extend OpenAPI doc for api v1: - document ETag - conditional-headers (details)
193. add missing 412 response for "Delete thing" (details)
194. improve indentation (details)
195. add missing if(-none)-match headers for ACL resources (details)
196. add simple toString() method to AbstractDittoHeadersBuilder, enhance (details)
197. add some debug-logging to WebSocketRoute: log the actual incoming (details)
198. make if-match and if-none-match writable to external headers (otherwise (details)
199. Removes precondition headers for inline policy in (details)
200. revert previous commit (make if-match and if-none-match writable to (details)
201. bugfix: don't apply the command when conditional-headers-validation (details)
202. Remove $ref in response headers (details)
203. fix copy-paste-error: ETag type is "string", not "string'" (details)
204. fix some sonar issues (details)
205. connectivity: add optional X.509 credentials to connections (details)
206. physically delete Things from search index after configurable age (details)
207. enable consuming and publishing for RabbitMQ connections after a (details)
208. pass authorizationContext to CustomHeadersHandler to allow (details)
209. move CA as field of Connection; rename X509Credentials to (details)
210. add SSLContextCreator (details)
211. use SSLContextCreator for MQTT and RabbitMQ (details)
212. Actually log stack trace. Some code formatting. (details)
213. set SSLContext for AMQP 1.0; cleanup SSLContextCreatorTest (details)
214. upgrade to qpid JMS 0.36.0 (details)
215. fixed errors after merge from master (details)
216. enhance CorsEnablingDirective to also add "Access-Control-Allow-Headers" (details)
217. Added info about URL encoding of filter params (details)
218. changed order in SignalFilter to be more efficient (details)
219. changed order in SignalFilter to be more efficient (details)
220. add server identity verification (details)
221. document certificate exact-match as identity proof (details)
222. treat empty username and password as "anonymous" login (details)
223. moved Gemfile (details)
224. improved filter examples (details)
225. refactored RQL related stuff from ditto-model-thingsearch-parser into (details)
226. Connectivity: add revocation check when trusting public CAs (details)
227. connectivity: document TLS features (details)
228. fix jekyll error (details)
229. validate RQL expressions at WebSocket/SSE/Connectivity and return error (details)
230. be as strict as Paho about MQTT URI (details)
231. fix comparing different data types with each other (details)
232. added correct DittoHeaders when throwing RQL parser exceptions (details)
233. added "not" to RQL query documentation as it is supported in filters (details)
234. incorporate feedback by marianne-klein <marianne.klein@bosch-si.com> (details)
235. set expiration of test certs to 01.01.2100 & improve descriptions (details)
236. moved RqlParserException to ditto-model-base as too many other modules (details)
237. BaseClientActor: add meaningful message to status for reporting (details)
238. allow wildcards (like *.eclipse.org) in certificates, use unique aliases (details)
239. RabbitMQClientActorTest: do not match the exact exception (details)
240. DittoTrustManager: remove unused method; handle 0-length names in server (details)
241. warn about aws-iot certificate expiration (details)
242. use HostnameChecker from jdk to verify hostnames (details)
243. SSLContextCreator: strip ipv6 brackets in URI; test RFC-6105 ss. 6.4.4 (details)
244. Started blogpost (details)
245. Finished message filter blogpost (details)
246. extended blogpost with example (details)
247. reviewed blogpost and adjusted a little, changed publishing date (details)
248. renamed images to match blog prefix (details)
249. fixed navbar logo css strangeness (details)
250. Made PolicyEntriesRoute final. Adjusted some formatting. (details)
251. enhance extensibility of EnforcerRetriever (details)
252. allow ActorAskCacheLoader to use PubSub (details)
253. added script for determining used maven plugins (details)
254. fixed markdown table (details)
255. also report errors during enforcement that are thrown inside the (details)
256. added NOTICE.md and legal/ directory containing NOTICE-THIRD-PARTY.md (details)
257. added NOTICE.md and legal/ directory containing NOTICE-THIRD-PARTY.md (details)
258. moved deployment related stuff (docker, kubernetes) to deployment/ (details)
259. fixed OSGi bundle inclusion of META-INF/* resource files (details)
260. added ditto logos symbolonly and textonly (details)
261. fixed "copy-legal-docs" dependency-plugin execution (details)
262. undid making NOTICE.md a symlink again (details)
263. delete NOTICE.md (details)
264. delete LICENSE symlink (details)
265. added NOTICE.md (details)
266. added LICENSE (details)
267. updated architecture and protocol images (details)
268. fix creation of new connection from another instance, add test to verify (details)
269. deleted duplicated third-party-file.ftl (details)
270. updated rabbitmq amqp-client to 5.4.2 (details)

refactoring in order to enable using RQL filters for event filtering in
the backend
* moved services-thingsearch-query-model to model-query (removed all
non-model dependencies)
* removed Bson dependencies from model
* added a default Predicate<Thing> based implementation
"ThingPredicateVisitor"
* added unit tests for testing this implementation
* added to StreamingSessionActor that an "eventFilter" may be specified
in order to filter events
* used in both WebsocketRoute and SseThingsRoute
* enhanced DummyAuthenticationProvider in order to specify dummy-auth
also as HTTP query param
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

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

removed still remaining classes
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed bug in SseThingsRoute - was no longer working due to cast error
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed after merge from master
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed build after merge from latest "master"
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

configure + apply event filter in connection targets
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed applying event filter in connection targets
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

updated jjwt library to 0.10.1
* implemented own jjwt serializer and deserializer using minimal-json in
order to get rid of jackson dependency
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

use ditto-json instead of minimal-json + Ditto ConditionChecker
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

worked in improvements suggested by @jufickel-b
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

initial version of mqtt connectivity
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

updated cqs.md
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

let filter be specified by adding "?filter=..." to websocket protocol
msg
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

add mqtt[s] protocol to connections model; remove [:] from username
regex
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fix compile error
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

read provided username/password from configuration and apply to mqtt
connection
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

add protocol-specific config to connection source & target
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

Connection: remove URI regexes & permit all valid URI at construction
time
Protocol-specific URI validations should be performed elsewhere.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

respond to metrics requests in mqtt actors
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

fix unit tests after merge
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

reduce unit test execution time
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

avoid actor name conflicts when creating consumer/publisher actors in
MqttClientActor
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

move URI scheme validation to protocol level
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

initialize mqtt connection with default ssl context
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

validate specific configs of MQTT sources and targets
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

translate SocketFactoryExtension from scala to java
Reason: It confused Maven.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

use ssl context only for secure connections
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

- move creation of MqttConnectionSettings to factory - add trust manager
that accepts any certificate for testing purposes - send OpenConnection
instead CreateConnection on recovery
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

fix initialization of custom ssl context
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

use async client in MQTT connection test to not block actor; use open
port in testTestConnectionFails
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

increment message counters in MqttClientActor thread
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

adjust formatting; enter moquette version in ditto-bom
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fix some sonar findings
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

delete unused Connection.UriRegex
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

validate configured mqtt topics
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

split protocol-specific source & target validation; configure Mqtt
consumers by QoS of sources
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

set QoS in MqttPublisherActor & start streams as children in
MqttClientActor
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

set QoS of MQTT-Subscribe messages by source config
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

move MQTT sink stream to MqttPublisherActor; delay ClientConnected until
publisher stream is ready
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fixed TODO in installation-operating.md - documenting the Prometheus
keys
* set the binary compatibility version to the released 0.8.0-M1
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed placeholder

MqttClientActor: add javadoc & start 1 stream per source instead of per
consumer
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

MqttClientActor: do not start stream if consumer count <= 0
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fixes  - recovery of connection actors (send open instead of create)  -
opening amqp 0.9.1 connections without a publisher (NPE)
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

removed shortcut for acking event subscriptions as it was not working in
cluster
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

test MqttValidator on target address with placeholder
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

MqttConsumerActor: add back pressure by acknowledgement
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

remove 'source' from reserved header list
Reason: DittoHeaderDefinition.SOURCE is readable and writable, hence not
reserved.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

replace specificConfig in Source and Target with specific
implementations for MQTT sources and targets
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

allow qos=2 for sources (test pending)
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

apply enforcement of thing id after payload mapping, added new exception
for failed enforcements
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

improve logging of unresolved placeholders
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

clean up, javadoc
Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>

fix docker-compose.yml for sandbox by adding max memory to be used
* updated to released openj9 image
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

made sandbox more robust
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fix ImmutableExternalMessageTest
- fixed 'testHashCodeAndEquals'
- ignored 'assertImmutability' until it is fixed
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fix incorrect I.MqttSource constructor call due to overloading
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

disable binary compatibility check for now
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

ConnectionActor: don't flush pending ACK messages on signal arrival
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

rename ImmutableExternalMessage to UnmodifiableE.M. and document correct
usage
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

ReconnectActor: stop pinging corrupted & nonexistent connections
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

replaced deprecated class JavaConversions with JavaConverters; adapt
several log levels
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>

add InternalRetrieveStatistics command to report Hot Entities to
Prometheus
Signed-off-by: Stefan Maute <stefan.maute@bosch-si.com>

unify required docker & docker-compose versions
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

Replaced "unknown" Policy SubjectType with "generated" as the default if
none specified
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

Reviewed JjwtDeserializer
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

fix unintended disconnect of freshly created connections
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

give MQTT source default QOS=0 for convenience; improve comment
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

corrected wrongly renamed javadoc
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

unify connection establishment and testing; removed 1 deadletter from
ConnectionActor
ConnectionActor
- Cancel STOP_SELF_IF_DELETED post-stop
BaseClientActor
- Accept only Status.Status as test connection result if it
 is sent from self
Mqtt
- Add dryRun mode to publisher and subscriber actors
- Instead of starting a new Paho client, start publishers and
 subscribers in dryRun mode to test the connection. Thus is
 test result consistent with normal operation.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fixed unit test
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

add Target.withAddress; remove unnecessary collection of responses in
ConnectionActor
Instead of collecting pending responses and flush them in one go, 
schedule the responses with fixed delay.
Reason: Sending CreateConnectionResponse on arrival of first event is
not correct because pub/sub may not be distributed on all cluster nodes.
Thus all responses are sent after fixed delay, obviating their retention
outside the scheduler.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

MQTT: remove moquette dependency & dead code; increment message counters
regardless of state
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

validate MQTT source topic filters
Also verified that Alpakka sources work with QoS 2.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

fixed errors after last merge from master
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

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

MQTT: fix TODOs
- Source buffer size is configured via ConnectionConfigReader.mqtt().
- Source is wrapped in RestartSource when failover is enabled.
Signed-off-by: Cai Yufei (INST/ECS1) <yufei.cai@bosch-si.com>

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

reduced max. message size in cluster to 128 KiB
* adjusted ThingsAggregatorActor accordingly so that it streams single 
things over the network instead of creating messages containing all the 
things
* changed search so that search only always returns found thingIds, 
retrieve the things in gateway as a follow-up
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

make ask timeout a constant
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

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

fixed Search response which was in wrong format after modifications
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed corner cases - selecting _policy in fieldselector + classcast
exception for exceptions instead of commandResponses
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>