1 ) ( (   (  ( (  ( (     (      W      ( (  (  (  (  (     / /  ! "[  #$ % &'( ;) &*+ ,- >. (/j0 ;123  45 H6 78 79 7: ; <= 7> 7? 7#  @ AsBwC &D 7E FGH FI &JK FL M N O ;PQ F#R  ST hU h? hV h#WXYZ[ n\ (]^ (_` (ab (c (defg h> hhijklmn op (q  r ;s &t (uv h8w (xy  z ({ |} ~      ;   <      ( (   (      M    (                  ( (                 ( ( (                                     (                 FV Fh         , FACILITYLjava/lang/String; ConstantValuem_tracerLoracle/mgw/common/Trace; m_apiTracerLoracle/mgw/common/ApiTrace;m_agentLoracle/mgw/engine/Agent;m_connLjava/sql/Connection; m_connString m_dbparamsLoracle/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_mgwInfoNotObtainedZm_apLoracle/mgw/engine/AgentParams; m_mgwguidm_mgwjobIm_dbinsts_subStateStmt8(Loracle/mgw/common/DBParams;Loracle/mgw/engine/Agent;)VCodeLineNumberTableLocalVariableTableerreLjava/sql/SQLException;thisLoracle/mgw/admin/AdminMgr;dbparamsagentevent Exceptions getConfig()Loracle/mgw/engine/Config;cfgLoracle/mgw/engine/Config;setConnectionInfo(Loracle/mgw/common/DBParams;)VreasonexClasssqlemae$Loracle/mgw/admin/MgwAdminException;dp setSubInfo((Ljava/lang/String;ILjava/lang/String;)VguidnumErrserrMsgerrStampLjava/sql/Timestamp; pSetSubInfoO(Ljava/lang/String;Ljava/lang/Integer;ILjava/lang/String;Ljava/sql/Timestamp;)Vsql_stmtsestatusLjava/lang/Integer;errTimepstmtLjava/sql/PreparedStatement;setSubStatistic(Ljava/lang/String;II)VnumMsgsnumExceptionMsgssetAgentStateInfo(ILjava/lang/String;)VmsgcodeexctypestateinforsLjava/sql/ResultSet;getMgwComponentVersion()Ljava/lang/String;cstmt%Loracle/jdbc/OracleCallableStatement;componentVersion getMgwInfo()VgetAgentParams!()Loracle/mgw/engine/AgentParams; getMgwGuid getMgwJob()I getDbInstremoveSubscriber(Ljava/lang/String;)VmsgretCodeshutdownmelockAgentConfig(I)VtimeoutunlockAgentConfig getSchedules()Ljava/util/Vector; schedParamsLoracle/mgw/common/SchParams;isched isInbound isEnabledpropTypetmpBDLjava/math/BigDecimal;latencyi schednamesLjava/util/Vector;schedsgetSubscribers subParamsLoracle/mgw/common/SubParams;isubisValid configStateoptionsLjava/util/Hashtable; jmsSubscriberflagssubnamessubsgetForeignQueues&(Ljava/util/Vector;)Ljava/util/Vector; destParamsLoracle/mgw/common/DestParams;iqueuedomainisTopicLjava/lang/Boolean;linknamelinks destnamesdestsgetLinks linkParams)Loracle/mgw/common/MsgLinkParamsNFactory; linknamesgetLink=(Ljava/lang/String;)Loracle/mgw/common/MsgLinkParamsNFactory;mqprops-Loracle/mgw/admin/sqlj/MgwMqseriesProperties;porttbprops*Loracle/mgw/admin/sqlj/MgwTibrvProperties;maxConnslinkisAQLink getLinkNames)(Ljava/sql/Connection;)Ljava/util/Vector;conngetForeignQueueNamesfqnames getSubIdssubIds getSchedIdsschedIds resetSubInfoN(Loracle/mgw/admin/sqlj/MgwiSubscriber;)Loracle/mgw/admin/sqlj/MgwiSubscriber;sub newstatuscheckAndResetConnectiongetOptionHashtableN(Loracle/mgw/admin/sqlj/MgwProperties;Ljava/lang/String;)Ljava/util/Hashtable;namevaluejprops$[Loracle/mgw/admin/sqlj/MgwProperty;opts%Loracle/mgw/admin/sqlj/MgwProperties;traceStrsetAgentJavaPropssbLjava/lang/StringBuffer;pnamepvalueencrypthmLjava/util/HashMap; SourceFile AdminMgr.java I 34 @Aoracle/mgw/common/Trace AdminMgr I -.oracle/mgw/common/ApiTrace I /0 67  5+ 12java/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- ./ I0 jksubscriber GUID is null IxYupdate 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/OraclePreparedStatement 34 56 78 9x :; <= >? @ A BSupdate 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 update C DEF G agent_status HI Jjob_instance_id KL MN  OP IQAupdate sys.mgw$_gateway set agent_status = ? where agent_name = ?3begin ?:=sys.mgwi_admin.mgw_component_version; end; RS#oracle/jdbc/OracleCallableStatement T6 Kselect 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_memorymax_connections max_threads IU BCmgw_guid D+ agent_job EFagent_instance GF removing subscriber, , from configuration;begin ?:=sys.mgwi_admin.remove_subscriber_by_agent(?); end; HVAdminMgr.removeSubscriber: subscriber does not existremoved old-style subscriberremoved subscriber and schedule'removed subscriber, schedule is missingunknown return code, W Shutting down wx X Y Z (begin sys.mgwi_admin.lock_admin(?); end;'begin sys.mgwi_admin.unlock_admin; end; java/util/Vector [ >? \]java/lang/String ^_ schedule, ` , is null abattribute, propType, is null cbattribute, state, is null dejava/lang/Integerf ghi Ioracle/mgw/common/SchParams jk lm n o p Iq rs  <= ^t  ubv wo xo yzAdminMgr: Subscriber options  {boracle/mgw/common/SubParams | } ~ I  :; ^ bjava/lang/Boolean IAdminMgr: Foreign Queue options oracle/mgw/common/DestParams   I   89 ^ blink type is null for, AdminMgr: Message Link options mqseries props is null for,  b bInvalid value: maxConnsAQ_FOREIGN_MSGLINK *oracle/mgw/drivers/aq/AQLinkParamsNFactory      I*oracle/mgw/drivers/mq/MQLinkParamsNFactory    b I tibrv props is null for, *oracle/mgw/drivers/rv/RVLinkParamsNFactory      Iunsupported 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_idselect 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_idsubscriber status is null o  st connection internal set/reset !oracle/mgw/admin/sqlj/MgwiMsgLink I&oracle/mgw/admin/sqlj/MgwiForeignQueue$oracle/mgw/admin/sqlj/MgwiSubscriber"oracle/mgw/admin/sqlj/MgwiSchedule java/util/Hashtable    :  = select name, decode(encrypted,1,sys.mgwi_crypto.decrypt_str_11g(enc_value),value), encrypted from sys.mgw$_agent_options where agent_name=? and type=1java/util/HashMapjava/lang/StringBufferJava System property:  <>  oracle/mgw/admin/AdminMgrjava/lang/Objectoracle/mgw/common/MgwLog getLogger()Loracle/mgw/common/Log;?(Loracle/mgw/common/Log;ILjava/lang/String;Ljava/lang/String;)V (Loracle/mgw/common/Trace;IIII)Voracle/mgw/admin/AdminUtilgetConnectionString0(Loracle/mgw/common/DBParams;)Ljava/lang/String;append-(Ljava/lang/String;)Ljava/lang/StringBuilder;toStringlog getErrorCodevalueOf(I)Ljava/lang/String;oracle/mgw/common/LoggetMsg9(ILjava/lang/String;Ljava/lang/String;)Ljava/lang/String;packageSQLErrorF(Loracle/mgw/common/Trace;Ljava/sql/SQLException;ILjava/lang/String;)V methodEntryjava/sql/ConnectionsetTransactionIsolation agentParams subscribers schedulescommitoracle/mgw/common/MgwConstantsisStatementCaching()ZsetImplicitCachingEnabled(Z)VsetStatementCacheSizeisLevel(I)Ztrace(Ljava/lang/String;I)V methodExitcloseclassifySQLException(Ljava/sql/SQLException;)Ioracle/mgw/engine/Agent+(Ljava/lang/String;Ljava/lang/Throwable;I)V getReason*(Ljava/lang/String;Ljava/lang/Throwable;)Vjava/lang/SystemcurrentTimeMillis()J(J)VprepareStatement0(Ljava/lang/String;)Ljava/sql/PreparedStatement;setDisableStmtCachingjava/sql/PreparedStatementsetInt(II)V setTimestamp(ILjava/sql/Timestamp;)V setStringintValueoracle/mgw/common/MgwUtil hexToBytes(Ljava/lang/String;)[BsetBytes(I[B)Vexecuterollback'(ILjava/lang/String;)Ljava/lang/String; getAgentName executeQuery()Ljava/sql/ResultSet;java/sql/ResultSetnextgetInt(Ljava/lang/String;)IgetJobId getString&(Ljava/lang/String;)Ljava/lang/String;equals(Ljava/lang/Object;)Z exception(Ljava/lang/Throwable;)V(ILjava/lang/String;I)V prepareCall0(Ljava/lang/String;)Ljava/sql/CallableStatement;registerOutParameter(III)V(I)I(I)Ljava/lang/StringBuilder;isClosed getErrorTypesetExitValueFromModesize elementAt(I)Ljava/lang/Object; loadEntry8(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/BigIntegergetMGuid()[B bytesToHex([B)Ljava/lang/String;getMId getMSourcegetMDestination`(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;getMConfigstateoracle/mgw/admin/DBConstants CREATE_AGENTDELETE_PENDING getMOptions'()Loracle/mgw/admin/sqlj/MgwProperties; getMFlagsgetMRulegetMTransformationgetMExceptionqueue(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/lang/String;ZZLjava/util/Hashtable;)VN(Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiForeignQueue; getMDomaingetMLinkgetMNamegetMProviderQueues(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Boolean;Ljava/util/Hashtable;)V7(Ljava/lang/String;)Loracle/mgw/admin/sqlj/MgwiMsgLink; getMLinktypegetMMqseriesprop/()Loracle/mgw/admin/sqlj/MgwMqseriesProperties;+oracle/mgw/admin/sqlj/MgwMqseriesPropertiesgetPortgetMaxConnectionsget&(Ljava/lang/Object;)Ljava/lang/Object; getMLinkname getUsername getPasswordgetInboundLogQueuegetOutboundLogQueue(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)VgetQueueManager getHostname getChannelgetInterfaceType(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_USERsetMConfigstate(Ljava/lang/Integer;)VgetJdbcConnection3(Loracle/mgw/common/DBParams;)Ljava/sql/Connection; setAutoCommit(Ljava/sql/Connection;)V#oracle/mgw/admin/sqlj/MgwPropertiesgetArray&()[Loracle/mgw/admin/sqlj/MgwProperty;!oracle/mgw/admin/sqlj/MgwPropertygetNamegetValue toUpperCaseput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;,(Ljava/lang/String;)Ljava/lang/StringBuffer; getProperties()Ljava/util/Properties;java/util/PropertiesputAll(Ljava/util/Map;)V!()*+,-./012345+6789:;<=>?@ABCD+EFGFH+,UIJKB****Y >* Y* *+ *+ *,*Y***.:**:*IorLFz[ g{"}$~7<DIfkortM>N+t)OPQRS7T2$zUFV;WXKE* Y L*!*"+*#$+*%&+*+&'(+*)*+*+,*-*!.2*/0*/1*2 *34M*,X* 5+LV  (0<DLU_erM  OPQRYZV;![\Ke* 6*+ *+ * *7**2!*Y8*4PM*,*N,96*-,: *-,:M*,<,=* 65SVS;LR &*5SVWpv|M>p#]+v^FW<_P `aQRb7cdK:->Y?@:*+-AL M4QRe+fFg+hiV; jkK #* B+;YCD:*:, E:F:*G:HIJKL,,MJ+NO+NOPW*- Q:f:a:*R:*Y+S:*Y Q:!::  Q::  * B5L/   $!&$'()//35@6K8T;^<h=l?x@CEFWXY\[]HLONPQWXY\[]UWXY\[\^"_M$l+mPmPN+,OPmPmP #QR#e+#no#fF#g+#piqrV;!stK> * T:+;YCD**UG:JJ+NOPW*- Q:f:a:*R:*Y+S:*Y Q:!:: Q::* T5]lo]tv]tL&p r stx!y.z7{@|L}T]biloqtvMp qmPmPN+v,OPmPmPQRe+uFvF qrV;!wxK * VN:W:**GN-*XL-Y:Z66[\ a66*]^_` b66C*a:*R: * b* ;Yc-Qd:*GN-J-*XL-PW*- e::- -QNw:r:*R:*Z e::- -QN2:-:  e:: - -QN:  * V5   %'03BQTVbej%Bjl{~jljL&I  "08BEHV[^ty|   "%'035BGNQTVZ`begjlqx{~MmP 2N+E|yFHyzFl+mP"mP5mP'OPVmPgmPmP mP QR{F|+ qr}~V;!KLMfN**-ghL+ i+jW+kM*-+ +lLKNGN*R:*-`+ +lLN:+ +lL:,:FI:MNWZhtw:{Mh{}{}{L" " ) 1 :>DF!I J"MNWZ\hlrt!w x"{}! !$M\ 3l+JmP\mPNOPxmPmPQR+V;!Kp*mLMN*+GM,*XL,YN-ZJ*nY-o\-p\-q\rs*-t_u*-v\w*-x\y- -e, ,QM:- -e, ,QM*~Lf*, 0 156'7.97;Z>f?r@~EFGHIJEFGHILNM* l+ qr}~QRV;K7 *z*sL STM  QRV;K7 *z*uL Z[M  QRV;K7 *z*wL abM  QRV;K7 *z*yL hiM  QRV;Kyk* {*2#*Y|+}4M~N6*-ghM,i,+N,jW,6*-1:*R:*[+S:*[*2: 9RkY:iY:PY:7Y:Y:*4* {5<vy{L"v y{469<JR]dmvy{  #9<WajM\ mPN+{,OP+kQRke+6592l+</FV;!K}** *7`L*+b+*&+*+ *L*+b+9= *;aLN (0;CNV^abjot|M* >ao ^FbmP}QR!K5*L M QRV;!K* MN*-ghM,,jW, ,lMA:<:*\, ,lM::, ,lM:* 5+7:+?NZ]+b?NbdpsbdbLv  $+/57:<?ANRXZ]_bdhnpsuxMR<mPA OP_mPumPQRF wqtl+V;!Kv* LM*,ghL+jW+ +lL=N9N*-]+ +lLN:+ +lL:* 5#/2#6COR#V6CVXdgVXVLr  #!'"-#/&2%3'67C!G"M#O&R%S'VX!\"b#d&g%i&l)u*MH3mP7 OPSmPimPvQR kqhl+V;K ***LYM>+:*+:*;YɻY+D:;YDM6:  ;YD M6: :  Y : Y :,,LbNP QRT"U3W8X_]f^k_xbdefiklmorzR|Mz "3?uALAfon{o E Bo FQR V;K ***LYM>+:*+:*:M66:" 66*: 6 :   M~6 Y  :,*,Ln "38;CVY`epvMz "3=VAYA`oY VA Oo FQR V;K ***MYN6,:*,,`:d::YM:*̷: : Yϸ  :-k-LJ !$AFIPSXo|Mp $Ai;PZoSW|. '+ FQR V;KF***LYM>+(:*+: ,,L.  "058>DM4"-FFQR 91V;K MN*+:!;YɻYض+D*ڷ:6׶MY:!;YɻYܶ+D:N-;Y߷D6<Y*X-MMɻY-MM~:  !;YɻY+DY     M!;YɻY+D,Lz; HKlsx!&(*+6LHOLVM[OyS\uyMf sW-oVt QR+o9HKAV;KHYMN::+-G:*XLY:Z,_ e Q:#: e Q:,LjjljLV )2<LQX]dgjqx}M>QR4 l+~qr{}~VKYYMN::+-G:*XLY:Z ,_,_ e Q:#: e Q:,YwwywLZ )2<IY^ejqtw~M>QR4 l+qr}~VKHYMN::+-G:*XLY:Z,_ e Q:#: e Q:,LjjljLV )2<LQX]dgjqx}M>QR4 l+~qr{}~VKJYMN::+-G:*XLY:Z,_ e Q:#: e Q:,NllnlLV *3=NSZ_filszM>QR4 l+qr|}~VKL+M,;YD,N,N+*+-A*++L*    #'.=JM*LQRL=Gno3oV;K**z* *7** *2*4** Y* * Y* * Y**Y*L2 !"#$.&9'D(N*]+l,{-/M QRV;K4N++:YN6s2:2:TO-W*28*Y,24-L6 78: ;<">,?6@@BLCWE<MMR,`+6V+xF QR+VK6 *LMN::+-G:*XLY:Z::6, YM,W*2 Y,!:  "### $#W* %4q e Q:#:  e Q: ,&,'*2L#[\] abij)k2l<nFoPpcrhsptyvxy{|Mf 1 F~+Pt+caAQR4 l+ qr }~V;