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 java.lang.Object

Constructor Summary

Constructors

Constructor and Description
UserBlotterManager(UserBlotterFactory userBlotterFactory)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

UserBlotterManager

public UserBlotterManager(UserBlotterFactory userBlotterFactory)

Method Detail

addIfAbsentContainerObservable

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

removeContainerObservable

public void removeContainerObservable(@Nonnull
                                      java.lang.String username)

getRecordObservable

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

publishRecord

public void publishRecord(@Nonnull
                          java.lang.String blotterId,
                          @Nonnull
                          java.lang.String username,
                          @Nonnull
                          java.util.Map<java.lang.String,java.lang.String> fields)
                   throws java.lang.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:

java.lang.IllegalStateException