Interface Publisher

All Superinterfaces:

AutoCloseable, Resource

public interface Publisher
extends AutoCloseable, Resource

API to send messages.

Instances are created and configured with a PublisherBuilder.

Implementations must be thread-safe.

See Also:

• PublisherBuilder
• Connection.publisherBuilder()

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Publisher.Callback	API to deal with the feedback the broker provides after its processing of a published message.
static interface	Publisher.Context	Feedback context.
static enum	Publisher.Status	Message status.

Nested classes/interfaces inherited from interface Resource

Resource.State, Resource.StateListener

Method Summary

Modifier and Type	Method	Description
void	close()	Close the publisher and release its resources.
Message	message()	Create a message meant to be published by the publisher instance.
Message	message(byte[] body)	Create a message meant to be published by the publisher instance.
void	publish(Message message, Publisher.Callback callback)	Publish a message.

Method Details

message

Message message()

Create a message meant to be published by the publisher instance.

Once published with the publish(Message, Callback) the message instance should not be modified or even reused.

Returns:

a message

message

Message message(byte[] body)

Create a message meant to be published by the publisher instance.

Once published with the publish(Message, Callback) the message instance should not be modified or even reused.

Parameters:

body - message body

Returns:

a message with the provided body

publish

void publish(Message message,
 Publisher.Callback callback)

Publish a message.

Parameters:

message - message to publish

callback - asynchronous callback for broker message processing feedback

close

void close()

Close the publisher and release its resources.

Specified by:

close in interface AutoCloseable