@Test
public void testGetQueueRequestInvalidJson(TestContext context){

    Async async = context.async();
    context.assertFalse(jedis.exists(QUEUE_REQUESTS));
    jedis.hset(QUEUE_REQUESTS, "queue_1", "not_a_json_value");
    storage.getQueueRequest("queue_1").setHandler(event -> {
        context.assertFalse(event.succeeded());
        context.assertEquals("Failed to decode queue request for queue 'queue_1'. Got this from storage: not_a_json_value", event.cause().getMessage());
        async.complete();
    });
}