co.cask.cdap.messaging.server

Class StoreHandler

java.lang.Object

co.cask.http.AbstractHttpHandler

co.cask.cdap.messaging.server.StoreHandler

All Implemented Interfaces:

co.cask.http.HttpHandler

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

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

Method Summary

Modifier and Type	Method and Description
void	publish(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespace, String topic)
void	rollback(org.jboss.netty.handler.codec.http.HttpRequest request, co.cask.http.HttpResponder responder, String namespace, String topic)
void	store(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

publish

@POST
 @Path(value="/publish")
public void publish(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

store

@POST
 @Path(value="/store")
public void store(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

rollback

@POST
 @Path(value="/rollback")
public void rollback(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