EnhancedMessageTypeKey add hash(), ChannelOutboundQueue change address to final and...

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / connection / ChannelOutboundQueue.java

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueue.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueue.java
index 6937a1fb004e8c2d1ed02ec0470813593e748300..cc7abcae4ab12f288df027b8cd49966f7069b56f 100644 (file)
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueue.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueue.java
@@ -96,9 +96,9 @@ final class ChannelOutboundQueue extends ChannelInboundHandlerAdapter {
     private final Queue<MessageHolder<?>> queue;
     private final long maxWorkTime;
     private final Channel channel;
-    private InetSocketAddress address;
+    private final InetSocketAddress address;
 
-    public ChannelOutboundQueue(final Channel channel, final int queueDepth) {
+    public ChannelOutboundQueue(final Channel channel, final int queueDepth, final InetSocketAddress address) {
         Preconditions.checkArgument(queueDepth > 0, "Queue depth has to be positive");
 
         /*
@@ -110,6 +110,7 @@ final class ChannelOutboundQueue extends ChannelInboundHandlerAdapter {
         this.queue = new LinkedBlockingQueue<>(queueDepth);
         this.channel = Preconditions.checkNotNull(channel);
         this.maxWorkTime = TimeUnit.MICROSECONDS.toNanos(DEFAULT_WORKTIME_MICROS);
+        this.address = address;
     }
 
     /**
@@ -276,8 +277,4 @@ final class ChannelOutboundQueue extends ChannelInboundHandlerAdapter {
     public String toString() {
         return String.format("Channel %s queue [%s messages flushing=%s]", channel, queue.size(), flushScheduled);
     }
-
-    public void setAddress(InetSocketAddress address) {
-        this.address = address;
-    }
 }