com.yahoo.bullet.pubsub.rest

Class RESTSubscriber

java.lang.Object

com.yahoo.bullet.pubsub.BufferingSubscriber

com.yahoo.bullet.pubsub.rest.RESTSubscriber

All Implemented Interfaces:

Subscriber, AutoCloseable

public class RESTSubscriber
extends BufferingSubscriber

Field Summary

Fields inherited from class com.yahoo.bullet.pubsub.BufferingSubscriber

maxUncommittedMessages, receivedMessages, uncommittedMessages

Constructor Summary

Constructors

Constructor and Description
RESTSubscriber(int maxUncommittedMessages, List<String> urls, org.apache.http.impl.client.CloseableHttpClient client, long minWait, int connectTimeout) Create a RESTSubscriber.

Method Summary

Modifier and Type	Method and Description
void	close()
List<PubSubMessage>	getMessages() Implement this method to read and return a List of PubSubMessage from your actual PubSub source.

Methods inherited from class com.yahoo.bullet.pubsub.BufferingSubscriber

commit, fail, haveMessages, receive

Methods inherited from class java.lang.Object

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

Constructor Detail

RESTSubscriber

public RESTSubscriber(int maxUncommittedMessages,
                      List<String> urls,
                      org.apache.http.impl.client.CloseableHttpClient client,
                      long minWait,
                      int connectTimeout)

Create a RESTSubscriber.

Parameters:

maxUncommittedMessages - The maximum number of records that will be buffered before commit() must be called.

urls - The URLs which will be used to make the http request.

client - The client to use to make http requests.

minWait - The minimum time (ms) to wait between subsequent http requests.

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

Method Detail

getMessages

public List<PubSubMessage> getMessages()

Description copied from class: BufferingSubscriber

Implement this method to read and return a List of PubSubMessage from your actual PubSub source.

Specified by:

getMessages in class BufferingSubscriber

Returns:

A List of PubSubMessage if any were read. A null or an empty list if not.

close

public void close()