Module io.cloudevents.core

Package io.cloudevents.core.message.impl

Class BaseBinaryMessageReader

java.lang.Object

io.cloudevents.core.message.impl.BaseBinaryMessageReader

All Implemented Interfaces:

MessageReader, StructuredMessageReader, io.cloudevents.rw.CloudEventReader

Direct Known Subclasses:

BaseGenericBinaryMessageReaderImpl

public abstract class BaseBinaryMessageReader
extends Object
implements MessageReader

Base MessageReader implementation for a binary message

Constructor Summary

Constructors

Constructor	Description
BaseBinaryMessageReader()

Method Summary

Modifier and Type	Method	Description
Encoding	getEncoding()
<T> T	read(StructuredMessageWriter<T> writer)	Read the message as structured encoded message using the provided writer

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, read, toEvent, toEvent

Constructor Details

BaseBinaryMessageReader

public BaseBinaryMessageReader()

Method Details

getEncoding

public Encoding getEncoding()

Specified by:

getEncoding in interface MessageReader

Returns:

The message encoding

read

public <T> T read(StructuredMessageWriter<T> writer)
           throws io.cloudevents.rw.CloudEventRWException,
IllegalStateException

Description copied from interface: MessageReader

Read the message as structured encoded message using the provided writer

Specified by:

read in interface MessageReader

Specified by:

read in interface StructuredMessageReader

Type Parameters:

T - the return type of the StructuredMessageWriter

Parameters:

writer - Structured Message writer

Returns:

the return value returned by StructuredMessageWriter.setEvent(EventFormat, byte[])

Throws:

io.cloudevents.rw.CloudEventRWException - if something went wrong during the visit.

IllegalStateException - if the message is not in structured encoding.