Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\admin\AdminMgr.class
?? 1? )? (? (?? ??? ? (?? ? (? (? ?? (? (?? ?? ( ? ? ? W ? ( ( ( ( ( ( / / ! "[#$ ?% &'( ;) &*+ ,- >. (/j0 ;12345 H678797: ?; <=7>7?7#@ AsBwC &D7EFGHFI &JKFL ?M N O ;PQF#RST hU h? hV h#WXYZ[ n\ (]^ (_` (ab (c (d?efg h> hhijklmn op (qr ;s &t (u?v h8?w (xy ?? ?z ({ ?|} ~ ?? ?? ?? ?? ?? ?; ??? ? <? ? ? ? ?? ?? (? (? ? (? ? ? ?? ?M ?? ?? (? ?? ? ? ? ? ? ? ? ?? (? (? ? ?? ?? ?? ?? ? ? ? ?? (? (? (? ? ?? ?? ?? ?? ???? ?? ? ? ?? ?? ?? ?? ??? ?? ?? ?? ?? ?? ??? ?? ?? ?? ?? ?? ???????????? ?? ? (? ????? ?? ?? ?? ? ??? ? ?? ?? ?? ????FVFh? ? ?? ?? ?? ,? ???? FACILITY Ljava/lang/String; ConstantValue m_tracer Loracle/mgw/common/Trace; m_apiTracer Loracle/mgw/common/ApiTrace; m_agent Loracle/mgw/engine/Agent; m_conn Ljava/sql/Connection; m_connString m_dbparams Loracle/mgw/common/DBParams; m_staticLink #Loracle/mgw/admin/sqlj/MgwiMsgLink; m_staticQ (Loracle/mgw/admin/sqlj/MgwiForeignQueue; m_staticSub &Loracle/mgw/admin/sqlj/MgwiSubscriber; m_staticSched $Loracle/mgw/admin/sqlj/MgwiSchedule; m_mgwInfoNotObtained Z m_ap Loracle/mgw/engine/AgentParams; m_mgwguid m_mgwjob I m_dbinst s_subStateStmt <init> 8(Loracle/mgw/common/DBParams;Loracle/mgw/engine/Agent;)V Code LineNumberTable LocalVariableTable err e Ljava/sql/SQLException; this Loracle/mgw/admin/AdminMgr; dbparams agent event Exceptions getConfig ()Loracle/mgw/engine/Config; cfg Loracle/mgw/engine/Config; setConnectionInfo (Loracle/mgw/common/DBParams;)V reason exClass sqle mae $Loracle/mgw/admin/MgwAdminException; dp setSubInfo ((Ljava/lang/String;ILjava/lang/String;)V guid numErrs errMsg errStamp Ljava/sql/Timestamp; pSetSubInfo O(Ljava/lang/String;Ljava/lang/Integer;ILjava/lang/String;Ljava/sql/Timestamp;)V sql_stmt se status Ljava/lang/Integer; errTime pstmt Ljava/sql/PreparedStatement; setSubStatistic (Ljava/lang/String;II)V numMsgs numExceptionMsgs setAgentStateInfo (ILjava/lang/String;)V msgcode exctype state info rs Ljava/sql/ResultSet; getMgwComponentVersion ()Ljava/lang/String; cstmt %Loracle/jdbc/OracleCallableStatement; componentVersion getMgwInfo ()V getAgentParams !()Loracle/mgw/engine/AgentParams; getMgwGuid getMgwJob ()I getDbInst removeSubscriber (Ljava/lang/String;)V msg retCode shutdown me lockAgentConfig (I)V timeout unlockAgentConfig getSchedules ()Ljava/util/Vector; schedParams Loracle/mgw/common/SchParams; isched isInbound isEnabled propType tmpBD Ljava/math/BigDecimal; latency i schednames Ljava/util/Vector; scheds getSubscribers subParams Loracle/mgw/common/SubParams; isub isValid configState options Ljava/util/Hashtable; jmsSubscriber flags subnames subs getForeignQueues &(Ljava/util/Vector;)Ljava/util/Vector; destParams Loracle/mgw/common/DestParams; iqueue domain isTopic Ljava/lang/Boolean; linkname links destnames dests getLinks linkParams )Loracle/mgw/common/MsgLinkParamsNFactory; linknames getLink =(Ljava/lang/String;)Loracle/mgw/common/MsgLinkParamsNFactory; mqprops -Loracle/mgw/admin/sqlj/MgwMqseriesProperties; port tbprops *Loracle/mgw/admin/sqlj/MgwTibrvProperties; maxConns link isAQLink getLinkNames )(Ljava/sql/Connection;)Ljava/util/Vector; conn getForeignQueueNames fqnames getSubIds subIds getSchedIds schedIds resetSubInfo N(Loracle/mgw/admin/sqlj/MgwiSubscriber;)Loracle/mgw/admin/sqlj/MgwiSubscriber; sub newstatus checkAndResetConnection getOptionHashtable N(Loracle/mgw/admin/sqlj/MgwProperties;Ljava/lang/String;)Ljava/util/Hashtable; name value j props $[Loracle/mgw/admin/sqlj/MgwProperty; opts %Loracle/mgw/admin/sqlj/MgwProperties; traceStr setAgentJavaProps sb Ljava/lang/StringBuffer; pname pvalue encrypt hm Ljava/util/HashMap; SourceFile AdminMgr.javaI?34@A oracle/mgw/common/Trace AdminMgrI-. oracle/mgw/common/ApiTraceI/0675+12 java/lang/StringBuilder .Connecting to database using connect string = ???? java/sql/SQLException? ? oracle/mgw/engine/Config?????C??????????????? oracle/jdbc/OracleConnection ?!" JDBC statement caching enabled#$%?&? reset connection: '()?* "oracle/mgw/admin/MgwAdminException+??, java/sql/Timestamp-./I0jk subscriber GUID is nullIx Yupdate sys.mgw$_subscribers set num_fails = ?,err_time = ?,err_message = ? where guid = ? kupdate sys.mgw$_subscribers set num_fails = ?,err_time = ?,err_message = ?,config_state = ? where guid = ?12 #oracle/jdbc/OraclePreparedStatement3456789x:?;<=>?@A?B Supdate sys.mgw$_subscribers set curr_prop_msgs = ?,curr_exq_msgs = ? where guid = ? Xselect agent_status, job_instance_id from sys.mgw$_gateway where agent_name=? for updateC?DEFG agent_statusHIJ? job_instance_idKLMNOPIQ Aupdate sys.mgw$_gateway set agent_status = ? where agent_name = ? 3begin ?:=sys.mgwi_admin.mgw_component_version; end;RS #oracle/jdbc/OracleCallableStatementT6K ?elect max_connections, max_memory, max_threads, rawtohex(gw_guid) mgw_guid, agent_job, agent_instance from sys.mgw$_gateway where agent_name=? oracle/mgw/engine/AgentParams max_memory max_connections max_threadsIUBC mgw_guidD+ agent_jobEF agent_instanceGF?? removing subscriber, , from configuration ;begin ?:=sys.mgwi_admin.remove_subscriber_by_agent(?); end;HV AdminMgr.removeSubscriber: subscriber does not exist removed old-style subscriber removed subscriber and schedule 'removed subscriber, schedule is missing unknown return code, W Shutting downwxXY?Z??? (begin sys.mgwi_admin.lock_admin(?); end; 'begin sys.mgwi_admin.unlock_admin; end;?? java/util/Vector[?>?\] java/lang/String^_ schedule, ` , is nullab attribute, propType, is nullcb attribute, state, is nullde java/lang/IntegerfghiI? oracle/mgw/common/SchParamsjklmn?o?p?Iqrs??<=^t??ubvwoxoyz AdminMgr: Subscriber options??{b oracle/mgw/common/SubParams|?}?~?I??:;^??b java/lang/BooleanI AdminMgr: Foreign Queue options?? oracle/mgw/common/DestParams????I?????89^??b link type is null for, AdminMgr: Message Link options?? mqseries props is null for, ??b?b Invalid value: maxConns AQ_FOREIGN_MSGLINK?? *oracle/mgw/drivers/aq/AQLinkParamsNFactory??????????I? *oracle/mgw/drivers/mq/MQLinkParamsNFactory???????bI??? tibrv props is null for, *oracle/mgw/drivers/rv/RVLinkParamsNFactory???????????I? unsupported link type for, 7select link_name from sys.mgw$_links where agent_name=? link_name |select f.name, f.link_name from sys.mgw$_foreign_queues f, sys.mgw$_links l where f.link_name=l.link_name and l.agent_name=? vselect s.subscriber_id from sys.mgw$_subscribers s, sys.mgw$_links l where s.link_name=l.link_name and l.agent_name=? subscriber_id ?elect s.schedule_id from sys.mgw$_schedules s, sys.mgw$_links l where s.link_name=l.link_name and l.agent_name=? and BITAND(s.flags,1)!=1 schedule_id subscriber status is null?o??st?? connection internal set/reset? !oracle/mgw/admin/sqlj/MgwiMsgLinkI? &oracle/mgw/admin/sqlj/MgwiForeignQueue $oracle/mgw/admin/sqlj/MgwiSubscriber "oracle/mgw/admin/sqlj/MgwiSchedule??? java/util/Hashtable????????? : = ?elect name, decode(encrypted,1,sys.mgwi_crypto.decrypt_str_11g(enc_value),value), encrypted from sys.mgw$_agent_options where agent_name=? and type=1 java/util/HashMap java/lang/StringBuffer Java System property: ? <<encrypted>>????? oracle/mgw/admin/AdminMgr java/lang/Object oracle/mgw/common/MgwLog getLogger ()Loracle/mgw/common/Log; ?(Loracle/mgw/common/Log;ILjava/lang/String;Ljava/lang/String;)V (Loracle/mgw/common/Trace;IIII)V oracle/mgw/admin/AdminUtil getConnectionString 0(Loracle/mgw/common/DBParams;)Ljava/lang/String; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString log getErrorCode valueOf (I)Ljava/lang/String; oracle/mgw/common/Log getMsg 9(ILjava/lang/String;Ljava/lang/String;)Ljava/lang/String; packageSQLError F(Loracle/mgw/common/Trace;Ljava/sql/SQLException;ILjava/lang/String;)V methodEntry java/sql/Connection setTransactionIsolation agentParams subscribers schedules commit oracle/mgw/common/MgwConstants isStatementCaching ()Z setImplicitCachingEnabled (Z)V setStatementCacheSize isLevel (I)Z trace (Ljava/lang/String;I)V methodExit close classifySQLException (Ljava/sql/SQLException;)I oracle/mgw/engine/Agent +(Ljava/lang/String;Ljava/lang/Throwable;I)V getReason *(Ljava/lang/String;Ljava/lang/Throwable;)V java/lang/System currentTimeMillis ()J (J)V prepareStatement 0(Ljava/lang/String;)Ljava/sql/PreparedStatement; setDisableStmtCaching java/sql/PreparedStatement setInt (II)V setTimestamp (ILjava/sql/Timestamp;)V setString intValue oracle/mgw/common/MgwUtil hexToBytes (Ljava/lang/String;)[B setBytes (I[B)V execute rollback '(ILjava/lang/String;)Ljava/lang/String; getAgentName executeQuery ()Ljava/sql/ResultSet; java/sql/ResultSet next getInt (Ljava/lang/String;)I getJobId getString &(Ljava/lang/String;)Ljava/lang/String; equals (Ljava/lang/Object;)Z exception (Ljava/lang/Throwable;)V (ILjava/lang/String;I)V prepareCall 0(Ljava/lang/String;)Ljava/sql/CallableStatement; registerOutParameter (III)V (I)I (I)Ljava/lang/StringBuilder; isClosed getErrorType setExitValueFromMode size elementAt (I)Ljava/lang/Object; loadEntry 8(Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiSchedule; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; getMProptype ()Ljava/lang/Integer; getMState getMLatency ()Ljava/math/BigDecimal; java/math/BigDecimal toBigInteger ()Ljava/math/BigInteger; java/math/BigInteger getMGuid ()[B bytesToHex ([B)Ljava/lang/String; getMId getMSource getMDestination `(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Integer;ZZ)V addElement (Ljava/lang/Object;)V :(Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiSubscriber; getMConfigstate oracle/mgw/admin/DBConstants CREATE_AGENT DELETE_PENDING getMOptions '()Loracle/mgw/admin/sqlj/MgwProperties; getMFlags getMRule getMTransformation getMExceptionqueue ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/lang/String;ZZLjava/util/Hashtable;)V N(Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiForeignQueue; getMDomain getMLink getMName getMProviderQueue s(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Boolean;Ljava/util/Hashtable;)V 7(Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiMsgLink; getMLinktype getMMqseriesprop /()Loracle/mgw/admin/sqlj/MgwMqseriesProperties; +oracle/mgw/admin/sqlj/MgwMqseriesProperties getPort getMaxConnections get &(Ljava/lang/Object;)Ljava/lang/Object; getMLinkname getUsername getPassword getInboundLogQueue getOutboundLogQueue ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V getQueueManager getHostname getChannel getInterfaceType ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Integer;Ljava/util/Hashtable;)V getMTibrvprop ,()Loracle/mgw/admin/sqlj/MgwTibrvProperties; (oracle/mgw/admin/sqlj/MgwTibrvProperties getService getNetwork getDaemon getCmName getCmLedger ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V CREATE_USER setMConfigstate (Ljava/lang/Integer;)V getJdbcConnection 3(Loracle/mgw/common/DBParams;)Ljava/sql/Connection; setAutoCommit (Ljava/sql/Connection;)V #oracle/mgw/admin/sqlj/MgwProperties getArray &()[Loracle/mgw/admin/sqlj/MgwProperty; !oracle/mgw/admin/sqlj/MgwProperty getName getValue toUpperCase put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; ,(Ljava/lang/String;)Ljava/lang/StringBuffer; getProperties ()Ljava/util/Properties; java/util/Properties putAll (Ljava/util/Map;)V !() *+ , -. /0 12 34 5+ 67 89 :; <= >? @A BC D+ EF GF H+ , U IJ K B ?*? *? *? *? Y? ? ? >*? Y*? ? ? *+? *+? ? *,? *? ? Y? ? *? ? ? ? *? *? ? .:*? ? ?? ? *? ? :*? ?? ? I o r L F z [ g { "