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

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

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

Method Summary

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

@PUT
 @Path(value="/topics/{topic}")
public void createTopic(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

updateTopic

@PUT
 @Path(value="/topics/{topic}/properties")
public void updateTopic(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

getTopic

@GET
 @Path(value="/topics/{topic}")
public void getTopic(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

listTopics

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

Throws:

Exception

deleteTopic

@DELETE
 @Path(value="/topics/{topic}")
public void deleteTopic(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