io.cloudevents.http.impl

Class HttpMessageReader

java.lang.Object

io.cloudevents.core.message.impl.BaseBinaryMessageReader

io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>

io.cloudevents.http.impl.HttpMessageReader

All Implemented Interfaces:

MessageReader, StructuredMessageReader, io.cloudevents.rw.CloudEventReader

public class HttpMessageReader
extends BaseGenericBinaryMessageReaderImpl<String,String>

Constructor Summary

Constructors

Constructor and Description
HttpMessageReader(io.cloudevents.SpecVersion version, Consumer<BiConsumer<String,String>> forEachHeader, byte[] body)
HttpMessageReader(io.cloudevents.SpecVersion version, Consumer<BiConsumer<String,String>> forEachHeader, io.cloudevents.CloudEventData body)

Method Summary

Modifier and Type	Method and Description
protected void	forEachHeader(BiConsumer<String,String> fn)
protected boolean	isCloudEventsHeader(String key)
protected boolean	isContentTypeHeader(String key)
protected String	toCloudEventsKey(String key)
protected String	toCloudEventsValue(String value)

Methods inherited from class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl

read

Methods inherited from class io.cloudevents.core.message.impl.BaseBinaryMessageReader

getEncoding, read

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.cloudevents.core.message.MessageReader

read, read, toEvent, toEvent

Methods inherited from interface io.cloudevents.core.message.StructuredMessageReader

from, from

Constructor Detail

HttpMessageReader

public HttpMessageReader(io.cloudevents.SpecVersion version,
                         Consumer<BiConsumer<String,String>> forEachHeader,
                         io.cloudevents.CloudEventData body)

HttpMessageReader

public HttpMessageReader(io.cloudevents.SpecVersion version,
                         Consumer<BiConsumer<String,String>> forEachHeader,
                         byte[] body)

Method Detail

isContentTypeHeader

protected boolean isContentTypeHeader(String key)

Specified by:

isContentTypeHeader in class BaseGenericBinaryMessageReaderImpl<String,String>

isCloudEventsHeader

protected boolean isCloudEventsHeader(String key)

Specified by:

isCloudEventsHeader in class BaseGenericBinaryMessageReaderImpl<String,String>

toCloudEventsKey

protected String toCloudEventsKey(String key)

Specified by:

toCloudEventsKey in class BaseGenericBinaryMessageReaderImpl<String,String>

forEachHeader

protected void forEachHeader(BiConsumer<String,String> fn)

Specified by:

forEachHeader in class BaseGenericBinaryMessageReaderImpl<String,String>

toCloudEventsValue

protected String toCloudEventsValue(String value)

Specified by:

toCloudEventsValue in class BaseGenericBinaryMessageReaderImpl<String,String>