Class CqlStorePayload


  • public class CqlStorePayload
    extends java.lang.Object
    DAO to store the resource record and payload data chunks
    • Constructor Summary

      Constructors 
      Constructor Description
      CqlStorePayload​(int resourceTypeId, java.lang.String logicalId, int version, java.lang.String resourcePayloadKey, InputOutputByteStream payloadStream)
      Public constructor
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void run​(com.datastax.oss.driver.api.core.CqlSession session)
      Store the resource into the Cassandra database.
      • Methods inherited from class java.lang.Object

        clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • CqlStorePayload

        public CqlStorePayload​(int resourceTypeId,
                               java.lang.String logicalId,
                               int version,
                               java.lang.String resourcePayloadKey,
                               InputOutputByteStream payloadStream)
        Public constructor
        Parameters:
        resourceTypeId -
        logicalId -
        version -
        resourcePayloadKey -
        payloadStream -
    • Method Detail

      • run

        public void run​(com.datastax.oss.driver.api.core.CqlSession session)
                 throws FHIRPersistenceException
        Store the resource into the Cassandra database. We rely on other services to ensure consistency during our writes (which are not isolated/atomic). This is why every object is given a UUID which we can use to check that the records we read are all associated with the same update
        Parameters:
        session -
        Throws:
        FHIRPersistenceException