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

Class ProtobufMessageBodyConsumer

java.lang.Object

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

All Implemented Interfaces:

org.apache.hbase.thirdparty.javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

@Provider
@Consumes({"application/x-protobuf","application/protobuf"})
@Private
public class ProtobufMessageBodyConsumer
extends Object
implements org.apache.hbase.thirdparty.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	Description
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ProtobufMessageBodyConsumer()

Method Summary

Modifier and Type	Method	Description
boolean	isReadable(Class<?> type, Type genericType, Annotation[] annotations, org.apache.hbase.thirdparty.javax.ws.rs.core.MediaType mediaType)
ProtobufMessageHandler	readFrom(Class<ProtobufMessageHandler> type, Type genericType, Annotation[] annotations, org.apache.hbase.thirdparty.javax.ws.rs.core.MediaType mediaType, org.apache.hbase.thirdparty.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 Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

ProtobufMessageBodyConsumer

public ProtobufMessageBodyConsumer()

Method Details

isReadable

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

Specified by:

isReadable in interface org.apache.hbase.thirdparty.javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

readFrom

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

Specified by:

readFrom in interface org.apache.hbase.thirdparty.javax.ws.rs.ext.MessageBodyReader<ProtobufMessageHandler>

Throws:

IOException

org.apache.hbase.thirdparty.javax.ws.rs.WebApplicationException