co.cask.cdap.messaging.server

Class MetadataHandler

java.lang.Object

co.cask.http.AbstractHttpHandler

co.cask.cdap.messaging.server.MetadataHandler

All Implemented Interfaces:

co.cask.http.HttpHandler

public final class MetadataHandler
extends co.cask.http.AbstractHttpHandler

A netty http handler for metadata REST API for the messaging system.

Method Summary

Methods

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

createTopic

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

Throws:

Exception

updateTopic

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

Throws:

Exception

getTopic

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

Throws:

Exception

listTopics

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

Throws:

Exception

deleteTopic

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

Throws:

Exception