com.yahoo.bullet.pubsub

Interface Publisher

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

RESTPublisher, RESTQueryPublisher, RESTResultPublisher

public interface Publisher
extends AutoCloseable

Method Summary

Modifier and Type	Method and Description
PubSubMessage	send(PubSubMessage message) Sends a PubSubMessage.
default PubSubMessage	send(String id, byte[] content) Send a message with an ID and content.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

send

default PubSubMessage send(String id,
                           byte[] content)
                    throws PubSubException

Send a message with an ID and content.

Parameters:

id - The ID associated with the message.

content - The content of the message.

Returns:

The sent PubSubMessage.

Throws:

PubSubException - if the messaging system throws an error.

send

PubSubMessage send(PubSubMessage message)
            throws PubSubException

Sends a PubSubMessage. The message might be modified so the sent message is returned.

Parameters:

message - The PubSubMessage to be sent.

Returns:

The sent PubSubMessage.

Throws:

PubSubException - if the messaging system throws an error.