summaryrefslogtreecommitdiffstats
path: root/simple/simple-http/src/test/java/org/simpleframework/http/core/TicketProcessor.java
diff options
context:
space:
mode:
Diffstat (limited to 'simple/simple-http/src/test/java/org/simpleframework/http/core/TicketProcessor.java')
-rw-r--r--simple/simple-http/src/test/java/org/simpleframework/http/core/TicketProcessor.java28
1 files changed, 28 insertions, 0 deletions
diff --git a/simple/simple-http/src/test/java/org/simpleframework/http/core/TicketProcessor.java b/simple/simple-http/src/test/java/org/simpleframework/http/core/TicketProcessor.java
new file mode 100644
index 0000000..4636cc7
--- /dev/null
+++ b/simple/simple-http/src/test/java/org/simpleframework/http/core/TicketProcessor.java
@@ -0,0 +1,28 @@
+package org.simpleframework.http.core;
+
+import java.io.IOException;
+import java.nio.channels.SocketChannel;
+
+import org.simpleframework.transport.SocketProcessor;
+import org.simpleframework.transport.Socket;
+
+class TicketProcessor implements SocketProcessor {
+
+ private SocketProcessor delegate;
+
+ public TicketProcessor(SocketProcessor delegate) {
+ this.delegate = delegate;
+ }
+
+ public void process(Socket pipe) throws IOException {
+ SocketChannel channel = pipe.getChannel();
+ int port = channel.socket().getPort();
+
+ pipe.getAttributes().put(Ticket.KEY,new Ticket(port));
+ delegate.process(pipe);
+ }
+
+ public void stop() throws IOException {
+ delegate.stop();
+ }
+} \ No newline at end of file