io.cloudevents.http.impl

Class HttpMessageWriter

java.lang.Object

io.cloudevents.http.impl.HttpMessageWriter

All Implemented Interfaces:

MessageWriter<HttpMessageWriter,Void>, StructuredMessageWriter<Void>, io.cloudevents.rw.CloudEventContextWriter, io.cloudevents.rw.CloudEventWriter<Void>, io.cloudevents.rw.CloudEventWriterFactory<HttpMessageWriter,Void>

public class HttpMessageWriter
extends Object
implements io.cloudevents.rw.CloudEventWriter<Void>, MessageWriter<HttpMessageWriter,Void>

Constructor Summary

Constructors

Constructor and Description
HttpMessageWriter(BiConsumer<String,String> putHeader, Consumer<byte[]> putBody)

Method Summary

Modifier and Type	Method and Description
HttpMessageWriter	create(io.cloudevents.SpecVersion version)
Void	end()
Void	end(io.cloudevents.CloudEventData value)
Void	setEvent(EventFormat format, byte[] value)
io.cloudevents.rw.CloudEventContextWriter	withContextAttribute(String name, String value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.cloudevents.rw.CloudEventContextWriter

withContextAttribute, withContextAttribute, withContextAttribute, withContextAttribute, withContextAttribute, withContextAttribute

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

writeBinary, writeStructured, writeStructured

Constructor Detail

HttpMessageWriter

public HttpMessageWriter(BiConsumer<String,String> putHeader,
                         Consumer<byte[]> putBody)

Method Detail

setEvent

public Void setEvent(EventFormat format,
                     byte[] value)
              throws io.cloudevents.rw.CloudEventRWException

Specified by:

setEvent in interface StructuredMessageWriter<Void>

Throws:

io.cloudevents.rw.CloudEventRWException

end

public Void end(io.cloudevents.CloudEventData value)
         throws io.cloudevents.rw.CloudEventRWException

Specified by:

end in interface io.cloudevents.rw.CloudEventWriter<Void>

Throws:

io.cloudevents.rw.CloudEventRWException

end

public Void end()

Specified by:

end in interface io.cloudevents.rw.CloudEventWriter<Void>

withContextAttribute

public io.cloudevents.rw.CloudEventContextWriter withContextAttribute(String name,
                                                                      String value)
                                                               throws io.cloudevents.rw.CloudEventRWException

Specified by:

withContextAttribute in interface io.cloudevents.rw.CloudEventContextWriter

Throws:

io.cloudevents.rw.CloudEventRWException

create

public HttpMessageWriter create(io.cloudevents.SpecVersion version)

Specified by:

create in interface io.cloudevents.rw.CloudEventWriterFactory<HttpMessageWriter,Void>