@Test
public void testGet() throws Exception {

    ObservableMap<String, String> observable = new ObservableMap<>(mqFactory, cache, uuidUtils);
    observable.registerListener(event -> fired++);
    observable.put("a", "b");
    assertEquals(1, fired);
}