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

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

Methods

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

public void publish(org.jboss.netty.handler.codec.http.HttpRequest request,
           co.cask.http.HttpResponder responder,
           String namespace,
           String topic)
             throws Exception

Throws:

Exception

store

public void store(org.jboss.netty.handler.codec.http.HttpRequest request,
         co.cask.http.HttpResponder responder,
         String namespace,
         String topic)
           throws Exception

Throws:

Exception

rollback

public void rollback(org.jboss.netty.handler.codec.http.HttpRequest request,
            co.cask.http.HttpResponder responder,
            String namespace,
            String topic)
              throws Exception

Throws:

Exception