Make RxJava2 instrumentation Android-friendly (#7895)

Resolves #7894

Replace `MethodHandle` with older `java.lang.reflect.Field`, which is
supported on older Java versions.

Also enables animal sniffer for the RxJava2 instrumentation to prevent
regression.

---------

Co-authored-by: opentelemetrybot <[email protected]>

Author: bherbst

instrumentation/rxjava/rxjava-2.0/library/build.gradle.kts

@@ -1,5 +1,6 @@
 plugins {
   id("otel.library-instrumentation")
+  id("otel.animalsniffer-conventions")
 }
 
 dependencies {

instrumentation/rxjava/rxjava-2.0/library/src/main/java/io/opentelemetry/instrumentation/rxjava/v2_0/TracingObserver.java

@@ -27,11 +27,10 @@
 import io.reactivex.Observer;
 import io.reactivex.internal.fuseable.QueueDisposable;
 import io.reactivex.internal.observers.BasicFuseableObserver;
-import java.lang.invoke.MethodHandle;
-import java.lang.invoke.MethodHandles;
+import java.lang.reflect.Field;
 
 class TracingObserver<T> extends BasicFuseableObserver<T, T> {
-  private static final MethodHandle queueDisposableGetter = getQueueDisposableGetter();
+  private static final Field queueDisposableField = getQueueDisposableField();
 
   // BasicFuseableObserver#actual has been renamed to downstream in newer versions, we can't use it
   // in this class
@@ -81,34 +80,35 @@ public T poll() throws Exception {
     return getQueueDisposable().poll();
   }
 
+  @SuppressWarnings("unchecked")
   private QueueDisposable<T> getQueueDisposable() {
     try {
-      return (QueueDisposable<T>) queueDisposableGetter.invoke(this);
+      return (QueueDisposable<T>) queueDisposableField.get(this);
     } catch (Throwable throwable) {
       throw new IllegalStateException(throwable);
     }
   }
 
-  private static MethodHandle getGetterHandle(String fieldName) {
+  private static Field getField(String fieldName) {
+
     try {
-      return MethodHandles.lookup()
-          .findGetter(BasicFuseableObserver.class, fieldName, QueueDisposable.class);
-    } catch (NoSuchFieldException | IllegalAccessException ignored) {
+      return BasicFuseableObserver.class.getDeclaredField(fieldName);
+    } catch (NoSuchFieldException ignored) {
       // Ignore
     }
     return null;
   }
 
-  private static MethodHandle getQueueDisposableGetter() {
-    MethodHandle getter = getGetterHandle("qd");
-    if (getter == null) {
+  private static Field getQueueDisposableField() {
+    Field queueDisposableField = getField("qd");
+    if (queueDisposableField == null) {
       // in versions before 2.2.1 field was named "qs"
-      getter = getGetterHandle("qs");
+      queueDisposableField = getField("qs");
     }
-    return getter;
+    return queueDisposableField;
   }
 
   public static boolean canEnable() {
-    return queueDisposableGetter != null;
+    return queueDisposableField != null;
   }
 }