Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\mq\MQLink.class
?? 1?? ?? ??? ?? ?? ???? ?? ? ? ?? ?? ?? ??? ?? ? ? ? ?? ?? ?? ?? ??? ?? ?????? &?? (? ?? ???? ?? ???? ?? ??? ?? ??? 8?? ?? ?? ?? ??? ??? A? ?? ??? ?? ? ? G??? ?? G?? ? A?? A?? ? ? ?? ?? ??? ??? ????? ?? ?? ??? ?? ??? ?? ??? (? ?? ??? ??? ?? (? (? (? (? (? (? ?? (? ?? (? ?? ?? A G ? &? ? ? &? &? &? & ? &? ? &? ? ? ? ? ? A A ? G ? ? G ? A! ?"# A$% A&' () G* A+ G,- ?. O/012 ?34 ?5 ?67 ?8 ?9: ?; ?<= ?> ?? ?@ ?AB ?C ?DEF ?GHIJK ?LMNOPQRST FACILITY Ljava/lang/String; ConstantValue COMPONENT I m_handleFactory *Loracle/mgw/drivers/PooledOPHandleFactory; m_connProps Ljava/util/Hashtable; <init> 0(Loracle/mgw/drivers/mq/MQLinkParamsNFactory;I)V Code LineNumberTable LocalVariableTable this Loracle/mgw/drivers/mq/MQLink; params ,Loracle/mgw/drivers/mq/MQLinkParamsNFactory; maxThreads alterLinkParams ,(Loracle/mgw/common/MsgLinkParamsNFactory;)V )Loracle/mgw/common/MsgLinkParamsNFactory; loggingSupport ()I getLogQDest 0(Ljava/lang/String;)Loracle/mgw/common/DestData; qname dp Loracle/mgw/common/DestParams; Exceptions registerLogSet C(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet; id prodP #Loracle/mgw/drivers/ProducerParams; consP #Loracle/mgw/drivers/ConsumerParams; browserP prodId consId browserId seq dest Loracle/mgw/common/DestData; whichLog subName jobId method logSet Loracle/mgw/common/LogIdSet; unregisterLogSet (Loracle/mgw/common/LogIdSet;)V removed Z close ()V makeMessageID !([B)Loracle/mgw/common/MessageID; mid [B getMsgCount (Ljava/lang/String;)I oph "Loracle/mgw/drivers/mq/MQOPHandle; consumer %Loracle/mgw/drivers/mq/MQMsgConsumer; count registerDestination <(Loracle/mgw/common/DestParams;)Loracle/mgw/common/DestData; producer %Loracle/mgw/drivers/mq/MQMsgProducer; e $Loracle/mgw/common/GatewayException; isTx isTopic data unregisterDestination (Loracle/mgw/common/DestData;)V ge startOperation ()Loracle/mgw/common/OPHandle; handle Loracle/mgw/common/OPHandle; startLogOperation commit (Loracle/mgw/common/OPHandle;)V mophU rollback registerConsumer }(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V subname filter transformation isBrowser options alterConsumer N(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V newParams cacheAction alterCachedConsumer E(Loracle/mgw/common/MsgConsumer;Loracle/mgw/drivers/ConsumerParams;)V cons Loracle/mgw/common/MsgConsumer; alterCachedProducer E(Loracle/mgw/common/MsgProducer;Loracle/mgw/drivers/ProducerParams;)V prod Loracle/mgw/common/MsgProducer; unregisterConsumer (Ljava/lang/String;)V registerProducer X(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/util/Hashtable;)V alterProducer <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V unregisterProducer getConsumer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgConsumer; goph createConsumer [(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;)Loracle/mgw/drivers/mq/MQMsgConsumer; getProducer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgProducer; send Y(Loracle/mgw/common/Message;Loracle/mgw/common/MsgProducer;)Loracle/mgw/common/MessageID; msg Loracle/mgw/common/Message; pr mqProd msgId Loracle/mgw/common/MessageID; removeMsg N(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/MessageID;)Z mqOph mqMid #Loracle/mgw/drivers/mq/MQMessageID; mqMsg Lcom/ibm/mq/MQMessage; ?(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Z mqCons receive <(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message; Y(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Loracle/mgw/common/Message; moveToExceptionQueue ?(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/DestData;Loracle/mgw/common/MessageID;)Loracle/mgw/common/MessageID; me $Loracle/mgw/common/MessageException; smid 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 mqParams closeResetHandlesFactories castMQ @(Loracle/mgw/common/OPHandle;)Loracle/mgw/drivers/mq/MQOPHandle; obj F(Loracle/mgw/common/MsgProducer;)Loracle/mgw/drivers/mq/MQMsgProducer; F(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/drivers/mq/MQMsgConsumer; B(Loracle/mgw/common/MessageID;)Loracle/mgw/drivers/mq/MQMessageID; SourceFile MQLink.java MQD ?VWX MQLink.alterLinkParamsYZG ? ?[G oracle/mgw/common/DestParams java/lang/StringBuilder ? MQ_\]^_` ? ?a oracle/mgw/common/DestData ?b MQLink.registerLogSetcd java/lang/StringBuffer ?e whichLog=\f\gZhijklmno _dest\p _srcqr log_producer log_consumer log_browser !oracle/mgw/drivers/ProducerParams ?s !oracle/mgw/drivers/ConsumerParams ?tuvwd , setId= nullxy_[h MQLink.unregisterLogSet setId=zd{| , removed=\} MQLink.close !oracle/mgw/drivers/mq/MQMessageID ?~ MQLink.getMsgCountd?????? oracle/mgw/drivers/mq/MQOPHandleMN #oracle/mgw/drivers/mq/MQMsgConsumer ????? MQLink.registerDestination?_ #oracle/mgw/drivers/mq/MQMsgProducer .registerDest ?? Destination validated using MQMsgProducer??? "oracle/mgw/common/GatewayException?? ?? validated using MQMsgConsumer MQLink.unregisterDestination???_?G????? MQLink.startOperation?? MQLink.startLogOperation?? log OPHandle already in use MQLink.commit OPHandle???yz. MQLink.rollback2 MQLink.registerConsumer????? Register Consumer: ?_???? @MQLink.registerConsumer: Error: consumer ID already registered: ?G MQLink.alterConsumer????? ????_8d?d??? ??G? ????????? MQLink.unregisterConsumer?? MQLink.registerProducer Register Producer: ?? @MQLink.registerProducer: Error: producer ID already registered: MQLink.alterProducer???d???G?? MQLink.unregisterProducer?? MQLink.getConsumerM?PQ??? DestData ?? MQLink.getProducerR? DestData is null ???? MQLink.sendy|T? MQLink.removeMsgy~??y} MQLink.receivee? MQLink.receive.messageIDe? MQLink.moveToExceptionQueue?d .exq_only ?????? "oracle/mgw/common/MessageException?_ ?? not implemented MQSeries MQLink.handleEventrs MQLink.initHandlesFactories? ?Z? initialize OPHandle factories??? ? *oracle/mgw/drivers/mq/MQLinkParamsNFactory?? ? ? 'oracle/mgw/drivers/mq/MQOPHandleFactory?_?_ ?? ? ? "assign OPHandle factories to pools??[? !MQLink.closeResetHandlesFactories close pooled OPHandles? closed messaging connections closed logging connection admin connection closed MQOPHandle?? MsgProducer MQMsgProducer MsgConsumer MQMsgConsumer MessageID MQMessageID oracle/mgw/drivers/mq/MQLink oracle/mgw/drivers/BaseLink oracle/mgw/common/FatalException A(Loracle/mgw/common/MsgLinkParamsNFactory;IZILjava/lang/String;)V m_apiTracer Loracle/mgw/common/ApiTrace; oracle/mgw/common/ApiTrace methodEntry methodExit append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; m_linkName s(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Boolean;Ljava/util/Hashtable;)V >(Loracle/mgw/common/DestParams;Loracle/mgw/common/MsgLink;ZZ)V isTraceEntry ()Z (I)V ,(Ljava/lang/String;)Ljava/lang/StringBuffer; (I)Ljava/lang/StringBuffer; '(Ljava/lang/String;Ljava/lang/String;)V checkValidLink m_syncLogQ Ljava/lang/Object; getLogDest (I)Loracle/mgw/common/DestData; getLogSetSequence (I)I (I)Ljava/lang/StringBuilder; logSetCache_get 1(Ljava/lang/String;Z)Loracle/mgw/common/LogIdSet; Y(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;ZLjava/util/Hashtable;)V ~(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZLjava/util/Hashtable;)V logSetCache_register ?(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/ConsumerParams;Loracle/mgw/drivers/ConsumerParams;Z)Loracle/mgw/common/LogIdSet; isTraceExit oracle/mgw/common/LogIdSet getId isValidLink logSetCache_unregister (Loracle/mgw/common/LogIdSet;Z)Z (Z)Ljava/lang/StringBuffer; ([B)V resetHandles m_adminLock m_adminOphPool !Loracle/mgw/drivers/OPHandlePool; oracle/mgw/drivers/OPHandlePool getHandle %()Loracle/mgw/drivers/PooledOPHandle; commitOph $(Loracle/mgw/drivers/BaseOPHandle;)V checkin (Z)V getNativeName N(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;ZILjava/lang/String;ZZZ)V trace ((Ljava/lang/String;Ljava/lang/String;I)V destroy getOptions ()Ljava/util/Hashtable; c(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;ZZLjava/util/Hashtable;Ljava/lang/String;ZZZ)V getDestParams ()Loracle/mgw/common/DestParams; getGuid closeConsumer m_logger Loracle/mgw/common/MgwLog; oracle/mgw/common/MgwLog exception *(Ljava/lang/String;Ljava/lang/Throwable;)V m_msgOphPool m_logOphPool oracle/mgw/common/MgwUtil GatewayException N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; m_tracer Loracle/mgw/common/Trace; oracle/mgw/common/Trace isLevel (I)Z toTraceString (Ljava/lang/String;I)V registerConsumerP /(Loracle/mgw/drivers/ConsumerProducerParams;Z)Z log getConsumerP &(Ljava/lang/String;)Ljava/lang/Object; alterParamsCheck (Ljava/util/Hashtable;)I NO_CHANGE getDestination ()Loracle/mgw/common/DestData; getSubName isLogConsumer putConsumerP @(Loracle/mgw/drivers/ConsumerProducerParams;Z)Ljava/lang/Object; CACHE_INVALIDATE closeAllConsumers CACHE_CHANGE alterAllConsumers 8(Ljava/lang/String;Loracle/mgw/drivers/ConsumerParams;)V (Ljava/lang/Throwable;)V alter &(Loracle/mgw/drivers/ConsumerParams;)V &(Loracle/mgw/drivers/ProducerParams;)V unregisterConsumerP (Ljava/lang/String;Z)Z registerProducerP getProducerP isLogProducer putProducerP closeAllProducers alterAllProducers 8(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;)V unregisterProducerP 3(Ljava/lang/String;)Loracle/mgw/common/MsgConsumer; addConsumer 4(Ljava/lang/String;Loracle/mgw/common/MsgConsumer;)V resetBrowser Z(Loracle/mgw/drivers/ConsumerParams;Loracle/mgw/drivers/mq/MQOPHandle;Ljava/lang/String;)V 3(Ljava/lang/String;)Loracle/mgw/common/MsgProducer; Z(Loracle/mgw/drivers/ProducerParams;Loracle/mgw/drivers/mq/MQOPHandle;Ljava/lang/String;)V addProducer 4(Ljava/lang/String;Loracle/mgw/common/MsgProducer;)V @(Loracle/mgw/common/Message;)Loracle/mgw/drivers/mq/MQMessageID; mqReceive <(JLoracle/mgw/drivers/mq/MQMessageID;)Lcom/ibm/mq/MQMessage; (J)Loracle/mgw/common/Message; A(JLoracle/mgw/drivers/mq/MQMessageID;)Loracle/mgw/common/Message; isTransactional b(Ljava/lang/String;Loracle/mgw/drivers/mq/MQOPHandle;ZLjava/util/Hashtable;Ljava/lang/String;ZZZ)V convertForExceptionQueue (Lcom/ibm/mq/MQMessage;)V mqSend x(Lcom/ibm/mq/MQMessage;Lcom/ibm/mq/MQPutMessageOptions;Loracle/mgw/common/MessageID;)Loracle/mgw/drivers/mq/MQMessageID; getReason +(ILjava/lang/String;Ljava/lang/Throwable;)V getEntryEvent )(Ljava/lang/String;Ljava/lang/String;II)V m_linkParams setConnectionProps U(Loracle/mgw/drivers/mq/MQLinkParamsNFactory;Ljava/lang/Object;)Ljava/util/Hashtable; getQMgr getCcdtUrl N(Ljava/lang/String;Ljava/util/Hashtable;Ljava/lang/String;Ljava/lang/String;)V setOPHandleFactory .(Loracle/mgw/drivers/PooledOPHandleFactory;Z)V destroyHandles `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; 1 ? ? ? ? ? ? ? ? ? ? ? ? ? + ? ? ? O *+ ? ? ? C D ? ? ? ? ? ? ? ? ? ? X *? ? *+? *? ? ? ? Q R S T ? ? ? ? ? ? ? ? , ? ? X ? ? ? ? ? ? q /? Y? Y? ? +? ? +*? +? M? Y,*? ? ? v # x ? / ? ? / ? ? # ? ? ? O ? ? ? ? l:*? ? ? "*? ? Y ? ? ? ? ? : *? *? Y: ?*? :? ?*? 6? ? Y? ? ? ? :? ? Y? !? ? ? :*? ": ? ? Y? #? ? ? :? Y? $? ? ? :? Y? %? ? ? :? &Y? ': ? (Y? ):? (Y? ):* ? *: ? : ??*? ? +? :*? ? Y ? ? ? ,? ? -? ? .? ? ? / ? < % ? f ? ? ? - ? 0 ? 4 ? <