AMF Provider for REST service

AmfProvider.java

package net.java.ws.providers;
 
import javax.ws.rs.Consumes;
import javax.ws.rs.Produces;
import javax.ws.rs.WebApplicationException;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.ext.MessageBodyReader;
import javax.ws.rs.ext.MessageBodyWriter;
import javax.ws.rs.ext.Provider;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.lang.annotation.Annotation;
import java.lang.reflect.Type;
import flex.messaging.io.SerializationContext;
import flex.messaging.io.amf.Amf3Input;
import flex.messaging.io.amf.Amf3Output;
 
/**
 * A JAX-RS provider for data that is serialized/deserialized according to the AMF specification for serialization of objects.
 * E.g. mime type "application/x-amf". 
 */
@Provider
@Produces ("application/x-amf")
@Consumes ("application/x-amf")
public class AMFProvider implements MessageBodyReader, MessageBodyWriter {
 
  public boolean isReadable(Class realType, Type genericType, Annotation[] annotations, MediaType mediaType) {
    return true; //we'll assume everything is readable, for now.
  }
 
  public Object readFrom(Class realType, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap httpHeaders, InputStream stream)
    throws IOException, WebApplicationException {
    SerializationContext context = new SerializationContext();
    Amf3Input input = new Amf3Input(context);
    input.setInputStream(stream);
    return input.readObject();
  }
 
  public boolean isWriteable(Class realType, Type genericType, Annotation[] annotations, MediaType mediaType) {
    return true; //we'll assume everything is writeable, for now.
  }
 
  public void writeTo(Object o, Class realType, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap httpHeaders, OutputStream stream) throws IOException, WebApplicationException {
    SerializationContext context = new SerializationContext();
    Amf3Output output = new Amf3Output(context);
    output.setOutputStream(stream);
    output.writeObject(obj);
  }
 
  public long getSize(Object o, Class type, Type genericType, Annotation[] annotations, MediaType mediaType) {
    return -1; //we don't know the size
  }
 
}