Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\aq\AQLink.class
?? 1 % $ $ $ % % ! "# $ $% $& $' $( $)* +, $-./01 $2 $3 /45 36 $789 :;<= $>? @AB CD %EFG $H 3I J kK 3L $M $NO kP QR kS kT kU $V $W X $Y QZ [\ ]^_ Q` abc ?d ef ?g Qh i [jklm no $pq @ar ks @tu vw kxyz ${| 3s $}~ 3? ?? 3? $?? ?? $? ?? $?? $??? /s $??? $? /? ?? /? $?? ?? $? ?? $?? $?? $? $? ?? ? Q?? $???? ? ?? ?? E? ?? 3? $? ?? ? ??? ?? /? ?? ?? ? ?;? $? ???? ? ?; $? ?? ?? ? ????? [? X?? Q???? [?? Q????? 3? [? $? $? ?? k?? [?? [??? Q?? Q?? ?? %?? ? ?? ? $?? ?? ?? $? ?? ?? ?? ?? ???? ? ? ? ? $ ? ?E $ ? ? $ U T k $ k [! k"# es$ ?%&' CLASS_PREFIX Ljava/lang/String; ConstantValue( FACILITY COMPONENT I DEBUG Z m_jdbcConnFactory 'Loracle/mgw/drivers/aq/JdbcConnFactory; <init> Q(Loracle/mgw/drivers/aq/AQLinkMgr;Loracle/mgw/drivers/aq/AQLinkParamsNFactory;I)V Code LineNumberTable LocalVariableTable this Loracle/mgw/drivers/aq/AQLink; linkMgr !Loracle/mgw/drivers/aq/AQLinkMgr; params ,Loracle/mgw/drivers/aq/AQLinkParamsNFactory; maxThreads makeMessageID !([B)Loracle/mgw/common/MessageID; mid [B method id Loracle/mgw/common/MessageID; Exceptions loggingSupport ()I support alterLinkParams ,(Loracle/mgw/common/MsgLinkParamsNFactory;)V newParams )Loracle/mgw/common/MsgLinkParamsNFactory; -(Loracle/mgw/common/MsgLinkParamsNFactory;I)V alter registerLogSet C(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet; producerId consumerId browserId producerP (Loracle/mgw/drivers/aq/AQProducerParams; consumerP (Loracle/mgw/drivers/aq/AQConsumerParams; browserP setId baseId seq dest Loracle/mgw/common/DestData; whichLog subName jobId logSet Loracle/mgw/common/LogIdSet; unregisterLogSet (Loracle/mgw/common/LogIdSet;)V e Ljava/lang/Exception; removed close ()V getMsgCount (Ljava/lang/String;)I consId consP count aqDest "Loracle/mgw/drivers/aq/AQDestData; getCountForSubscriber 1(Loracle/mgw/common/DestData;Ljava/lang/String;)I conn Ljava/sql/Connection; errm sqlE Ljava/sql/SQLException; oph "Loracle/mgw/drivers/aq/AQOPHandle; trcm topic schema table qname subData &Loracle/mgw/drivers/aq/SubscriberData; getCountForQueue (Loracle/mgw/common/DestData;)I queue registerDestination <(Loracle/mgw/common/DestParams;)Loracle/mgw/common/DestData; dParams Loracle/mgw/common/DestParams; nativeName unregisterDestination (Loracle/mgw/common/DestData;)V registerConsumer }(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V aqSubName subname filter transformation isBrowser options Ljava/util/Hashtable; alterConsumer N(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V newP oldP action unregisterConsumer (Ljava/lang/String;)V registerProducer X(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/util/Hashtable;)V prodP prodId alterProducer <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V unregisterProducer startOperation ()Loracle/mgw/common/OPHandle; Loracle/mgw/common/OPHandle; startLogOperation commit (Loracle/mgw/common/OPHandle;)V aqOPH) rollback gwE2 $Loracle/mgw/common/GatewayException; gwE getConsumer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgConsumer; transName transData %Loracle/mgw/drivers/aq/TransformData; aqOph aqConsumer %Loracle/mgw/drivers/aq/AQMsgConsumer; getProducer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgProducer; aqProducer %Loracle/mgw/drivers/aq/AQMsgProducer; send Y(Loracle/mgw/common/Message;Loracle/mgw/common/MsgProducer;)Loracle/mgw/common/MessageID; msg Loracle/mgw/common/Message; pr Loracle/mgw/common/MsgProducer; aqPr msgId* receive <(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message; cons Loracle/mgw/common/MsgConsumer; aqCons Y(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; removeMsg N(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/MessageID;)Z found moveToExceptionQueue ?(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/DestData;Loracle/mgw/common/MessageID;)Loracle/mgw/common/MessageID; midExq midSrc #Loracle/mgw/drivers/aq/AQMessageID; excD srcD srcQueue excQueue sendToExceptionQueue r(Loracle/mgw/common/OPHandle;Loracle/mgw/common/DestData;Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; subscribe unsubscribe updateSub handleEvent (Loracle/mgw/common/Event;)V event Loracle/mgw/common/Event; initHandlesFactories ociPool *Loracle/jdbc/pool/OracleOCIConnectionPool; stmtCacheSize msgOphFactory )Loracle/mgw/drivers/aq/AQOPHandleFactory; adminOphFactory closeResetHandlesFactories alterCachedConsumer E(Loracle/mgw/common/MsgConsumer;Loracle/mgw/drivers/ConsumerParams;)V #Loracle/mgw/drivers/ConsumerParams; alterCachedProducer E(Loracle/mgw/common/MsgProducer;Loracle/mgw/drivers/ProducerParams;)V prod #Loracle/mgw/drivers/ProducerParams; startAdminOperation $()Loracle/mgw/drivers/aq/AQOPHandle; getAQDest qData !Loracle/mgw/drivers/aq/QueueData; qtData "Loracle/mgw/drivers/aq/QTableData; oa [Ljava/lang/Object; destD getTransformation 9(Ljava/lang/String;)Loracle/mgw/drivers/aq/TransformData; tdata getSubscriberData q(Ljava/sql/Connection;Loracle/mgw/drivers/aq/AQDestData;Ljava/lang/String;)Loracle/mgw/drivers/aq/SubscriberData; subscriberIdToName &(Ljava/lang/String;)Ljava/lang/String; subId SourceFile AQLink.java AQN2+./01 AQLink.makeMessageID !oracle/mgw/drivers/aq/AQMessageID2,-./01234 AQLink.loggingSupport5?67 java/lang/StringBuilder2i 0x89:;<=>3? AQLink.alterLinkParamsIJ3?IM AQLink.registerLogSet@7 java/lang/StringBuffer2A whichLog=8B8C , subName=5?DiEFGHI?JK _src8L _destMN log_producer log_consumer log_browser &oracle/mgw/drivers/aq/AQProducerParamsO7PQ2R &oracle/mgw/drivers/aq/AQConsumerParams2STU , setId= nullVW> AQLink.unregisterLogSet setId=XY java/lang/ExceptionZ[\ , removed=8] AQLink.closehi AQLink.getMsgCount consId=^_`abcd7e>qr?? , count=f>ghij>k>l>mA??no??hpqqrst java/sql/SQLException {0}@{1})uvwx AQLink.getCountForSubscriber .count={0}, queue={1}, subName={2}, hasRule={3}y<z{7y|u}~4? AQLink.getCountForQueue count={0}, queue={1} AQLink.registerDestination??>?? AQ oracle/mgw/drivers/aq/AQDestData?>~? AQLink.unregisterDestination????i #removed cached subscribers; queue: AQLink.registerConsumer?? Register Consumer: ?? consumer ID already registered: AQLink.alterConsumer????,2??? Altered Consumer: ?,???,?? AQLink.unregisterConsumer?? AQLink.registerProducer Register Producer: ?? producer ID already registered: AQLink.alterProducer?_???2??? Altered Producer: ???? AQLink.unregisterProducer?? AQLink.startOperation?7?????6x?? AQLink.startLogOperation?? log OPHandle already in use AQLink.commit OPHandleb??i AQLink.rollback?i "oracle/mgw/common/GatewayException AQLink.getConsumer?? #oracle/mgw/drivers/aq/AQMsgConsumer?>??2????i AQLink.getProducer?? #oracle/mgw/drivers/aq/AQMsgProducer2??? AQLink.sendb? prodId=0??? , msgId= AQLink.receiveb?0???0? AQLink.receive(mid)b??? , found= AQLink.removeMsg MessageID???G aremoveMsg: message to be removed does not exist msgId: {0}, consId: {1}, queue: {2}, subName: {3}?? AQLink.moveToExceptionQueue destination queue .msgId: {0}, srcQ: {1}, subName: {2}, excQ: {3}?? `moveToExceptionQueue: message to be moved does not exist msgId: {0}, srcQueue: {1}, subName: {2}u? msgId= , excMsgId= not implemented AQLink.subscribe?>?????'????? AQLink.unsubscribe?? AQLink.updateSub?? =altered subscriber rule; queue: {0}, subName: {1} rule: [{2}] ?? java/lang/Stringh? AQLink.handleEvent?0>?? AQLink.initHandlesFactories?G54 request OCI conn pool~??? )initialize JdbcConnFactory: use ociPool? 8? %oracle/mgw/drivers/aq/JdbcConnFactory2?????G?>?>?>2? #JdbcConnFactory is already non-NULL JdbcConnFactory is NULL??7?G implicit statment cache size: initialize OPHandle factories 'oracle/mgw/drivers/aq/AQOPHandleFactory2? "assign OPHandle factories to pools???? !AQLink.closeResetHandlesFactories close pooled OPHandles?i close JdbcConnFactory release OCI conn pool?iN?N? AQLink.startAdminOperation oracle/mgw/drivers/aq/AQOPHandle null handle! :startAdminOperation: admin OPHandle already in use; link: AQLink.getAQDest DestParams?? oracle/mgw/drivers/aq/QueueData oracle/mgw/drivers/aq/QTableData?>?>?72??? DestData?????? caching subscriber data; MGW_?> oracle/mgw/drivers/aq/AQLink oracle/mgw/drivers/aq/AQBaseLink AQLink. oracle/mgw/common/FatalException "oracle/mgw/common/MessageException d(Loracle/mgw/drivers/aq/AQLinkMgr;Loracle/mgw/drivers/aq/AQLinkParamsNFactory;IILjava/lang/String;)V ([B)V m_apiTracer Loracle/mgw/common/ApiTrace; oracle/mgw/drivers/aq/AQUtil trcString 1(Loracle/mgw/common/MessageID;)Ljava/lang/String; oracle/mgw/common/ApiTrace methodExit ((Ljava/lang/String;Ljava/lang/String;I)V methodEntry isTraceExit ()Z append -(Ljava/lang/String;)Ljava/lang/StringBuilder; java/lang/Integer toHexString (I)Ljava/lang/String; toString ()Ljava/lang/String; '(Ljava/lang/String;Ljava/lang/String;)V isTraceEntry (I)V ,(Ljava/lang/String;)Ljava/lang/StringBuffer; (I)Ljava/lang/StringBuffer; checkValidLink m_syncLogQ Ljava/lang/Object; getLogDest (I)Loracle/mgw/common/DestData; verifyLogDestType getLogSetSequence (I)I (I)Ljava/lang/StringBuilder; logSetCache_get 1(Ljava/lang/String;Z)Loracle/mgw/common/LogIdSet; isForeignLink m_tracer Loracle/mgw/common/Trace; s(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;ZLjava/util/Hashtable;ZLoracle/mgw/common/Trace;)V ?(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZLjava/util/Hashtable;ZLoracle/mgw/common/Trace;)V logSetCache_register ?(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/ConsumerParams;Loracle/mgw/drivers/ConsumerParams;Z)Loracle/mgw/common/LogIdSet; oracle/mgw/common/LogIdSet getId logSetCache_unregister (Loracle/mgw/common/LogIdSet;Z)Z oracle/mgw/common/Trace exception (Ljava/lang/Throwable;)V (Z)Ljava/lang/StringBuffer; getConsumerP &(Ljava/lang/String;)Ljava/lang/Object; getDestination ()Loracle/mgw/common/DestData; castAQ @(Loracle/mgw/common/DestData;)Loracle/mgw/drivers/aq/AQDestData; isTopic getSubName getFullName oracle/mgw/common/MgwUtil GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; getSchema getQueueTable getQueueName m_adminLock getConnection ()Ljava/sql/Connection; `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; oracle/mgw/drivers/aq/AQAdminMgr `(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)I checkin (Z)V format J(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; isLevel (I)Z valueOf $oracle/mgw/drivers/aq/SubscriberData hasRule (Z)Ljava/lang/String; n(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; trace N(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)I oracle/mgw/common/DestParams getNativeName toTraceString (Ljava/lang/String;I)V oracle/mgw/common/DestData getDestParams ()Loracle/mgw/common/DestParams; clearSubData registerConsumerP /(Loracle/mgw/drivers/ConsumerProducerParams;Z)Z alterParamsCheck <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)I !oracle/mgw/drivers/ConsumerParams NO_CHANGE d(Loracle/mgw/drivers/aq/AQConsumerParams;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V putConsumerP @(Loracle/mgw/drivers/ConsumerProducerParams;Z)Ljava/lang/Object; CACHE_INVALIDATE closeAllConsumers CACHE_CHANGE alterAllConsumers 8(Ljava/lang/String;Loracle/mgw/drivers/ConsumerParams;)V unregisterConsumerP (Ljava/lang/String;Z)Z registerProducerP getProducerP *(Ljava/lang/String;Ljava/util/Hashtable;)I !oracle/mgw/drivers/ProducerParams R(Loracle/mgw/drivers/aq/AQProducerParams;Ljava/lang/String;Ljava/util/Hashtable;)V putProducerP closeAllProducers alterAllProducers 8(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;)V unregisterProducerP resetHandles m_msgOphPool !Loracle/mgw/drivers/OPHandlePool; oracle/mgw/drivers/OPHandlePool getHandle %()Loracle/mgw/drivers/PooledOPHandle; nvl_null &(Ljava/lang/Object;)Ljava/lang/String; m_logOphPool @(Loracle/mgw/common/OPHandle;)Loracle/mgw/drivers/aq/AQOPHandle; 3(Ljava/lang/String;)Loracle/mgw/common/MsgConsumer; ?(Loracle/mgw/drivers/aq/AQConsumerParams;Loracle/mgw/common/OPHandle;Loracle/mgw/drivers/aq/TransformData;Loracle/mgw/common/Trace;)V addConsumer 4(Ljava/lang/String;Loracle/mgw/common/MsgConsumer;)V resetBrowser 3(Ljava/lang/String;)Loracle/mgw/common/MsgProducer; ?(Loracle/mgw/drivers/aq/AQProducerParams;Loracle/mgw/common/OPHandle;Loracle/mgw/drivers/aq/TransformData;Loracle/mgw/common/Trace;)V addProducer 4(Ljava/lang/String;Loracle/mgw/common/MsgProducer;)V F(Loracle/mgw/common/MsgProducer;)Loracle/mgw/drivers/aq/AQMsgProducer; 7(Loracle/mgw/drivers/ProducerParams;)Ljava/lang/String; enqueue :(Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; F(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/drivers/aq/AQMsgConsumer; 7(Loracle/mgw/drivers/ConsumerParams;)Ljava/lang/String; dequeue ()Loracle/mgw/common/Message; /(Loracle/mgw/common/Message;)Ljava/lang/String; B(Loracle/mgw/common/MessageID;)Loracle/mgw/drivers/aq/AQMessageID; :(Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; removeMessage _(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Loracle/mgw/drivers/aq/AQMessageID;)Z getErrorCode nvl_empty moveMessage ?(Ljava/sql/Connection;Ljava/lang/String;Loracle/mgw/drivers/aq/AQMessageID;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/AQMessageID; \(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; getFilter addQueueSubscriber N(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V m_logger Loracle/mgw/common/MgwLog; m_linkName oracle/mgw/common/MgwLog logMsg L(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V removeSubData removeQueueSubscriber <(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)V alterSubscriberRule nvl 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; r(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; oracle/mgw/common/Event getEntryEvent )(Ljava/lang/String;Ljava/lang/String;II)V requestOCIPool ,()Loracle/jdbc/pool/OracleOCIConnectionPool; (Z)Ljava/lang/StringBuilder; ?(Loracle/jdbc/pool/OracleDataSource;Loracle/mgw/common/Trace;)V aqLinkParams .()Loracle/mgw/drivers/aq/AQLinkParamsNFactory; *oracle/mgw/drivers/aq/AQLinkParamsNFactory getConnType getDatabase getUser getPassword S(ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;Loracle/mgw/common/Trace;)V oracle/mgw/common/MgwConstants isStatementCaching msgStatementCacheSize V(Loracle/mgw/drivers/aq/JdbcConnFactory;ILjava/lang/String;Loracle/mgw/common/Trace;)V setOPHandleFactory .(Loracle/mgw/drivers/PooledOPHandleFactory;Z)V m_adminOphPool destroyHandles releaseOCIPool &(Loracle/mgw/drivers/ConsumerParams;)V &(Loracle/mgw/drivers/ProducerParams;)V retrieveQueueNTableData <(Ljava/sql/Connection;Ljava/lang/String;)[Ljava/lang/Object; getOwner getPayloadObjectType isMultipleConsumers ?(Loracle/mgw/common/DestParams;Loracle/mgw/common/MsgLink;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZ)V retrieveTransformData N(Ljava/sql/Connection;Ljava/lang/String;)Loracle/mgw/drivers/aq/TransformData; getSubData :(Ljava/lang/String;)Loracle/mgw/drivers/aq/SubscriberData; describeSubscriber ?(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/SubscriberData; putSubData )(Loracle/mgw/drivers/aq/SubscriberData;)V toUpperCase !$% &' ( ) *' ( +, ( - ./ 01 , 23 4 k *+, ? *? *? ? 5 ? ? ? ?6 * 78 9: ;<