Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\eons\impl\OnsBridgeSenderThread.class
?? 1 ? ; i : j k : l : m : n o p : q o r : s t u : v o w x y z { | } : ~ ? ? ? ? ? ? ? ? o ? ? : ? ? ? ? ? ? ? ? ? ? ? " i ? " ? " ? " ? ? o ? ? ? ? ? ? ? ? ? ? ? ? o ? ? : ? ? ? ? ? ? ? ? ? bridge Loracle/eons/impl/OnsBridge; shutdown Z q $Loracle/eons/impl/NotificationQueue; Signature ;Loracle/eons/impl/NotificationQueue<Lorg/jgroups/Message;>; myBridgeId Ljava/lang/String; myAddress Lorg/jgroups/Address; <init> (Loracle/eons/impl/OnsBridge;)V Code LineNumberTable LocalVariableTable this (Loracle/eons/impl/OnsBridgeSenderThread; b run ()V localAddrs Ljava/util/List; peerBridgeAddr i$ Ljava/util/Iterator; dst msg Lorg/jgroups/Message; LocalVariableTypeTable 7Ljava/util/List<Loracle/eons/impl/LogicalAddressImpl;>; passToTransport -(Lorg/jgroups/Address;Lorg/jgroups/Message;)V e *Lorg/jgroups/ChannelNotConnectedException; ex Ljava/lang/Exception; addr send #(Loracle/eons/impl/JGroupMessage;)V Loracle/eons/impl/JGroupMessage; 8(Loracle/eons/impl/JGroupMessage;Lorg/jgroups/Address;)V SourceFile OnsBridgeSenderThread.java H Q ? ? EonsBridgeSenderThread ? ? > ? < = ? ? ? F G ? ? D E "oracle/eons/impl/NotificationQueue H ? @ A ? ? ? ? ? oracle/eons/impl/JGroupMessage ? ? ? H ? c d ? ? org/jgroups/Message ? ? ? ? ? ? #Bridge sending to following peers: ? ? ? ? ? ? ? \ ] ? ? ? ? ? ? ? ? org/jgroups/Address ? ? java/lang/StringBuilder destination bridge peer: ? ? ? ? ? ? ? ? ? ? ? c ? (org/jgroups/ChannelNotConnectedException ? ? Message delivery halted ? ? ONS-21 ? ? > Q java/lang/Exception c f send ==> queueing event msg= ? ? H ? ? ? ? Q ONS-22 &oracle/eons/impl/OnsBridgeSenderThread java/lang/Thread setDaemon (Z)V setName (Ljava/lang/String;)V oracle/eons/impl/OnsBridge localAddress ()Lorg/jgroups/Address; getBridgeId ()Ljava/lang/String; (Ljava/lang/Object;)V getLocalAddrs ()Ljava/util/List; java/util/List size ()I &oracle/eons/impl/JGroupMessage$MSGTYPE MSGTYPE InnerClasses ADD_SUBSCRIBER (Loracle/eons/impl/JGroupMessage$MSGTYPE; S(Loracle/eons/impl/JGroupMessage$MSGTYPE;Ljava/lang/Object;Ljava/util/Collection;)V dequeue (Z)Ljava/lang/Object; oracle/eons/impl/OnsLogger logger Ljava/util/logging/Logger; java/util/logging/Level FINEST Ljava/util/logging/Level; java/util/logging/Logger log .(Ljava/util/logging/Level;Ljava/lang/String;)V getBridgePeers ()Ljava/util/Collection; getDest java/util/Collection iterator ()Ljava/util/Iterator; java/util/Iterator hasNext ()Z next ()Ljava/lang/Object; isLoggable (Ljava/util/logging/Level;)Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString setDest (Lorg/jgroups/Address;)V channel Loracle/eons/blab/BlabChannel; oracle/eons/blab/BlabChannel (Lorg/jgroups/Message;)V FINE WARNING C(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V setOriginBridge C(Lorg/jgroups/Address;Lorg/jgroups/Address;Ljava/io/Serializable;)V enqueue drain_and_close 0 : ; < = > ? @ A B C D E F G H I J ? <*? *? *? *? *+? **? ? ? **? ? ? *? Y*? ? ? K & $ % & ' ( ) $ * / + ; , L < M N < O = P Q J ? ?*? ? $*? ? L+? ? *? Y? +? ? *? ? ?*? ? ? L+? ?? ? ? *? ? YM?+? N-? *-+? ? Z*? ? ? :? ? B? ? :? ? ? !? ? ? ? "Y? #$? %? &? '? *+? ??,? :,???\? W ? ? ? ? ? K R 7 @ A C ( H / J ; P ? Q B S M U W W \ X ` Z i _ ? a ? c ? f ? i ? j ? k L > R S ? 0 T G w I U V \ d W G ; ? X Y ? M N Z R [ \ ] J ? `,+? (*? ? ),? * ? MN*? ? ? ? ,-? ? ? ? ./-? 0*? ? 1*? ? N? ? ./-? 0*? ? 1*? ? + F 2 K > q r ? t v x + | 7 } > ~ C ? F ? G ? S ? Z ? _ ? L 4 - ^ _ G ` a ` M N ` b G ` X Y c d J ? *+? 3? K ? ? L M N X e c f J ? E? ? ? !? ? ? ? "Y? #4? %+? &? '? +*? ? 5*? ? Y,*? +? 6? 7? K ? ? ( ? 0 ? D ? L E M N E X e E b G > Q J m *? ? 8*? ? L? ? ,9+? 0? 2 K ? ? ? ? ? ? L ^ a M N g h ? { ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de