Package com.caplin.motif.fx.ret.orders.blotter.sources

Class UserBlotterManager

java.lang.Object

com.caplin.motif.fx.ret.orders.blotter.sources.UserBlotterManager

public class UserBlotterManager
extends Object

Constructor Summary

Constructors

Constructor	Description
UserBlotterManager(UserBlotterFactory userBlotterFactory)

Method Summary

Modifier and Type	Method	Description
rx.Observable<String>	addIfAbsentContainerObservable(String username)
rx.Observable<com.google.common.collect.ImmutableMap<String,String>>	getRecordObservable(String username, String requestId)
void	publishRecord(String blotterId, String username, Map<String,String> fields)	Use this method to update the data provider when an historical blotter update is received.
void	removeContainerObservable(String username)

Methods inherited from class java.lang.Object

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

Constructor Details

UserBlotterManager

public UserBlotterManager(UserBlotterFactory userBlotterFactory)

Method Details

addIfAbsentContainerObservable

@Nonnull
public rx.Observable<String> addIfAbsentContainerObservable(@Nonnull
 String username)

removeContainerObservable

public void removeContainerObservable(@Nonnull
 String username)

getRecordObservable

@Nullable
public rx.Observable<com.google.common.collect.ImmutableMap<String,String>> getRecordObservable(@Nonnull
 String username,
 @Nonnull
 String requestId)

publishRecord

public void publishRecord(@Nonnull
 String blotterId,
 @Nonnull
 String username,
 @Nonnull
 Map<String,String> fields)
                   throws IllegalStateException

Use this method to update the data provider when an historical blotter update is received.

A historicalOrder is an order received from LOMS' cache. The update will be published on a dedicated historical channel.

Parameters:

username - the user the order belongs to

fields - the blotter items to be published

Throws:

IllegalStateException