import com.twitter.finagle.Service;
import com.twitter.finagle.http.Http;
import com.twitter.util.Future;
import org.jboss.netty.buffer.ChannelBuffers;
import org.jboss.netty.handler.codec.http.*;
public class MyService extends Service<HttpRequest, HttpResponse> {
@Override
public Future<HttpResponse> apply(HttpRequest req) {
HttpResponse response = new DefaultHttpResponse(
req.getProtocolVersion(), HttpResponseStatus.OK);
response.setContent(ChannelBuffers.wrappedBuffer("Hello, World!".getBytes()));
response.setHeader(HttpHeaders.Names.CONTENT_TYPE, "text/plain");
return Future.value(response);
}
}
public class Server {
public static void main(String[] args) {
Service<HttpRequest, HttpResponse> service = new MyService();
com.twitter.finagle.builder.ServerBuilder.safeBuild(
service,
Http.serverBuilder(),
"localhost:8080");
}
}
