NO-JIRA Remove unused call to get transport http headers
Unused call to transport getHttpHeaders left in code removed and cleaned
up the headers apply loop when filling in the Netty Default headers.
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyWsTransport.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyWsTransport.java
index 3da8784..52d4013 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyWsTransport.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/transports/netty/NettyWsTransport.java
@@ -19,7 +19,6 @@
import java.io.IOException;
import java.net.URI;
import java.nio.charset.StandardCharsets;
-import java.util.Map;
import org.apache.qpid.jms.transports.TransportListener;
import org.apache.qpid.jms.transports.TransportOptions;
@@ -135,10 +134,9 @@
public NettyWebSocketTransportHandler() {
DefaultHttpHeaders headers = new DefaultHttpHeaders();
- getTransportOptions().getHttpHeaders();
- for (Map.Entry<String, String> entry : getTransportOptions().getHttpHeaders().entrySet()) {
- headers.set(entry.getKey(), entry.getValue());
- }
+ getTransportOptions().getHttpHeaders().forEach((key, value) -> {
+ headers.set(key, value);
+ });
handshaker = WebSocketClientHandshakerFactory.newHandshaker(
getRemoteLocation(), WebSocketVersion.V13, AMQP_SUB_PROTOCOL,
