Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\engine\Agent.class
?? 1? ? ?? ?? ?? ??? ?? ?? ?? ?? ??? ? ?? ?? ?? ?? ?? ?? ??? ? ?? ?? ???? ?? ? ?? ? ??? "? ??? "???? "? ? ??? ?? "? ?? ?? ?? ?? ?? ??? "? ??? ?? 9? ??? ??? ??? A?? C? "? A? C?? "? "? ?? x? C? A? ?? ?? ?? ?? ?? ' ???? x??? ?? ??? C??? A???? "? ?? z??? ?? ?? ?? ?? ?? ? ?? ?? ?? ?? ?? ??? x?? z? ? z ? ? z ? ? ? ? ? ? ? ? ?? ? ? ?? ? ? ? ? ? ! ?"# ?$% ?&' () ?* ?+ ?, ?- ?. ?/ ?0 ?" ?$ x1 A12 ?3 ?1 ?45 ?? ?6 C7 C18 ?? ?1 9: ?;<=>?@ABC ?DEFGH (I ?J KL KMN ?O ?PQ ?RS ?T UVW maxMemory I maxThreads traceLevel heapSize logFile Ljava/lang/String; mgwguid jobid agentName admin_mgr Loracle/mgw/admin/AdminMgr; link_mgr Loracle/mgw/engine/MsgLinkMgr; dest_mgr Loracle/mgw/engine/DestMgr; job_mgr Loracle/mgw/engine/JobMgr; sch_mgr Loracle/mgw/engine/SchMgr; notifHandler Loracle/mgw/engine/NotifHandler; dbparams Loracle/mgw/common/DBParams; config Loracle/mgw/engine/Config; scheduler Loracle/mgw/engine/Scheduler; eventThr Loracle/mgw/engine/EventThr; pollingThr Loracle/mgw/engine/PollingThr; configNotifier !Loracle/mgw/admin/ConfigNotifier; cmdNotifier Loracle/mgw/admin/CmdNotifier; worker [Loracle/mgw/engine/Worker; m_stop_lock Ljava/lang/Object; m_stop_flag Z FACILITY ConstantValue COMPONENT logger Loracle/mgw/common/MgwLog; STARTUP_EXIT???? ERROR_EXIT???? VERSION_EXIT???? DBSHUTDOWN_EXIT???? DBSHUTDOWN_ERR_EXIT???? ROGUE_EXIT???? BROKEN_EXIT???? NORMAL_EXIT VERSION m_exitSyncObj [B m_exitValue <init> ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V Code LineNumberTable LocalVariableTable this Loracle/mgw/engine/Agent; dbname username passwd connType logLevel start ()I wrapper Loracle/mgw/common/MgwThrWrap; e $Loracle/mgw/admin/MgwAdminException; Ljava/lang/Throwable; getConfiguration ()Loracle/mgw/engine/Config; cfg Exceptions handleEvent (Loracle/mgw/common/Event;)V event Loracle/mgw/common/Event; shutdown ()V i ee Ljava/lang/InterruptedException; getExitPriority (I)I exitValue priority setExitValue (I)V exv setExitValueFromMode mode +(Ljava/lang/String;Ljava/lang/Throwable;I)V info ex (Ljava/lang/String;I)V *(Ljava/lang/String;Ljava/lang/Throwable;)V (Ljava/lang/String;)V waitForEnd initAgent lp )Loracle/mgw/common/MsgLinkParamsNFactory; dp Loracle/mgw/common/DestParams; schp Loracle/mgw/common/SchParams; sch Loracle/mgw/engine/SchData; state subp Loracle/mgw/common/SubParams; latency J maxConns numElem aqLinkMgr !Loracle/mgw/drivers/aq/AQLinkMgr;X stopAgent getLinkMgr ()Loracle/mgw/engine/MsgLinkMgr; getJobMgr ()Loracle/mgw/engine/JobMgr; getAdminMgr ()Loracle/mgw/admin/AdminMgr; getScheduler ()Loracle/mgw/engine/Scheduler; getDestMgr ()Loracle/mgw/engine/DestMgr; getSchMgr ()Loracle/mgw/engine/SchMgr; getPoller ()Loracle/mgw/engine/PollingThr; getLogger ()Loracle/mgw/common/MgwLog; getDBParams ()Loracle/mgw/common/DBParams; getConfigNotifier #()Loracle/mgw/admin/ConfigNotifier; getCmdNotifier ()Loracle/mgw/admin/CmdNotifier; getMaxThreads getAgentName ()Ljava/lang/String; getJobId agentMain ([Ljava/lang/String;I)I !Ljava/lang/NumberFormatException; temp version ie database password sleep agent rtEx Ljava/lang/RuntimeException; er Ljava/lang/Error; args [Ljava/lang/String; main ([Ljava/lang/String;)V retVal SourceFile Agent.java; ? ? ? ? ? ? ? ? java/lang/Object ? oracle/mgw/common/DBParamsY ? ? ? ? ? ? ? ? ? ? ? ? ? ? oracle/mgw/common/MgwThrWrapZ[\]^_`r Engine java/lang/StringBuilder MGW Agent version: abcd{e{fg oracle/mgw/admin/AdminMgrh ? ? MGW Component version: i{ MGW agent name: , MGW job instance id: , MGW database instance: j,aklm MGW guid: nop{qrstuv23 ? ?fKO; wxN; "oracle/mgw/admin/MgwAdminExceptionyLz,CD java/lang/Throwable:; Exiting with return code {; oracle/mgw/admin/CmdNotifier oracle/mgw/admin/ConfigNotifier|;}; Initializing~3;?D ? ? ? ? ? ??? Event Handling thread completed $Event Handling thread did not start. Polling thread completed Polling thread did not start. completed did not start. config notifier thread completed %config notifier thread did not start. !command notifier thread completed &command notifier thread did not start. java/lang/InterruptedException ? ? proposed exit value: , existing exit value: ?@??FDb;:H?;?????,?, ? ?y,?? oracle/mgw/engine/PollingThr? oracle/mgw/engine/MsgLinkMgr????,?? 'oracle/mgw/common/MsgLinkParamsNFactory?? oracle/mgw/drivers/aq/AQLinkMgrz{??? oracle/mgw/engine/DestMgr? ? ??? oracle/mgw/common/DestParams???{ @?{?{f? oracle/mgw/engine/JobMgr ? ? oracle/mgw/engine/Scheduler? oracle/mgw/engine/SchMgr ? ??? oracle/mgw/common/SchParams oracle/mgw/engine/SchData????{ (?{ --> ?{ )?? oracle/mgw/common/SubParams??,????????,???{+; oracle/mgw/engine/Worker??; oracle/mgw/engine/NotifHandler ? ??? oracle/mgw/engine/EventThr?; -database?? -username -password -connType -mgwguid -jobid -agentName -logLevel java/lang/IntegerM java/lang/NumberFormatException -version -logFile oci? ???????? oracle/mgw/engine/Agent +, java/lang/RuntimeException?? java/lang/Error}~??D oracle/mgw/common/EventHandler oracle/mgw/common/FatalException K(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V oracle/mgw/common/ThrowableWrap setWrapper $(Loracle/mgw/common/ThrowableWrap;)V oracle/mgw/common/MgwLog createLogger 8(Ljava/lang/String;IILoracle/mgw/common/ThrowableWrap;)V getMgwLogger append -(Ljava/lang/String;)Ljava/lang/StringBuilder; oracle/mgw/common/MgwVersion getFullVersion toString logMsg ((Ljava/lang/String;ILjava/lang/String;)V 8(Loracle/mgw/common/DBParams;Loracle/mgw/engine/Agent;)V getMgwComponentVersion getDbInst (I)Ljava/lang/StringBuilder; isTRACE_LITE (I)Z trace )(Ljava/lang/String;Ljava/lang/String;II)V getMgwGuid java/lang/String equals (Ljava/lang/Object;)Z oracle/mgw/common/MgwUtil FatalException ^(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/FatalException; setAgentStateInfo (ILjava/lang/String;)V exception getErrorType destroyLogger lockAgentConfig purgeMessageSources getConfig unlockAgentConfig stopThread join (J)V log <(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)V wait oracle/mgw/engine/Config agentParams Loracle/mgw/engine/AgentParams; oracle/mgw/engine/AgentParams getMaxConnections getMaxMemory valueOf (I)Ljava/lang/String; (Loracle/mgw/engine/Agent;)V links Ljava/util/Vector; java/util/Vector size elementAt (I)Ljava/lang/Object; addLink -(Loracle/mgw/common/MsgLinkParamsNFactory;I)V 3(Ljava/lang/String;Loracle/mgw/common/DBParams;II)V setAQLinkMgr $(Loracle/mgw/drivers/aq/AQLinkMgr;)V ?(Loracle/mgw/admin/AdminMgr;Loracle/mgw/drivers/aq/AQLinkMgr;)V dests addForeignDest ?(Loracle/mgw/engine/MsgLinkMgr;Loracle/mgw/common/DestParams;)V getDestID getLinkName getNativeName :(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)V (Loracle/mgw/engine/Agent;I)V schedules (Loracle/mgw/common/SchParams;)V addSch (Loracle/mgw/engine/SchData;)V getScheduleID getSrcQueueName getDestQueueName subscribers oracle/mgw/common/MgwConstants pollingInterval isValid ()Z findScheduleForSub :(Loracle/mgw/common/SubParams;)Loracle/mgw/engine/SchData; m_enabled m_latency Ljava/lang/Integer; intValue createJob "(Loracle/mgw/common/SubParams;IJ)V getSubscriberID (ILoracle/mgw/engine/Agent;)V cleanDeletedPendingSubs setNotifHandler #(Loracle/mgw/engine/NotifHandler;)V notifyAll equalsIgnoreCase (Ljava/lang/String;)Z DEBUG_SLEEP_TIME getIntProperty (Ljava/lang/String;I)I java/lang/Thread currentThread ()Ljava/lang/Thread; logMsgEx +(Ljava/lang/String;ILjava/lang/Throwable;)V java/lang/System exit ! ? ? &