com.yahoo.bullet.pubsub.rest

Class RESTResultPublisher

java.lang.Object

com.yahoo.bullet.pubsub.rest.RESTPublisher

com.yahoo.bullet.pubsub.rest.RESTResultPublisher

All Implemented Interfaces:

Publisher, AutoCloseable

public class RESTResultPublisher
extends RESTPublisher

Field Summary

Fields inherited from class com.yahoo.bullet.pubsub.rest.RESTPublisher

APPLICATION_JSON, CONTENT_TYPE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
PubSubMessage	send(PubSubMessage message) Sends a PubSubMessage.

Methods inherited from class com.yahoo.bullet.pubsub.rest.RESTPublisher

close, sendToURL

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

Constructor Detail

RESTResultPublisher

public RESTResultPublisher(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

send

public PubSubMessage send(PubSubMessage message)

Description copied from interface: Publisher

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.