// Path: src/main/java/com/neverwinterdp/sparkngin/NullDevMessageForwarder.java
// public class NullDevMessageForwarder implements MessageForwarder {
//   private boolean dump = false ;
//   private int count ;
//   private Throwable error ;
//   
//   
//   public NullDevMessageForwarder() {
//   }
//   
//   public NullDevMessageForwarder(Map<String, String> props) {
//     dump = MapUtil.getBool(props, "forwarder.nulldev.dump", false) ;
//   }
//   
//   public boolean hasError() { return error != null ; }
//   
//   public void setError(Throwable error) { this.error = error ; }
//   
//   public boolean reconnect() { 
//     error = null ;
//     return true ; 
//   }
//   
//   public int getProcessCount() { return count ; }
//   
//   public void forward(Message message) {
//     count++ ;
//     dump(message) ;
//   }
//   
//   public void dump(Message message) {
//     if(!dump) return ;
//     System.out.println(JSONSerializer.INSTANCE.toString(message.getHeader()));
//     try {
//       Class<?> type = Class.forName(message.getData().getType()) ;
//       Object object = message.getData().getDataAs(type) ;
//       System.out.println(JSONSerializer.INSTANCE.toString(object));
//     } catch (ClassNotFoundException e) {
//       e.printStackTrace();
//     }
//   }
//   
//   public void close() {
//   }
// }


import com.neverwinterdp.netty.http.HttpServer;
import com.neverwinterdp.netty.http.StaticFileHandler;
import com.neverwinterdp.sparkngin.NullDevMessageForwarder;
import com.neverwinterdp.sparkngin.Sparkngin;
import com.neverwinterdp.util.FileUtil;
import com.neverwinterdp.yara.MetricRegistry;

package com.neverwinterdp.sparkngin.http;

/**
 * @author Tuan Nguyen
 * @email  tuan08@gmail.com
 */
public class SparknginServer {
  static {
    System.setProperty("log4j.configuration", "file:src/main/resources/log4j.properties") ;
  }


// Path: src/main/java/com/neverwinterdp/sparkngin/NullDevMessageForwarder.java
// public class NullDevMessageForwarder implements MessageForwarder {
//   private boolean dump = false ;
//   private int count ;
//   private Throwable error ;
//   
//   
//   public NullDevMessageForwarder() {
//   }
//   
//   public NullDevMessageForwarder(Map<String, String> props) {
//     dump = MapUtil.getBool(props, "forwarder.nulldev.dump", false) ;
//   }
//   
//   public boolean hasError() { return error != null ; }
//   
//   public void setError(Throwable error) { this.error = error ; }
//   
//   public boolean reconnect() { 
//     error = null ;
//     return true ; 
//   }
//   
//   public int getProcessCount() { return count ; }
//   
//   public void forward(Message message) {
//     count++ ;
//     dump(message) ;
//   }
//   
//   public void dump(Message message) {
//     if(!dump) return ;
//     System.out.println(JSONSerializer.INSTANCE.toString(message.getHeader()));
//     try {
//       Class<?> type = Class.forName(message.getData().getType()) ;
//       Object object = message.getData().getDataAs(type) ;
//       System.out.println(JSONSerializer.INSTANCE.toString(object));
//     } catch (ClassNotFoundException e) {
//       e.printStackTrace();
//     }
//   }
//   
//   public void close() {
//   }
// }


// Path: src/test/java/com/neverwinterdp/sparkngin/http/SparknginServer.java
import com.neverwinterdp.netty.http.HttpServer;
import com.neverwinterdp.netty.http.StaticFileHandler;
import com.neverwinterdp.sparkngin.NullDevMessageForwarder;
import com.neverwinterdp.sparkngin.Sparkngin;
import com.neverwinterdp.util.FileUtil;
import com.neverwinterdp.yara.MetricRegistry;

package com.neverwinterdp.sparkngin.http;

/**
 * @author Tuan Nguyen
 * @email  tuan08@gmail.com
 */
public class SparknginServer {
  static {
    System.setProperty("log4j.configuration", "file:src/main/resources/log4j.properties") ;
  }


  NullDevMessageForwarder forwarder ;
