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