net.vz.mongodb.jackson.internal.stream
Class JacksonDBDecoder<T>

java.lang.Object
  net.vz.mongodb.jackson.internal.stream.JacksonDBDecoder<T>

All Implemented Interfaces:

com.mongodb.DBDecoder, org.bson.BSONDecoder

public class JacksonDBDecoder<T>
extends Object
implements com.mongodb.DBDecoder

DB decoder that decodes the database stream using Jackson and bson4jackson

Since:

1.1.2

Author:

James Roper

Constructor Summary

JacksonDBDecoder(JacksonDBCollection<T,?> dbCollection, org.codehaus.jackson.map.ObjectMapper objectMapper, org.codehaus.jackson.type.JavaType type)

Method Summary

int	decode(byte[] b, org.bson.BSONCallback callback)
com.mongodb.DBObject	decode(byte[] b, com.mongodb.DBCollection collection)
int	decode(InputStream in, org.bson.BSONCallback callback)
com.mongodb.DBObject	decode(InputStream in, com.mongodb.DBCollection collection)
com.mongodb.DBCallback	getDBCallback(com.mongodb.DBCollection collection)
org.bson.BSONObject	readObject(byte[] b)
org.bson.BSONObject	readObject(InputStream in)

Methods inherited from class java.lang.Object

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

Constructor Detail

JacksonDBDecoder

public JacksonDBDecoder(JacksonDBCollection<T,?> dbCollection,
                        org.codehaus.jackson.map.ObjectMapper objectMapper,
                        org.codehaus.jackson.type.JavaType type)

Method Detail

getDBCallback

public com.mongodb.DBCallback getDBCallback(com.mongodb.DBCollection collection)

Specified by:

getDBCallback in interface com.mongodb.DBDecoder

decode

public com.mongodb.DBObject decode(byte[] b,
                                   com.mongodb.DBCollection collection)

Specified by:

decode in interface com.mongodb.DBDecoder

decode

public com.mongodb.DBObject decode(InputStream in,
                                   com.mongodb.DBCollection collection)
                            throws IOException

Specified by:

decode in interface com.mongodb.DBDecoder

Throws:

IOException

readObject

public org.bson.BSONObject readObject(byte[] b)

Specified by:

readObject in interface org.bson.BSONDecoder

readObject

public org.bson.BSONObject readObject(InputStream in)
                               throws IOException

Specified by:

readObject in interface org.bson.BSONDecoder

Throws:

IOException

decode

public int decode(byte[] b,
                  org.bson.BSONCallback callback)

Specified by:

decode in interface org.bson.BSONDecoder

decode

public int decode(InputStream in,
                  org.bson.BSONCallback callback)
           throws IOException

Specified by:

decode in interface org.bson.BSONDecoder

Throws:

IOException