com.netflix.ribbon.examples.rx.proxy

Class RxMovieProxyExample

java.lang.Object

com.netflix.ribbon.examples.rx.AbstractRxMovieClient

com.netflix.ribbon.examples.rx.proxy.RxMovieProxyExample

public class RxMovieProxyExample
extends AbstractRxMovieClient

Run RxMovieServer prior to running this example!

Field Summary

Fields inherited from class com.netflix.ribbon.examples.rx.AbstractRxMovieClient

NEW_LINE_SPLIT_RE, TEST_USER

Constructor Summary

Constructors

Constructor and Description
RxMovieProxyExample(int port)

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
void	shutdown()
protected rx.Observable<io.netty.buffer.ByteBuf>[]	triggerMoviesRegistration()
protected rx.Observable<io.netty.buffer.ByteBuf>[]	triggerRecommendationsSearch()
protected rx.Observable<io.netty.buffer.ByteBuf>[]	triggerRecommendationsUpdate()

Methods inherited from class com.netflix.ribbon.examples.rx.AbstractRxMovieClient

registerMovies, runExample, searchCatalog, updateRecommendations

Methods inherited from class java.lang.Object

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

Constructor Detail

RxMovieProxyExample

public RxMovieProxyExample(int port)

Method Detail

triggerMoviesRegistration

protected rx.Observable<io.netty.buffer.ByteBuf>[] triggerMoviesRegistration()

Specified by:

triggerMoviesRegistration in class AbstractRxMovieClient

triggerRecommendationsUpdate

protected rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsUpdate()

Specified by:

triggerRecommendationsUpdate in class AbstractRxMovieClient

triggerRecommendationsSearch

protected rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsSearch()

Specified by:

triggerRecommendationsSearch in class AbstractRxMovieClient

shutdown

public void shutdown()

Overrides:

shutdown in class AbstractRxMovieClient

main

public static void main(java.lang.String[] args)