Issue eclipse-ditto/ditto#792: re-added "declared-acks" to DittoHeade…

…rDefinition Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Oct 6, 2020 · 3e72f06 · 3e72f06
1 parent 3321981
commit 3e72f06
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/main/java/org/eclipse/ditto/client/messaging/internal/WebSocketMessagingProvider.java b/...src/main/java/org/eclipse/ditto/client/messaging/internal/WebSocketMessagingProvider.java
@@ -46,8 +46,8 @@
 import org.eclipse.ditto.json.JsonCollectors;
 import org.eclipse.ditto.json.JsonValue;
 import org.eclipse.ditto.model.base.acks.AcknowledgementLabel;
-import org.eclipse.ditto.model.base.common.DittoConstants;
 import org.eclipse.ditto.model.base.common.HttpStatusCode;
+import org.eclipse.ditto.model.base.headers.DittoHeaderDefinition;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -192,7 +192,7 @@ private WebSocket createWebsocket() {
                     .collect(JsonCollectors.valuesToArray())
                     .toString();
             ws = webSocketFactory.createSocket(messagingConfiguration.getEndpointUri())
-                    .addHeader(DittoConstants.WEBSOCKET_SESSION_HEADER_DECLARED_ACKS, declaredAcksJsonArrayString);
+                    .addHeader(DittoHeaderDefinition.DECLARED_ACKS.getKey(), declaredAcksJsonArrayString);
         } catch (final IOException e) {
             throw MessagingException.connectFailed(sessionId, e);
         }