com.yahoo.bullet.pubsub.rest

Class RESTPublisher

java.lang.Object

com.yahoo.bullet.pubsub.rest.RESTPublisher

All Implemented Interfaces:

Publisher, AutoCloseable

Direct Known Subclasses:

RESTQueryPublisher, RESTResultPublisher

public abstract class RESTPublisher
extends Object
implements Publisher

Field Summary

Fields

Modifier and Type	Field and Description
static String	APPLICATION_JSON
static String	CONTENT_TYPE

Constructor Summary

Constructors

Constructor and Description
RESTPublisher(org.apache.http.impl.client.CloseableHttpClient client, int connectTimeout) Create a RESTQueryPublisher from a CloseableHttpClient.

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	sendToURL(String url, PubSubMessage message) Send the PubSubMessage to the given url.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.yahoo.bullet.pubsub.Publisher

send, send

Field Detail

APPLICATION_JSON

public static final String APPLICATION_JSON

See Also:

Constant Field Values

CONTENT_TYPE

public static final String CONTENT_TYPE

See Also:

Constant Field Values

Constructor Detail

RESTPublisher

public RESTPublisher(org.apache.http.impl.client.CloseableHttpClient client,
                     int connectTimeout)

Create a RESTQueryPublisher from a CloseableHttpClient.

Parameters:

client - The client.

connectTimeout - The minimum time (ms) to wait for a connection to be made.

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

sendToURL

protected void sendToURL(String url,
                         PubSubMessage message)

Send the PubSubMessage to the given url.

Parameters:

url - The url to which to send the message.

message - The message to send.