com.yahoo.bullet.pubsub.rest

Class RESTQueryPublisher

java.lang.Object

com.yahoo.bullet.pubsub.rest.RESTPublisher

com.yahoo.bullet.pubsub.rest.RESTQueryPublisher

All Implemented Interfaces:

Publisher, AutoCloseable

public class RESTQueryPublisher
extends RESTPublisher

Field Summary

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

APPLICATION_JSON, CONTENT_TYPE

Constructor Summary

Constructors

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

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

RESTQueryPublisher

public RESTQueryPublisher(org.apache.http.impl.client.CloseableHttpClient client,
                          String queryURL,
                          String resultURL,
                          int connectTimeout)

Create a RESTQueryPublisher from a CloseableHttpClient, queryURL and resultURL. The BulletConfig must contain a valid url in the bullet.pubsub.rest.query.urls field.

Parameters:

client - The client.

queryURL - The URL to which to POST queries.

resultURL - The URL that will be added to the Metadata (results will be sent to this URL from the backend).

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.