}
// Start the Response Consumer timer
- CrudAsyncResponseConsumer crudAsyncResponseConsumer = new CrudAsyncResponseConsumer(asyncResponseConsumer);
+ CrudAsyncResponseConsumer crudAsyncResponseConsumer = new CrudAsyncResponseConsumer(
+ asyncResponseConsumer, new GraphEventUpdater()
+ );
timer = new Timer("crudAsyncResponseConsumer-1");
timer.schedule(crudAsyncResponseConsumer, responsePollInterval, responsePollInterval);
}
String responsePayload = responseHandler.handleVertexResponse(version, event, response);
- return new ImmutablePair<EntityTag, String>(entityTag, responsePayload);
+ return new ImmutablePair<>(entityTag, responsePayload);
}
@Override
}
String responsePayload = responseHandler.handleEdgeResponse(version, event, response);
- return new ImmutablePair<EntityTag, String>(entityTag, responsePayload);
+ return new ImmutablePair<>(entityTag, responsePayload);
}
@Override
}
String responsePayload = responseHandler.handleVertexResponse(version, event, response);
- return new ImmutablePair<EntityTag, String>(entityTag, responsePayload);
+ return new ImmutablePair<>(entityTag, responsePayload);
}
@Override
}
String responsePayload = responseHandler.handleVertexResponse(version, event, response);
- return new ImmutablePair<EntityTag, String>(entityTag, responsePayload);
+ return new ImmutablePair<>(entityTag, responsePayload);
}
@Override
}
String responsePayload = responseHandler.handleEdgeResponse(version, event, response);
- return new ImmutablePair<EntityTag, String>(entityTag, responsePayload);
+ return new ImmutablePair<>(entityTag, responsePayload);
}
@Override
}
String responsePayload = responseHandler.handleEdgeResponse(version, event, response);
- return new ImmutablePair<EntityTag, String>(entityTag, responsePayload);
+ return new ImmutablePair<>(entityTag, responsePayload);
}
@PreDestroy