diff --git a/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/ReactivePacketProcessor.java b/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/ReactivePacketProcessor.java
deleted file mode 100644
index bc5d30a..0000000
--- a/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/ReactivePacketProcessor.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package org.onlab.onos.net.trivial.packet.impl;
-
-import static org.slf4j.LoggerFactory.getLogger;
-
-import org.onlab.onos.net.PortNumber;
-import org.onlab.onos.net.flow.Instructions;
-import org.onlab.onos.net.packet.PacketContext;
-import org.onlab.onos.net.packet.PacketProcessor;
-import org.slf4j.Logger;
-
-public class ReactivePacketProcessor implements PacketProcessor {
-
-    private final Logger log = getLogger(getClass());
-
-    @Override
-    public void process(PacketContext context) {
-        context.treatmentBuilder().add(Instructions.createOutput(PortNumber.FLOOD));
-        context.send();
-    }
-
-}
diff --git a/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/SimplePacketManager.java b/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/SimplePacketManager.java
index 95d3664..637ada8 100644
--- a/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/SimplePacketManager.java
+++ b/core/trivial/src/main/java/org/onlab/onos/net/trivial/packet/impl/SimplePacketManager.java
@@ -1,5 +1,6 @@
 package org.onlab.onos.net.trivial.packet.impl;
 
+import static com.google.common.base.Preconditions.checkNotNull;
 import static org.slf4j.LoggerFactory.getLogger;
 
 import java.util.Map;
@@ -42,22 +43,20 @@
 
     private final Map<Integer, PacketProcessor> processors = new TreeMap<>();
 
-    private final PacketProcessor reactiveProcessor = new ReactivePacketProcessor();
 
     @Activate
     public void activate() {
-        addProcessor(reactiveProcessor, PacketProcessor.ADVISOR_MAX + 1);
         log.info("Started");
     }
 
     @Deactivate
     public void deactivate() {
-        removeProcessor(reactiveProcessor);
         log.info("Stopped");
     }
 
     @Override
     public void addProcessor(PacketProcessor processor, int priority) {
+        checkNotNull(processor, "Processor cannot be null");
         processors.put(priority, processor);
     }