Module io.cloudevents.http.basic

Package 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:

io.cloudevents.core.message.MessageReader, io.cloudevents.core.message.StructuredMessageReader, io.cloudevents.rw.CloudEventReader

public class HttpMessageReader
extends io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>

Constructor Summary

Constructors

Constructor	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	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

Constructor Details

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 Details

isContentTypeHeader

protected boolean isContentTypeHeader(String key)

Specified by:

isContentTypeHeader in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>

isCloudEventsHeader

protected boolean isCloudEventsHeader(String key)

Specified by:

isCloudEventsHeader in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>

toCloudEventsKey

protected String toCloudEventsKey(String key)

Specified by:

toCloudEventsKey in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>

forEachHeader

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

Specified by:

forEachHeader in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>

toCloudEventsValue

protected String toCloudEventsValue(String value)

Specified by:

toCloudEventsValue in class io.cloudevents.core.message.impl.BaseGenericBinaryMessageReaderImpl<String,String>