// Path: src/main/java/com/neverwinterdp/sparkngin/Ack.java
// public class Ack implements Serializable {
//   static public enum Status { OK, ERROR, NOT_AVAIBLE }
// 
//   private Object messageId ;
//   private Status status;
//   private String message;
// 
//   public Object getMessageId() { return messageId; }
//   public void setMessageId(Object objectId) {
//     this.messageId = objectId;
//   }
// 
//   public Status getStatus() {
//     return status;
//   }
// 
//   public void setStatus(Status status) {
//     this.status = status;
//   }
// 
//   public String getMessage() {
//     return message;
//   }
// 
//   public void setMessage(String message) {
//     this.message = message;
//   }
// }


import io.netty.handler.codec.http.HttpContent;
import io.netty.util.CharsetUtil;
import com.neverwinterdp.message.Message;
import com.neverwinterdp.sparkngin.Ack;
import com.neverwinterdp.util.JSONSerializer;
package com.neverwinterdp.sparkngin.http;



public class JSONHttpSparknginClient extends AbstractHttpSparknginClient {
  
  public JSONHttpSparknginClient(String host, int port, int bufferSize, boolean connect) throws Exception {
    super(host, port, bufferSize, connect) ;
    setPath("/message/json") ;
  }
  
// Path: src/main/java/com/neverwinterdp/sparkngin/Ack.java
// public class Ack implements Serializable {
//   static public enum Status { OK, ERROR, NOT_AVAIBLE }
// 
//   private Object messageId ;
//   private Status status;
//   private String message;
// 
//   public Object getMessageId() { return messageId; }
//   public void setMessageId(Object objectId) {
//     this.messageId = objectId;
//   }
// 
//   public Status getStatus() {
//     return status;
//   }
// 
//   public void setStatus(Status status) {
//     this.status = status;
//   }
// 
//   public String getMessage() {
//     return message;
//   }
// 
//   public void setMessage(String message) {
//     this.message = message;
//   }
// }


// Path: src/main/java/com/neverwinterdp/sparkngin/http/JSONHttpSparknginClient.java
import io.netty.handler.codec.http.HttpContent;
import io.netty.util.CharsetUtil;
import com.neverwinterdp.message.Message;
import com.neverwinterdp.sparkngin.Ack;
import com.neverwinterdp.util.JSONSerializer;

package com.neverwinterdp.sparkngin.http;



public class JSONHttpSparknginClient extends AbstractHttpSparknginClient {
  
  public JSONHttpSparknginClient(String host, int port, int bufferSize, boolean connect) throws Exception {
    super(host, port, bufferSize, connect) ;
    setPath("/message/json") ;
  }
  
  protected Ack toAck(HttpContent content) {