com.hcl.domino.keep.eventbus

Class KeepEventBusRequestObservable<T>

java.lang.Object

com.hcl.domino.keep.eventbus.KeepEventBusRequestObservable<T>

Type Parameters:

T -

All Implemented Interfaces:

EventBusRequestObservable<T>, io.reactivex.ObservableOnSubscribe<T>, org.reactivestreams.Subscription

public class KeepEventBusRequestObservable<T>
extends java.lang.Object
implements EventBusRequestObservable<T>

Handles the communication from an Handler to and from the eventbus Abstracts the creation of the temporary listener address and processing of replies and errors

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
KeepEventBusRequestObservable(io.vertx.core.Vertx vertx, java.lang.String address, io.vertx.core.MultiMap headers, io.vertx.core.json.JsonObject payload)

Method Summary

Modifier and Type	Method and Description
void	cancel()
java.lang.String	getAddress()
java.lang.String	getCacheHeader()
io.vertx.core.MultiMap	getHeaders()
io.vertx.core.json.JsonObject	getPayload()
java.lang.String	getTotalCount()
void	request(long n) Sends data from the queue to the subscriber to supply additional data until the queue is exhausted
void	subscribe(io.reactivex.ObservableEmitter<T> incomingObserver)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

KeepEventBusRequestObservable

public KeepEventBusRequestObservable(io.vertx.core.Vertx vertx,
                                     java.lang.String address,
                                     io.vertx.core.MultiMap headers,
                                     io.vertx.core.json.JsonObject payload)

Parameters:

vertx -

address -

headers -

payload -

Method Detail

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

getAddress

public java.lang.String getAddress()

Returns:

the address

getHeaders

public io.vertx.core.MultiMap getHeaders()

Returns:

the headers

getPayload

public io.vertx.core.json.JsonObject getPayload()

Returns:

the incoming

getTotalCount

public java.lang.String getTotalCount()

Specified by:

getTotalCount in interface EventBusRequestObservable<T>

Returns:

the totalCount of expected results

request

public void request(long n)

Sends data from the queue to the subscriber to supply additional data until the queue is exhausted

Specified by:

request in interface org.reactivestreams.Subscription

Parameters:

n - how many items are requested typically we expect one

subscribe

public void subscribe(io.reactivex.ObservableEmitter<T> incomingObserver)

Specified by:

subscribe in interface io.reactivex.ObservableOnSubscribe<T>

getCacheHeader

public java.lang.String getCacheHeader()

Specified by:

getCacheHeader in interface EventBusRequestObservable<T>

Returns:

Can the request be cached under an Id, null if not