in Elastiflix/java-favorite-otel-manual/src/main/java/com/movieapi/ApiServlet.java [90:110]
public void postUserFavorites(String user_id, String movieID) {
Span span = GlobalOpenTelemetry.getTracer(SERVICE_NAME).spanBuilder("Redis.Post").setSpanKind(SpanKind.CLIENT).startSpan();
Jedis jedis = r.getResource();
try (Scope scope = span.makeCurrent()) {
span.setAttribute("db.system", "redis");
span.setAttribute("db.connection_string", redisHost);
span.setAttribute("db.statement", "POST user_id " + user_id +" AND movie_id "+movieID);
Long redisResponse = jedis.srem(user_id, movieID);
if (redisResponse == 0) {
jedis.sadd(user_id, movieID);
}
} catch (Exception e) {
span.setStatus(StatusCode.ERROR, "Error while getting data from Redis");
span.recordException(e);
} finally {
jedis.close();
span.end();
}
}