org.apache.hadoop.hbase.rest.provider.consumer

Class ProtobufMessageBodyConsumer

java.lang.Object

org.apache.hadoop.hbase.rest.provider.consumer.ProtobufMessageBodyConsumer

All Implemented Interfaces:

javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

@Provider
 @Consumes(value={"application/x-protobuf","application/protobuf"})
 @InterfaceAudience.Private
public class ProtobufMessageBodyConsumer
extends Object
implements javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

Adapter for hooking up Jersey content processing dispatch to ProtobufMessageHandler interface capable handlers for decoding protobuf input.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
ProtobufMessageBodyConsumer()

Method Summary

Modifier and Type	Method and Description
boolean	isReadable(Class<?> type, Type genericType, Annotation[] annotations, javax.ws.rs.core.MediaType mediaType)
ProtobufMessageHandler	readFrom(Class<ProtobufMessageHandler> type, Type genericType, Annotation[] annotations, javax.ws.rs.core.MediaType mediaType, javax.ws.rs.core.MultivaluedMap<String,String> httpHeaders, InputStream inputStream)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

ProtobufMessageBodyConsumer

public ProtobufMessageBodyConsumer()

Method Detail

isReadable

public boolean isReadable(Class<?> type,
                          Type genericType,
                          Annotation[] annotations,
                          javax.ws.rs.core.MediaType mediaType)

Specified by:

isReadable in interface javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

readFrom

public ProtobufMessageHandler readFrom(Class<ProtobufMessageHandler> type,
                                       Type genericType,
                                       Annotation[] annotations,
                                       javax.ws.rs.core.MediaType mediaType,
                                       javax.ws.rs.core.MultivaluedMap<String,String> httpHeaders,
                                       InputStream inputStream)
                                throws IOException,
                                       javax.ws.rs.WebApplicationException

Specified by:

readFrom in interface javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

Throws:

IOException

javax.ws.rs.WebApplicationException