com.yahoo.bard.webservice.async.broadcastchannels

Class RedisBroadcastChannel<T>

java.lang.Object

com.yahoo.bard.webservice.async.broadcastchannels.RedisBroadcastChannel<T>

Type Parameters:

T - The type of message that the RedisBroadcastChannel publishes

All Implemented Interfaces:

BroadcastChannel<T>, Closeable, AutoCloseable

@Singleton
public class RedisBroadcastChannel<T>
extends Object
implements BroadcastChannel<T>

A Redis backed implementation of BroadcastChannel. Redisson is used as the Redis-Client. RedisBroadcastChannel has a 'topic' that publishes to the REDIS_CHANNEL. It also has a listener that listens to all the messages on REDIS_CHANNEL and populates an observable. BroadcastListeners can subscribe to this observable to get messages passed around on REDIS_CHANNEL.

Field Summary

Fields inherited from interface com.yahoo.bard.webservice.async.broadcastchannels.BroadcastChannel

PUBLISH_ON_CLOSED_ERROR_MESSAGE

Constructor Summary

Constructors

Constructor and Description
RedisBroadcastChannel(org.redisson.api.RedissonClient redissonClient) Builds a Broadcastchannel that knows how to communicate with Redis.

Method Summary

Modifier and Type	Method and Description
void	close()
rx.Observable<T>	getNotifications() This method returns a Hot Observable (Observable which emits events whether someone is listening or not) that emits all the notifications passed to it by Bard instances in the cluster.
void	publish(T message) Publish is used to publish a message from a Bard box.

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisBroadcastChannel

public RedisBroadcastChannel(org.redisson.api.RedissonClient redissonClient)

Builds a Broadcastchannel that knows how to communicate with Redis.

Parameters:

redissonClient - The client to use to communicate with Redis

Method Detail

publish

public void publish(T message)
             throws UnsupportedOperationException

Description copied from interface: BroadcastChannel

Publish is used to publish a message from a Bard box.

Specified by:

publish in interface BroadcastChannel<T>

Parameters:

message - The message to be published

Throws:

UnsupportedOperationException - if someone attempts to publish to the channel after it has been closed

getNotifications

public rx.Observable<T> getNotifications()

Description copied from interface: BroadcastChannel

This method returns a Hot Observable (Observable which emits events whether someone is listening or not) that emits all the notifications passed to it by Bard instances in the cluster.

Specified by:

getNotifications in interface BroadcastChannel<T>

Returns:

An unbounded stream of notifications from Bard instances

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable