Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\mq\jms\MQJmsLink.class
?? 1'? ?? ? ??? ?? ? ??? ?? ?? ?? ?? ??? ?? ?? ??? ?? ? ?? ??? ?? ? ? ??? ? ?? #?? ??? '?? '? '?? '? ?? ?? ?? ?? ??? ??? ?? ????? ??? =?? ?? ?? ???? ?? ???? ?? ??? '?? ???? P??? ?? ?? ?? ?? ??? Y? Y? #? Y? ?? ? ? ??? ?? ?? ? ? ? ? Y Y Y Y? ? ? ? ? ? ? ? ? ?! ?" #$ ?%& ?'() * ?+,- ?./ ?0 =1 * =2 ?3 = ?4 =! ?56 ?78 Y9: Y; Y< ?=> Y? Y@ YAB ?C ?DE ?F ?G ??HI ?J ?KLM ?N OPQ ORS =T ?U ??V ?WXYZ ?[ ?\] ?^ ?_` Yabcd ?ef ?g ?hi ?_ j k ?lm ?n ?opq ?rstu v?wxyz FACILITY Ljava/lang/String; ConstantValue COMPONENT I m_connFactory 2Loracle/mgw/drivers/mq/jms/MQJmsConnectionFactory; m_conn "Loracle/mgw/drivers/JmsConnection; m_interfaceType <init> 0(Loracle/mgw/drivers/mq/MQLinkParamsNFactory;I)V Code LineNumberTable LocalVariableTable ge $Loracle/mgw/common/GatewayException; this %Loracle/mgw/drivers/mq/jms/MQJmsLink; params ,Loracle/mgw/drivers/mq/MQLinkParamsNFactory; maxThreads getLinkParamsNFactory +()Loracle/mgw/common/MsgLinkParamsNFactory; alterLinkParams ,(Loracle/mgw/common/MsgLinkParamsNFactory;)V )Loracle/mgw/common/MsgLinkParamsNFactory; loggingSupport ()I getLogQDest 0(Ljava/lang/String;)Loracle/mgw/common/DestData; qname isTopic Z options Ljava/util/Hashtable; durSubQueue dp Loracle/mgw/common/DestParams; Exceptions registerLogSet C(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet; baseId id filter 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 close ()V makeMessageID !([B)Loracle/mgw/common/MessageID; mid [B Loracle/mgw/common/MessageID; getMsgCount (Ljava/lang/String;)I registerDestination <(Loracle/mgw/common/DestParams;)Loracle/mgw/common/DestData; data )Loracle/mgw/drivers/mq/jms/MQJmsDestData; session Loracle/mgw/drivers/JmsSession; !(Loracle/mgw/common/DestParams;)Z linkParams name unregisterDestination (Loracle/mgw/common/DestData;)V startOperation ()Loracle/mgw/common/OPHandle; handle Loracle/mgw/common/OPHandle; startLogOperation commit (Loracle/mgw/common/OPHandle;)V oph{ rollback closeSession registerConsumer }(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V subname transformation isBrowser alterConsumer N(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V newParams &Loracle/mgw/drivers/JmsConsumerParams; cacheAction e unregisterConsumer (Ljava/lang/String;)V alterCachedConsumer E(Loracle/mgw/common/MsgConsumer;Loracle/mgw/drivers/ConsumerParams;)V cons Loracle/mgw/common/MsgConsumer; registerProducer X(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/util/Hashtable;)V alterCachedProducer E(Loracle/mgw/common/MsgProducer;Loracle/mgw/drivers/ProducerParams;)V prod Loracle/mgw/common/MsgProducer; alterProducer <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)V &Loracle/mgw/drivers/JmsProducerParams; unregisterProducer getConsumer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgConsumer; consumer Loracle/mgw/drivers/JmsConsumer; getProducer O(Ljava/lang/String;Loracle/mgw/common/OPHandle;)Loracle/mgw/common/MsgProducer; producer Loracle/mgw/drivers/JmsProducer; send Y(Loracle/mgw/common/Message;Loracle/mgw/common/MsgProducer;)Loracle/mgw/common/MessageID; msg Loracle/mgw/common/Message; pr jmsProd msgId removeMsg N(Loracle/mgw/common/OPHandle;Ljava/lang/String;Loracle/mgw/common/MessageID;)Z oldParams selector jmsMsg Ljavax/jms/Message; ?(Loracle/mgw/common/MsgConsumer;Loracle/mgw/common/MessageID;)Z receive <(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message; jmsCons 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; exq newMid !Loracle/mgw/drivers/JmsMessageID; srcq consParams prodParams sendToExceptionQueue r(Loracle/mgw/common/OPHandle;Loracle/mgw/common/DestData;Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; smid subscribe subscriber unsubscribe updateSub handleEvent (Loracle/mgw/common/Event;)V event Loracle/mgw/common/Event; initHandlesFactories closeResetHandlesFactories Ljava/lang/Exception; SourceFile MQJmsLink.java MQJMS ?|} ? ? 0oracle/mgw/drivers/mq/jms/MQJmsConnectionFactory~ ?? ? ? "oracle/mgw/common/GatewayException?(?????? ?? MQJmsLink.alterLinkParams??R ? ??R *oracle/mgw/drivers/mq/MQLinkParamsNFactory?? java/util/Hashtable ???? ??? oracle/mgw/common/DestParams java/lang/StringBuilder ?( MQ_????? ? java/lang/Boolean ?? ?? 'oracle/mgw/drivers/mq/jms/MQJmsDestData ?? MQJmsLink.registerLogSet?? java/lang/StringBuffer whichLog=???? , subName=???(?????? _dest?? _src MGL_????? log_producer log_consumer log_browser??? $oracle/mgw/drivers/JmsProducerParams ?? $oracle/mgw/drivers/JmsConsumerParams ?????? , setId= null????? MQJmsLink.unregisterLogSet setId=???? , removed=?? MQJmsLink.close'( MQJmsLink.makeMessageID oracle/mgw/drivers/JmsMessageID ?? MQJmsLink.getMsgCount MQJmsLink.registerDestination6?,??????? oracle/mgw/drivers/JmsSession??????? ? ?????? queue topic????? MQJmsLink.unregisterDestination MQJmsLink.startOperation?? MQJmsLink.startLogOperation?? log session already in use?? MQJmsLink.commit OPHandle????@( MQJmsLink.rollbackD( MQJmsLink.registerConsumer MGW_??? Register Consumer: ??????? CMQJmsLink.registerConsumer: Error: consumer ID already registered: ?R MQJmsLink.alterConsumer????? ? ????? ??R? ????? MQJmsLink.unregisterConsumer?? oracle/mgw/drivers/JmsConsumer?? MQJmsLink.registerProducer Register Producer: ??? CMQJmsLink.registerProducer: Error: producer ID already registered: oracle/mgw/drivers/JmsProducer?? MQJmsLink.alterProducer???? ?????R?? MQJmsLink.unregisterProducer?? MQJmsLink.getConsumera? consumer ID not registered: ???? ( MQJmsLink.getProducere MQJmsLink.send? MQJmsLink.removeMsg -Method removeMsg not supported by JMS drivers MQJmsLink.receive? w 9Method receive by message ID not supported by JMS drivers MQJmsLink.moveToExceptionQueue? ;moveToExceptionQueue should not be called for a JMS Topic: temp? "oracle/mgw/common/MessageException? MQJmsLink.sendToExceptionQueue MQJmsLink.subscribe is not a topic.? created durable subscriber: ?? MQJmsLink.unsubscribe? removed durable subscriber: MQJmsLink.updateSub MQJmsLink.handleEvent?? MQJmsLink.initHandlesFactories? initialize OPHandle factories !" ? ? "assign OPHandle factories to pools#$? $MQJmsLink.closeResetHandlesFactories close pooled OPHandles%( closed messaging connections closed logging connection admin connection closed& JMS connection closed java/lang/Exception #oracle/mgw/drivers/mq/jms/MQJmsLink oracle/mgw/drivers/BaseLink oracle/mgw/common/FatalException A(Loracle/mgw/common/MsgLinkParamsNFactory;IZILjava/lang/String;)V getInterfaceType m_tracer Loracle/mgw/common/Trace; H(Loracle/mgw/drivers/mq/MQLinkParamsNFactory;Loracle/mgw/common/Trace;)V markLinkInvalid m_logger Loracle/mgw/common/MgwLog; oracle/mgw/common/MgwLog exception *(Ljava/lang/String;Ljava/lang/Throwable;)V m_linkParams m_apiTracer Loracle/mgw/common/ApiTrace; oracle/mgw/common/ApiTrace methodEntry methodExit getJmsDurSubQueue ()Ljava/lang/String; (I)V oracle/mgw/common/MgwConstants LINK_OPT_MQJMS_DURSUBQ put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString m_linkName (Z)V s(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Boolean;Ljava/util/Hashtable;)V P(Loracle/mgw/common/DestParams;ZLoracle/mgw/common/MsgLink;ILjava/lang/String;)V isTraceEntry ()Z ,(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; 'oracle/mgw/common/MsgLinkParamsNFactory getName logSetCache_get 1(Ljava/lang/String;Z)Loracle/mgw/common/LogIdSet; oracle/mgw/drivers/JmsUtil buildSelector_JobId &(Ljava/lang/String;)Ljava/lang/String; 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 m_adminLock resetHandles m_adminOphPool !Loracle/mgw/drivers/OPHandlePool; oracle/mgw/drivers/OPHandlePool getHandle %()Loracle/mgw/drivers/PooledOPHandle; getJmsSession ()Ljavax/jms/Session; getSessionType getJmsDestination -(Ljavax/jms/Session;I)Ljavax/jms/Destination; checkin getNativeName ()Ljava/lang/Boolean; booleanValue oracle/mgw/common/MgwUtil GatewayException r(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; m_msgOphPool m_logOphPool log castJms =(Loracle/mgw/common/OPHandle;)Loracle/mgw/drivers/JmsSession; closeTopicSubscribers oracle/mgw/common/Trace isLevel (I)Z !oracle/mgw/drivers/ConsumerParams toTraceString trace (Ljava/lang/String;I)V registerConsumerP /(Loracle/mgw/drivers/ConsumerProducerParams;Z)Z getConsumerP &(Ljava/lang/String;)Ljava/lang/Object; alterParamsCheck <(Ljava/lang/String;Ljava/lang/String;Ljava/util/Hashtable;)I NO_CHANGE b(Loracle/mgw/drivers/JmsConsumerParams;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 (Ljava/lang/Throwable;)V unregisterConsumerP (Ljava/lang/String;Z)Z alter )(Loracle/mgw/drivers/JmsConsumerParams;)V !oracle/mgw/drivers/ProducerParams registerProducerP )(Loracle/mgw/drivers/JmsProducerParams;)V getProducerP *(Ljava/lang/String;Ljava/util/Hashtable;)I P(Loracle/mgw/drivers/JmsProducerParams;Ljava/lang/String;Ljava/util/Hashtable;)V putProducerP closeAllProducers alterAllProducers 8(Ljava/lang/String;Loracle/mgw/drivers/ProducerParams;)V unregisterProducerP 3(Ljava/lang/String;)Loracle/mgw/common/MsgConsumer; createConsumer H(Loracle/mgw/drivers/JmsConsumerParams;)Loracle/mgw/drivers/JmsConsumer; addConsumer 4(Ljava/lang/String;Loracle/mgw/common/MsgConsumer;)V resetBrowser 3(Ljava/lang/String;)Loracle/mgw/common/MsgProducer; createProducer H(Loracle/mgw/drivers/JmsProducerParams;)Loracle/mgw/drivers/JmsProducer; addProducer 4(Ljava/lang/String;Loracle/mgw/common/MsgProducer;)V A(Loracle/mgw/common/MsgProducer;)Loracle/mgw/drivers/JmsProducer; produce >(Loracle/mgw/common/Message;)Loracle/mgw/drivers/JmsMessageID; buildSelector_MessageID 1(Loracle/mgw/common/MessageID;)Ljava/lang/String; jmsReceive (J)Ljavax/jms/Message; A(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/drivers/JmsConsumer; (J)Loracle/mgw/common/Message; getDestination ()Loracle/mgw/common/DestData; oracle/mgw/common/DestData getDestParams ()Loracle/mgw/common/DestParams; setExceptionMsgHandler 6(Ljavax/jms/Message;)Loracle/mgw/drivers/JmsMessageID; getReason commitOph $(Loracle/mgw/drivers/BaseOPHandle;)V isTRACE_LITE getSubName )(Ljava/lang/String;Ljava/lang/String;II)V (Ljava/lang/String;)Z getEntryEvent ((Ljava/lang/String;Ljava/lang/String;I)V changeParams /(Loracle/mgw/drivers/mq/MQLinkParamsNFactory;)V createConnection $()Loracle/mgw/drivers/JmsConnection; setOPHandleFactory .(Loracle/mgw/drivers/PooledOPHandleFactory;Z)V destroyHandles oracle/mgw/drivers/JmsConnection 1 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ( ? ? ? ? 7*+ ? *+? ? *? Y+*? ? ? ? N*? *? -? ? $ ' ? "