We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2f4f34d commit ca7c690Copy full SHA for ca7c690
test/src/test/groovy/org/openremote/test/custom/TeltonikaMQTTProtocolTest.groovy
@@ -507,7 +507,7 @@ class TeltonikaMQTTProtocolTest extends Specification implements ManagerContaine
507
String assetId = UniqueIdentifierGenerator.generateId(getTELTONIKA_DEVICE_IMEI());
508
int i = 0;
509
when: "the device starts publishing payloads"
510
- payloads.stream().forEach { Object payload ->
+ payloads.stream().limit(100).forEach { Object payload ->
511
// Your logic here, for example:
512
getLOG().debug(JsonOutput.toJson(payload));
513
0 commit comments