Edit D:\app\Administrator\product\11.2.0\dbhome_1\opmn\lib\oracle\ons\Subscriber.class
?? 1 ? ? ? ? ? ? ? ? ? ? ? 5 ????????? 5 ? 5 ? ? ? 5 ? 5 ? 5 ? 5 ? ? ? 5 ? ? ? 5 ? 5 ? ? 5 ? 5 ? ? ? ? ? ? 5 ? ? ? ? ? ? % ? % ? ? ? ? ) ? % ? 5 ? ? % ? ? ? ? ? ? ? ? subscription Ljava/lang/String; component pub Loracle/ons/Publisher; oems Loracle/ons/ONS; closed Z id I queue Loracle/ons/NotificationQueue; cb Loracle/ons/CallBack; cbmode cblock Ljava/lang/Object; numcbthreads cbthread Loracle/ons/CallBackThread; CBMODE_ONETHREAD ConstantValue CBMODE_THREADPERCB <init> '(Ljava/lang/String;Ljava/lang/String;)V Code LineNumberTable LocalVariableTable this Loracle/ons/Subscriber; s c sm Ljava/lang/SecurityManager; Exceptions ? ((Ljava/lang/String;Ljava/lang/String;J)V timeout J 7(Loracle/ons/ONS;Ljava/lang/String;Ljava/lang/String;)V o 8(Loracle/ons/ONS;Ljava/lang/String;Ljava/lang/String;J)V realStartup getPublisher ()Loracle/ons/Publisher; receive (Z)Loracle/ons/Notification; blocking (J)Loracle/ons/Notification; wait close ()V relinquish (Loracle/ons/Notification;)V e Loracle/ons/Notification; ()Ljava/lang/String; ()I setID (I)V i deliver cbt n register_callback (Loracle/ons/CallBack;I)V mode cancel_callback Ljava/lang/Exception; numthreads cbthread_exit SourceFile Subscriber.java P l ? ? ? oracle/ons/SubscribePermission ONSUser P ? ? ? ? ? ? ? ; < c ] 6 7 oracle/ons/Publisher P ? 9 : 8 7 = > ? @ oracle/ons/NotificationQueue A B ? ? C D E @ java/lang/Object F G H @ oracle/ons/PublishPermission ? ? oracle/ons/Notification ? ? | l ? t k l oracle/ons/CallBackThread P ? ? l ? ? oracle/ons/SubscriptionException "Callback object already registered P ? I J No callback object registered ? l ? ? ? ? ? java/lang/Exception oracle/ons/Subscriber oracle/ons/ONSException java/lang/System getSecurityManager ()Ljava/lang/SecurityManager; (Ljava/lang/String;)V java/lang/SecurityManager checkPermission (Ljava/security/Permission;)V oracle/ons/ONS getONS ()Loracle/ons/ONS; %(Loracle/ons/ONS;Ljava/lang/String;)V addSubscriber (Loracle/ons/Subscriber;J)V dequeue (Z)Ljava/lang/Object; (J)Ljava/lang/Object; removeSubscriber H(Loracle/ons/Subscriber;Loracle/ons/CallBack;Loracle/ons/Notification;)V start enqueue (Ljava/lang/Object;)V /(Loracle/ons/Subscriber;Loracle/ons/CallBack;)V set_shutdown java/lang/Thread currentThread ()Ljava/lang/Thread; sleep (J)V ! 5 6 7 8 7 9 : ; <