this.consumerFaultCounter = 0;
}
+ @SuppressWarnings("java:S1172")
public void handleException(Throwable t) {
++this.consumerFaultCounter;
}
private void sendLastStoredRecord() {
String data = "{}";
- FilteredData output = new FilteredData(this.jobGroup.getType().getId(), null, data.getBytes());
+ FilteredData output = new FilteredData("", this.jobGroup.getType().getId(), null, data.getBytes());
sendToClient(output).subscribe();
}
gzip.flush();
gzip.close();
byte[] zipped = out.toByteArray();
- return new FilteredData(data.infoTypeId, data.key, zipped, true);
+ return new FilteredData(data.getSourceName(), data.infoTypeId, data.key, zipped, true);
} catch (IOException e) {
logger.error("Unexpected exception when zipping: {}", e.getMessage());
return data;