1 files changed, 141 insertions, 0 deletions
diff --git a/simple/simple-http/src/test/java/org/simpleframework/http/message/ReplyConsumer.java b/simple/simple-http/src/test/java/org/simpleframework/http/message/ReplyConsumer.java
new file mode 100644
index 0000000..a7fbfe5
--- /dev/null
+++ b/simple/simple-http/src/test/java/org/simpleframework/http/message/ReplyConsumer.java
@@ -0,0 +1,141 @@
+package org.simpleframework.http.message;
+
+import org.simpleframework.http.Cookie;
+import org.simpleframework.http.ResponseHeader;
+import org.simpleframework.http.Status;
+import org.simpleframework.http.message.RequestConsumer;
+
+public class ReplyConsumer extends RequestConsumer implements ResponseHeader {
+
+   private String text;
+   private int code;
+
+   public ReplyConsumer() {
+      super();
+   }
+
+   private void status() {
+      while(pos < count) {
+         if(!digit(array[pos])) {
+            break;
+         }
+         code *= 10;
+         code += array[pos];
+         code -= '0';
+         pos++;
+      }
+   }
+
+   private void text() {
+      StringBuilder builder = new StringBuilder();
+
+      while(pos < count) {
+         if(terminal(array[pos])) {
+            pos += 2;
+            break;
+         }
+         builder.append((char) array[pos]);
+         pos++;
+      }
+      text = builder.toString();
+   }
+
+   public String getDescription() {
+      return text;
+   }
+
+   public void setDescription(String text) {
+      this.text = text;
+   }
+
+   public int getCode() {
+      return code;
+   }
+
+   public void setCode(int status) {
+      this.code = status;
+   }
+   
+   public Status getStatus() {
+      return Status.getStatus(code);
+   }
+
+   public void setStatus(Status status) {
+      code = status.code;
+      text = status.description;
+   }
+
+   @Override
+   protected void add(String name, String value) {
+      if(equal("Set-Cookie", name)) { // A=b; version=1; path=/;  
+         String[] list = value.split(";"); // "A=b", "version=1", "path=/" 
+
+         if(list.length > 0) {
+            String[] pair = list[0].split("=");
+
+            if(pair.length > 1) {
+               header.setCookie(pair[0], pair[1]); // "A", "b" 
+            }
+         }
+      }
+      super.add(name, value);
+   }
+
+   @Override
+   protected void process() {
+      version(); // HTTP/1.1 
+      adjust();
+      status(); // 200 
+      adjust();
+      text(); // OK 
+      adjust();
+      headers();
+   }
+
+   public void setMajor(int major) {
+      this.major = major;
+
+   }
+
+   public void setMinor(int minor) {
+      this.minor = minor;
+
+   }
+
+   public void addValue(String name, String value) {
+      header.addValue(name, value);      
+   }
+
+   public void addInteger(String name, int value) {
+      header.addInteger(name, value);
+      
+   }
+
+   public void addDate(String name, long date) {
+      header.addDate(name, date);
+   }
+
+   public void setValue(String name, String value) {
+      header.setValue(name, value);
+   }
+
+   public void setInteger(String name, int value) {
+      header.setInteger(name, value);
+   }   
+
+   public void setLong(String name, long value) {
+      header.setLong(name, value);
+   }
+   
+   public void setDate(String name, long date) {
+      header.setDate(name, date);
+   }
+   
+   public Cookie setCookie(Cookie cookie) {
+      return header.setCookie(cookie);
+   }
+
+   public Cookie setCookie(String name, String value) {
+      return header.setCookie(name, value);
+   }
+}