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

Class UserBlotterManager

  • public class UserBlotterManager
extends java.lang.Object

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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