public abstract class AbstractJsonInboundMessageMapper<P> extends java.lang.Object implements InboundMessageMapper<java.lang.String>
InboundMessageMapper
implementation that maps incoming JSON messages
to a Message
with the specified payload type.JsonInboundMessageMapper
Modifier and Type | Field and Description |
---|---|
protected static java.util.Map<java.lang.String,java.lang.Class<?>> |
DEFAULT_HEADER_TYPES |
protected java.util.Map<java.lang.String,java.lang.Class<?>> |
headerTypes |
protected boolean |
mapToPayload |
protected static java.lang.String |
MESSAGE_FORMAT_ERROR |
protected java.lang.reflect.Type |
payloadType |
Constructor and Description |
---|
AbstractJsonInboundMessageMapper(java.lang.reflect.Type payloadType) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.util.Map<java.lang.String,java.lang.Object> |
readHeaders(P parser,
java.lang.String jsonMessage) |
protected abstract java.lang.Object |
readPayload(P parser,
java.lang.String jsonMessage) |
void |
setHeaderTypes(java.util.Map<java.lang.String,java.lang.Class<?>> headerTypes) |
void |
setMapToPayload(boolean mapToPayload) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
toMessage
protected static final java.lang.String MESSAGE_FORMAT_ERROR
protected static final java.util.Map<java.lang.String,java.lang.Class<?>> DEFAULT_HEADER_TYPES
protected final java.lang.reflect.Type payloadType
protected final java.util.Map<java.lang.String,java.lang.Class<?>> headerTypes
protected volatile boolean mapToPayload
public AbstractJsonInboundMessageMapper(java.lang.reflect.Type payloadType)
public void setHeaderTypes(java.util.Map<java.lang.String,java.lang.Class<?>> headerTypes)
public void setMapToPayload(boolean mapToPayload)
protected abstract java.lang.Object readPayload(P parser, java.lang.String jsonMessage) throws java.lang.Exception
java.lang.Exception
protected abstract java.util.Map<java.lang.String,java.lang.Object> readHeaders(P parser, java.lang.String jsonMessage) throws java.lang.Exception
java.lang.Exception