Initial framework migration to netty.

[bgpcep.git] / pcep / testtool / src / main / java / org / opendaylight / protocol / pcep / testtool / Main.java

diff --git a/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/Main.java b/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/Main.java
index 7bd16b0137a84a6d52da30fe5889536c4c1873fb..2ec8987b5a4f2d2caf96a0c8de60fd648ab1849e 100644 (file)
--- a/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/Main.java
+++ b/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/Main.java
@@ -7,6 +7,10 @@
  */
 package org.opendaylight.protocol.pcep.testtool;
 
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+
 import org.opendaylight.protocol.framework.DispatcherImpl;
 import org.opendaylight.protocol.pcep.PCEPConnection;
 import org.opendaylight.protocol.pcep.PCEPConnectionFactory;
@@ -18,14 +22,10 @@ import org.opendaylight.protocol.pcep.PCEPSessionProposalCheckerFactory;
 import org.opendaylight.protocol.pcep.PCEPSessionProposalFactory;
 import org.opendaylight.protocol.pcep.impl.PCEPConnectionImpl;
 import org.opendaylight.protocol.pcep.impl.PCEPDispatcherImpl;
+import org.opendaylight.protocol.pcep.impl.PCEPMessageFactory;
 import org.opendaylight.protocol.pcep.impl.PCEPSessionProposalCheckerFactoryImpl;
 import org.opendaylight.protocol.pcep.impl.PCEPSessionProposalFactoryImpl;
 
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.InetSocketAddress;
-import java.util.concurrent.Executors;
-
 public class Main {
 
        public static String usage = "DESCRIPTION:\n" + "\tCreates a server with given parameters. As long as it runs, it accepts connections "
@@ -140,7 +140,7 @@ public class Main {
 
                final PCEPSessionProposal prefs = spf.getSessionProposal(address, 0);
 
-               final DispatcherImpl d = new DispatcherImpl(Executors.defaultThreadFactory());
+               final DispatcherImpl d = new DispatcherImpl(new PCEPMessageFactory());
                final PCEPDispatcherImpl dispatcher = new PCEPDispatcherImpl(d, spf);
 
                try {
@@ -169,7 +169,7 @@ public class Main {
 
                } finally {
                        ((PCEPSessionProposalCheckerFactoryImpl) spcf).close();
-                       d.stop();
+                       // d.stop();
                }
        }
 }