co.cask.cdap.messaging.server

Class FetchHandler

java.lang.Object

co.cask.http.AbstractHttpHandler

co.cask.cdap.messaging.server.FetchHandler

All Implemented Interfaces:

co.cask.http.HttpHandler

@Path(value="/v1/namespaces/{namespace}/topics/{topic}")
public final class FetchHandler
extends co.cask.http.AbstractHttpHandler

A netty http handler for handling message fetching REST API for the messaging system.

Method Summary

Modifier and Type	Method and Description
void	poll(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespace, String topic)

Methods inherited from class co.cask.http.AbstractHttpHandler

destroy, init, sendInternalRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

poll

@POST
 @Path(value="poll")
public void poll(org.jboss.netty.handler.codec.http.HttpRequest request,
                                            co.cask.http.HttpResponder responder,
                                            @PathParam(value="namespace")
                                            String namespace,
                                            @PathParam(value="topic")
                                            String topic)
                                     throws Exception

Throws:

Exception