Class DefaultC4CAggregatingCollectorIntegrationTest

    • Constructor Detail

      • DefaultC4CAggregatingCollectorIntegrationTest

        public DefaultC4CAggregatingCollectorIntegrationTest()
    • Method Detail

      • setup

        public void setup()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldConsumeEverything

        public void shouldConsumeEverything()
      • whenOneOfAddressesIsDeleted

        public void whenOneOfAddressesIsDeleted()
      • whenTheOnlyAddressIsDeleted

        public void whenTheOnlyAddressIsDeleted()
      • whenCustomerIsDeleted

        public void whenCustomerIsDeleted()
      • whenEverythingIsDeleted

        public void whenEverythingIsDeleted()
      • shouldCreateSeparateInstances

        public void shouldCreateSeparateInstances()
      • shouldGrabRelatedAddresses

        public void shouldGrabRelatedAddresses()
      • shouldGrabRelatedCustomers

        public void shouldGrabRelatedCustomers()
      • shouldConsumeSyntheticChanges

        public void shouldConsumeSyntheticChanges()
      • consumeAllChanges

        protected void consumeAllChanges​(java.lang.String streamId)
      • dump

        protected void dump​(java.util.List<ItemChangeDTO> items)