Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\eons\impl\SenderThread.class
?? 1F V ? U ? U ? ? U ? U ? U ? ? ? U ? U ? ? ? U ? U ? ? ? ? U ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? # ? ? ? ? ? ? ? ? ? ) ? ( ? ? ? ? ? ? U ? ? ? ? ? ? ? ? U ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? U ? ? ? ? ? ? ? ? ? ? ? ? ? ? ' ? ? ? ? ? ? ? ? ? oems Loracle/eons/impl/ONSImpl; shutdown Z q $Loracle/eons/impl/NotificationQueue; Signature FLoracle/eons/impl/NotificationQueue<Loracle/eons/impl/JGroupMessage;>; myTierId Ljava/lang/String; myAddress Lorg/jgroups/Address; msgCount I showPayload lastOnsCapture J <init> 2(Loracle/eons/impl/ONSImpl;Lorg/jgroups/Address;)V Code LineNumberTable LocalVariableTable se Ljava/lang/SecurityException; this Loracle/eons/impl/SenderThread; o addr run ()V la Loracle/eons/LogicalAddress; i$ Ljava/util/Iterator; gwAddr %Loracle/eons/impl/LogicalAddressImpl; arr$ &[Loracle/eons/impl/LogicalAddressImpl; len$ jgaddrs Ljava/util/Set; fwdToGateways destinations Ljava/util/Collection; e *Lorg/jgroups/ChannelNotConnectedException; $Lorg/jgroups/ChannelClosedException; ex Ljava/lang/Exception; payload Loracle/eons/impl/JGroupMessage; msg Lorg/jgroups/Message; LocalVariableTypeTable &Ljava/util/Set<Lorg/jgroups/Address;>; 4Ljava/util/Collection<Loracle/eons/LogicalAddress;>; handleTerminalException (Ljava/lang/Exception;)V passToTransport (Lorg/jgroups/Message;)V Exceptions printPayload onsmsg cnfe "Ljava/lang/ClassNotFoundException; payloadMsg Ljava/lang/StringBuilder; onsmsgBuf [B send #(Loracle/eons/impl/JGroupMessage;)V toString ()Ljava/lang/String; SourceFile SenderThread.java h t f g EonsSenderThread Y Z W X ? _ ` a b "oracle/eons/impl/NotificationQueue h [ \ c d oracle.eons.showPayload e Z java/lang/SecurityException oracle/eons/impl/JGroupMessage org/jgroups/Message h java/lang/StringBuilder !run ==> have an message, payload= ? ? ? java/util/HashSet !"#$%& oracle/eons/LogicalAddress #oracle/eons/impl/LogicalAddressImpl'() ?*+,-.,/0 ? ?1 )Forwarding message to following gateways:23 destination gateway: (org/jgroups/ChannelNotConnectedException ? ? "org/jgroups/ChannelClosedException java/lang/Exception4 ONS-215 Y t6 Message delivery halted Sending message to channel - 789 ? ? ? ?:; 2Additional data related to previous send: msgsize=< , message detail:=>? java/lang/ClassNotFoundException not available@ABC eONS Runtime state capture: send ==> queueing event msg=DE t ONS-22 EonsSenderThread (msgs: ) oracle/eons/impl/SenderThread java/lang/Thread setDaemon (Z)V setName (Ljava/lang/String;)V oracle/eons/impl/ONSImpl getLocalTierId (Ljava/lang/Object;)V java/lang/Boolean getBoolean (Ljava/lang/String;)Z dequeue (Z)Ljava/lang/Object; oracle/eons/impl/OnsUtil convertObj2Bytes (Ljava/io/Serializable;)[B /(Lorg/jgroups/Address;Lorg/jgroups/Address;[B)V oracle/eons/impl/OnsLogger logger Ljava/util/logging/Logger; java/util/logging/Level FINEST Ljava/util/logging/Level; java/util/logging/Logger isLoggable (Ljava/util/logging/Level;)Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; log .(Ljava/util/logging/Level;Ljava/lang/String;)V ()Ljava/util/Collection; java/util/Collection iterator ()Ljava/util/Iterator; java/util/Iterator hasNext ()Z next ()Ljava/lang/Object; getInternalAddress ()Lorg/jgroups/Address; getTierId java/lang/String equals (Ljava/lang/Object;)Z java/util/Set add setDest (Lorg/jgroups/Address;)V FINER getCurrentGatewayAddrs (()[Loracle/eons/impl/LogicalAddressImpl; WARNING C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V FINE channel Loracle/eons/blab/BlabChannel; oracle/eons/blab/BlabChannel getRawBuffer ()[B (I)Ljava/lang/StringBuilder; convertBytes2Obj ([B)Ljava/io/Serializable; (C)Ljava/lang/StringBuilder; INFO java/lang/System currentTimeMillis ()J enqueue drain_and_close 0 U V W X Y Z [ \ ] ^ _ ` a b B c d e Z f g h i j ? R*? * ? *? *? *? *+? **? ? ? *,? *? Y*? ? *? *? ? ? N*? ? ? H K k >