@Test
public void testNewTaskAddedToQueue() throws InvalidArgumentException, DeserializationException, InterruptedException, ResponseHandlerException {

    String chainName = "chainName";
    when(response.headers()).thenReturn(headers);
    when(headers.get("messageMapId")).thenReturn("messageMap");
    when(strategy.deserialize(any())).thenReturn(new DSObject("{\"foo\": \"bar\"}"));
    responseHandler.handle(ctx, response);
    verify(taskQueue, times(1)).put(any());
}