From 1b38713024d2eef4e9babed8396c258c62728e44 Mon Sep 17 00:00:00 2001
From: awildturtok <1553491+awildturtok@users.noreply.github.com>
Date: Mon, 22 Jan 2024 15:38:51 +0100
Subject: [PATCH] fixes usage of outputStreams

---
 .../messages/network/specific/ForwardToWorker.java    | 11 ++---------
 1 file changed, 2 insertions(+), 9 deletions(-)

diff --git a/backend/src/main/java/com/bakdata/conquery/models/messages/network/specific/ForwardToWorker.java b/backend/src/main/java/com/bakdata/conquery/models/messages/network/specific/ForwardToWorker.java
index 2ab6246667..c118778fb8 100644
--- a/backend/src/main/java/com/bakdata/conquery/models/messages/network/specific/ForwardToWorker.java
+++ b/backend/src/main/java/com/bakdata/conquery/models/messages/network/specific/ForwardToWorker.java
@@ -1,9 +1,6 @@
 package com.bakdata.conquery.models.messages.network.specific;
 
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
 import java.io.IOException;
-import java.io.OutputStream;
 import java.util.Objects;
 
 import com.bakdata.conquery.io.cps.CPSType;
@@ -58,15 +55,11 @@ public static ForwardToWorker create(WorkerId worker, WorkerMessage message, Obj
 
 	@SneakyThrows(IOException.class)
 	private static byte[] serializeMessage(WorkerMessage message, ObjectWriter writer) {
-		try (OutputStream outputStream = new ByteArrayOutputStream()) {
-			writer.writeValue(outputStream, message);
-		}
-
-		return new ByteArrayOutputStream().toByteArray();
+		return writer.writeValueAsBytes(message);
 	}
 
 	private static WorkerMessage deserializeMessage(byte[] messageRaw, ObjectMapper mapper) throws java.io.IOException {
-		return mapper.readerFor(WorkerMessage.class).readValue(new ByteArrayInputStream(messageRaw));
+		return mapper.readerFor(WorkerMessage.class).readValue(messageRaw);
 	}
 
 	@Override