Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\admin\NotificationProcessor.class
?? 1? q ? p ? p ? p ? ? ? p ????????? p ? p ? ? ? p ? p ? p ? p ? p ? p ? p ? ? ? ? ? p ? p ? p ? p ? ? ? p ? ? ? ! p p p p p ? p p 5 ? 5 5 5! p" p#$ %&' p() * +,-. !/ ?012345 p678 S ?9 S:; <=> <?@ <A S! qBC 5D EFG pH IJKL pMN ?6 pOP Q R pSTUV m_agent Loracle/mgw/engine/Agent; m_dbparams Loracle/mgw/common/DBParams; m_connString Ljava/lang/String; m_conn Ljava/sql/Connection; m_dbMsgSrc Loracle/mgw/admin/DBMsgSrc; m_dbMsgDest m_notifHandler Loracle/mgw/engine/NotifHandler; m_resetConn Z m_shutdownStarted m_tracer Loracle/mgw/common/Trace; m_paramsSyncObj [B m_syncObj Ljava/lang/Object; m_idleTimeout J m_lastUseTime m_primeCount I m_timeout Ljava/lang/Integer; m_sendMessages m_initSyncObj m_initialized <init> (Loracle/mgw/common/DBParams;Loracle/mgw/engine/NotifHandler;Loracle/mgw/engine/Agent;Ljava/lang/Integer;ZLjava/lang/String;I)V Code LineNumberTable LocalVariableTable this (Loracle/mgw/admin/NotificationProcessor; db handler agent timeout sendMessages facility component setIdleTimeout (J)V idleTimeout createMsgSrc 3(Ljava/sql/Connection;Z)Loracle/mgw/admin/DBMsgSrc; Exceptions handleEvent (Loracle/mgw/common/Event;)V event Loracle/mgw/common/Event; purgeMessageSources ()V err e Ljava/sql/SQLException; initLoop msgLoopProcessing1 msgLoopProcessing2 noMessageAvailable handleMessage &(Loracle/mgw/admin/sqlj/MgwNotifMsg;)V myRun mae $Loracle/mgw/admin/MgwAdminException; me "Loracle/mgw/common/FatalException; Loracle/mgw/common/MGWException; exClass se msg #Loracle/mgw/admin/sqlj/MgwNotifMsg; rtEx Ljava/lang/RuntimeException; er Ljava/lang/Error; ex Ljava/lang/Exception; setConnectionInfo (Loracle/mgw/common/DBParams;)V sb Ljava/lang/StringBuffer; dbparams wakeThread start ie Ljava/lang/InterruptedException; forceStop shutdownAgent +(Ljava/lang/String;Ljava/lang/Throwable;I)V reason thr Ljava/lang/Throwable; shutdownType closeConnection conn cleanup resetConnection getConnection ()Ljava/sql/Connection; setConnection (Ljava/sql/Connection;)V checkConnectionIdleTimeout currentTime SourceFile NotificationProcessor.java ?W ? ? ? ? ? ? java/lang/Object ? ? ? ? ? ? ? ? java/lang/Integer ?X ? ? ? ? ? ? u v ~ s t ? ? oracle/mgw/common/TraceYZ[ ?\ ? ? y z ? ? { |]^ ? } |_` Purged message sources.ab java/sql/SQLExceptioncdefg w xhijklmnop ? ? ? ?qrs ? ? ?tuvwu Waiting for notification.xy ? ? ? ?z ? java/lang/StringBuilder 'received notification message of type: {|}~?d{??? ? ? ? ? "oracle/mgw/admin/MgwAdminException?? oracle/mgw/common/FatalException Caught FatalException ? ? oracle/mgw/common/MGWException???? #: Resetting connection due to error : Database is shutting down : x? ?? Error in notification handler java/lang/RuntimeException RTX in notification handler java/lang/Error java/lang/Exception ? ? NotificationProcessor is closed java/lang/StringBuffer Connection reset flag set: {? username: ??? database: ?? conntype: ?? ? ? Waiting on {?? ? java/lang/InterruptedException Thread is initialized. ? ??? ?? ?? ? ? ? closing connection ? ? Creating/Resetting connection???? ? ? &oracle/mgw/admin/NotificationProcessor oracle/mgw/engine/ManagedThr oracle/mgw/common/EventHandler (Ljava/lang/String;)V (I)V oracle/mgw/common/MgwLog getLogger ()Loracle/mgw/common/Log; ?(Loracle/mgw/common/Log;ILjava/lang/String;Ljava/lang/String;)V oracle/mgw/admin/DBMsgSrc purge isLevel (I)Z trace (Ljava/lang/String;I)V getErrorCode ()I java/lang/String valueOf (I)Ljava/lang/String; oracle/mgw/common/Log getMsg 9(ILjava/lang/String;Ljava/lang/String;)Ljava/lang/String; oracle/mgw/admin/AdminUtil packageSQLError F(Loracle/mgw/common/Trace;Ljava/sql/SQLException;ILjava/lang/String;)V java/lang/System currentTimeMillis ()J primeConnection 1(Ljava/sql/Connection;Loracle/mgw/common/Trace;)V notify getStop ()Z java/sql/Connection isClosed getMessage 8(Ljava/lang/Integer;)Loracle/mgw/admin/sqlj/MgwNotifMsg; commit append -(Ljava/lang/String;)Ljava/lang/StringBuilder; !oracle/mgw/admin/sqlj/MgwNotifMsg getAction ()Ljava/lang/Integer; intValue (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; exception (Ljava/lang/Throwable;)V classifySQLException (Ljava/sql/SQLException;)I getFacility +(ILjava/lang/String;Ljava/lang/Throwable;)V ,(Ljava/lang/String;)Ljava/lang/StringBuffer; oracle/mgw/common/DBParams getUserName getDatabase getConnTypeStr -(Ljava/lang/Object;)Ljava/lang/StringBuilder; wait oracle/mgw/engine/Agent shutdown rollback close getConnectionString 0(Loracle/mgw/common/DBParams;)Ljava/lang/String; getJdbcConnection 3(Loracle/mgw/common/DBParams;)Ljava/sql/Connection;! p q r s t u v w x y z { | } | ~ ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ) y*? *? *? *?? *? Y? ? * ? *? *? Y? ? *? Y? ? *? *+? *,? *-? *? *? *? Y? ? ? ? ? F p ? @ H P "