@Test
public void shouldProperlyPropagateValues() throws Exception {

    MacheLoader<String, TestEntity2> cacheLoader =
            new HashMapCacheLoader<>(TestEntity2.class);
    ObservableCacheFactory<String, TestEntity2> observableCacheFactory1 =
        new MessageQueueObservableCacheFactory<>(mqFactory1, mqConfiguration, new UuidUtils());
    ObservableCacheFactory<String, TestEntity2> observableCacheFactory2 =
        new MessageQueueObservableCacheFactory<>(mqFactory2, mqConfiguration, new UuidUtils());
    Mache<String, TestEntity2> cache1 = observableCacheFactory1.createCache(
            macheFactory2.create(String.class, TestEntity2.class, cacheLoader));
    Mache<String, TestEntity2> cache2 = observableCacheFactory2.createCache(
            macheFactory2.create(String.class, TestEntity2.class, cacheLoader));
    final String key1 = "X1";
    final String val1 = "someValue1";
    cache1.put(key1, new TestEntity2(key1, val1));
    assertEquals(val1, cache2.get(key1).otherValue);
    final String val2 = "someValue2";
    cache1.put(key1, new TestEntity2(key1, val2));
    assertEquals(val2, cache2.get(key1).otherValue);
}