Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\aq\jms\AQJmsLink.class
?? 1$ 5 4 4 !" # 4$%& '() '* 4+ ,- './ 01 2 34 5 '67 58 '9 5:; '<= >? @ AB 5 'C 4D 4E 4F 4G 4H 4IJ KLM 4NO 4PQRS TUV 6WX 8Y 4Z[\ ]^_` 4ab 4c def gh 5ijklm no 4pq rs dtu Qv dwx yz T{| y}~ 8v 4?? r?? 4? 8? ?? 8? 4?? ?? 4? ?? 4?? 4??? 6v 4??? 4? 6? ?? 6? 4?? ?? 4? ?? 4?? 4?? 4? 4? ??? 4? '? r?? 4???? T? ?? ?? ?i? ??? ??? ??? ?? ?? ??? ??? ?? ??? T? ?^?? 4? '? ?? ?? 4???? ?? ?? ??? ??? T? ?^? 4? ?? ????? T? 't ?? ?i? 8? 8? r? r???? 8??? 6? ?? ?i ??????? ???? 4? 4? 4?? r?? ?? 4??? 8^? ??? ?? ??? ? ? ? 5 ' ' ' 4 ? ? ? 4 ? i! 4" ?# ?$%&'() ?* 4+,- . / 0 1 2 Q3 ?4 Q5 46 Qz78 9:;<=>?@ABC 'DE )FGHIJK LM NO N5 LPQR CLASS_PREFIX Ljava/lang/String; ConstantValueS FACILITY COMPONENT I MSG_SUBID_PREFIX LOG_SUBID_PREFIX DEBUG Z m_jmsConnection "Loracle/mgw/drivers/JmsConnection; <init> Q(Loracle/mgw/drivers/aq/AQLinkMgr;Loracle/mgw/drivers/aq/AQLinkParamsNFactory;I)V Code LineNumberTable LocalVariableTable this %Loracle/mgw/drivers/aq/jms/AQJmsLink; 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 )Loracle/mgw/common/MsgLinkParamsNFactory; -(Loracle/mgw/common/MsgLinkParamsNFactory;I)V newParams alter registerLogSet C(ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/LogIdSet; producerId consumerId browserId filter producerP &Loracle/mgw/drivers/JmsProducerParams; consumerP &Loracle/mgw/drivers/JmsConsumerParams; browserP setId baseId jmsSubId 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 count registerDestination <(Loracle/mgw/common/DestParams;)Loracle/mgw/common/DestData; dParams Loracle/mgw/common/DestParams; nativeName aqDest unregisterDestination (Loracle/mgw/common/DestData;)V jmsDest Loracle/mgw/drivers/JmsDestData; registerConsumer }(Ljava/lang/String;Loracle/mgw/common/DestData;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/util/Hashtable;)V consP subname 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; oph Loracle/mgw/common/OPHandle; startLogOperation commit (Loracle/mgw/common/OPHandle;)V gwE $Loracle/mgw/common/GatewayException; session Loracle/mgw/drivers/JmsSession;T rollback gwE3 closeSession 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; #Loracle/mgw/drivers/ProducerParams; msg Loracle/mgw/common/Message; pr Loracle/mgw/common/MsgProducer; jpr msgId receive <(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/common/Message; #Loracle/mgw/drivers/ConsumerParams; cons Loracle/mgw/common/MsgConsumer; jcons 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 jmsMsg Ljavax/jms/Message; cacheP selector found 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; srcDest midExq sendToExceptionQueue r(Loracle/mgw/common/OPHandle;Loracle/mgw/common/DestData;Loracle/mgw/common/Message;)Loracle/mgw/common/MessageID; destQueue subscribe subscriber trcm topicName unsubscribe unsubscribeOJMS H(Loracle/mgw/drivers/JmsSession;Loracle/mgw/drivers/JmsConsumerParams;)V errCode ignore lex jmsE Ljavax/jms/JMSException; jdestD ojmsSess Loracle/jms/AQjmsSession; topic Ljavax/jms/Topic; updateSub handleEvent (Loracle/mgw/common/Event;)V event Loracle/mgw/common/Event; initHandlesFactories jmsConnFactory 2Loracle/mgw/drivers/aq/jms/AQJmsConnectionFactory; ociPool *Loracle/jdbc/pool/OracleOCIConnectionPool; closeResetHandlesFactories alterCachedConsumer E(Loracle/mgw/common/MsgConsumer;Loracle/mgw/drivers/ConsumerParams;)V alterCachedProducer E(Loracle/mgw/common/MsgProducer;Loracle/mgw/drivers/ProducerParams;)V prod startAdminOperation !()Loracle/mgw/drivers/JmsSession; getAQDest qData !Loracle/mgw/drivers/aq/QueueData; qtData "Loracle/mgw/drivers/aq/QTableData; jmsSess conn Ljava/sql/Connection; oa [Ljava/lang/Object; destD )Loracle/mgw/drivers/aq/jms/AQJmsDestData; verifyAQPayloadSupported jdest payloadType isAQPayloadSupported (Ljava/lang/String;)Z supported isOJMSError (Ljava/lang/Throwable;I)Z th Ljava/lang/Throwable; errorCode ret traceSession "(Loracle/mgw/drivers/JmsSession;)V jmse jmsSession mgwSession <clinit> ojmsProp SourceFile AQJmsLink.java AQJMSDU@ABC AQJmsLink.makeMessageID oracle/mgw/drivers/JmsMessageIDDVWXYZ[\]^ AQJmsLink.loggingSupport_?`abcded java/lang/StringBuilderD} 0xfghijk[]l AQJmsLink.alterLinkParams[\]?[^ AQJmsLink.registerLogSetmd java/lang/StringBufferDn whichLog=fofp , subName=_lq}rstu?v?wx _srcfy _dest MGL_z7 _{| log_producer log_consumer log_browser}~ $oracle/mgw/drivers/JmsProducerParamsD? $oracle/mgw/drivers/JmsConsumerParamsD??? , setId= null??[ AQJmsLink.unregisterLogSet setId=?? java/lang/Exception????? , removed=f? AQJmsLink.close|} AQJmsLink.getMsgCount consId= , count= AQJmsLink.registerDestination??[?? AQ????? 'oracle/mgw/drivers/aq/jms/AQJmsDestData?[?? AQJmsLink.unregisterDestination????? AQJmsLink.registerConsumer?d MGW_ Register Consumer: ?? consumer ID already registered: ?? AQJmsLink.alterConsumer?????<D??? Altered Consumer: ?<???<?? AQJmsLink.unregisterConsumer?? AQJmsLink.registerProducer Register Producer: ?? producer ID already registered: AQJmsLink.alterProducer????D??? Altered Producer: ???? AQJmsLink.unregisterProducer?? AQJmsLink.startOperation?d????? oracle/mgw/drivers/JmsSessione??? AQJmsLink.startLogOperation?? .startLogOperation: log OPHandle already in use AQJmsLink.commit OPHandle???}?d "oracle/mgw/common/GatewayException?? AQJmsLink.rollback?} AQJmsLink.getConsumer?? oracle/mgw/drivers/JmsConsumer?????} AQJmsLink.getProducer?? oracle/mgw/drivers/JmsProducer???? AQJmsLink.send?? prodId= !oracle/mgw/drivers/ProducerParams???^???? "oracle/mgw/common/MessageException????Y?[D? , msgId=??? AQJmsLink.receive?? !oracle/mgw/drivers/ConsumerParams?????? 2receive by message ID not supported by JMS drivers AQJmsLink.removeMsg MessageID???? aremoveMsg: message to be removed does not exist msgId: {0}, consId: {1}, queue: {2}, subName: {3}?[?[???? , found= AQJmsLink.moveToExceptionQueue , excQ=?? 2moveToExceptionQueue not supported for JMS Topic: temp???? jmoveToExceptionQueue: message to be moved does not exist msgId: {0}, consId: {1}, queue: {2}, subName: {3} mid= , excMsgId= AQJmsLink.sendToExceptionQueue msgId=D? AQJmsLink.subscribe is not a topic?S???? +created durable subscriber: {0}, queue: {1}?? AQJmsLink.unsubscribe??? +removed durable subscriber: {0}, queue: {1} AQJmsLink.unsubscribeOJMS oracle/mgw/drivers/JmsDestData?? oracle/jms/AQjmsSession?Y?? javax/jms/Topic?? 4OJMS unsubscribe removed subscriber {0} on topic {1} javax/jms/JMSException?? java/sql/SQLException?Y /OJMS subscriber {0} does not exist on topic {1} AQJmsLink.updateSub AQJmsLink.handleEvent??[?? AQJmsLink.initHandlesFactories?Y_^ request OCI conn pool?? 0initialize AQJmsConnectionFactory: use ociPool? f 0oracle/mgw/drivers/aq/jms/AQJmsConnectionFactoryD *AQJmsConnectionFactory is already non-NULL JmsConnection is NULL "assign OPHandle factories to pools? $AQJmsLink.closeResetHandlesFactories close pooled OPHandles } close JmsConnection release OCI conn pool}`` AQJmsLink.startAdminOperation null handle! :startAdminOperation: admin OPHandle already in use; link: AQJmsLink.getAQDest DestParams oracle/mgw/drivers/aq/QueueData oracle/mgw/drivers/aq/QTableData[[[[dD?[[ AQJmsLink.isPayloadSupported SYS.AQ$_JMS_MESSAGE SYS.AQ$_JMS_BYTES_MESSAGE SYS.AQ$_JMS_TEXT_MESSAGE SYS.AQ$_JMS_MAP_MESSAGE SYS.AQ$_JMS_STREAM_MESSAGE SYS.AQ$_JMS_OBJECT_MESSAGE SYS.ANYDATA payload= , supported= &oracle/mgw/common/LinkWrapperException? oracle/jms/AQjmsExceptionY AQJmsLink.traceSession mgwSession= jmsSession= jdbcConnection= oracle.jms.printLinkedException !"# #oracle/mgw/drivers/aq/jms/AQJmsLink oracle/mgw/drivers/aq/AQBaseLink AQJmsLink. oracle/mgw/common/FatalException 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/common/MessageID getIDAsString ()Ljava/lang/String; oracle/mgw/common/ApiTrace methodExit ((Ljava/lang/String;Ljava/lang/String;I)V methodEntry aqLinkParams .()Loracle/mgw/drivers/aq/AQLinkParamsNFactory; *oracle/mgw/drivers/aq/AQLinkParamsNFactory isLogTopic ()Z isTraceExit append -(Ljava/lang/String;)Ljava/lang/StringBuilder; java/lang/Integer toHexString (I)Ljava/lang/String; toString '(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; m_linkName 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; oracle/mgw/common/LogIdSet getId logSetCache_unregister (Loracle/mgw/common/LogIdSet;Z)Z m_tracer Loracle/mgw/common/Trace; oracle/mgw/common/Trace exception (Ljava/lang/Throwable;)V (Z)Ljava/lang/StringBuffer; oracle/mgw/common/DestParams getNativeName oracle/mgw/common/MgwUtil GatewayException `(Ljava/lang/Throwable;ILjava/lang/String;Ljava/lang/String;)Loracle/mgw/common/GatewayException; isLevel (I)Z toTraceString trace (Ljava/lang/String;I)V oracle/mgw/common/DestData getDestParams ()Loracle/mgw/common/DestParams; castJms >(Loracle/mgw/common/DestData;)Loracle/mgw/drivers/JmsDestData; isTopic registerConsumerP /(Loracle/mgw/drivers/ConsumerProducerParams;Z)Z N(Ljava/lang/Throwable;ILjava/lang/String;)Loracle/mgw/common/GatewayException; 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 unregisterConsumerP (Ljava/lang/String;Z)Z registerProducerP 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 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/JmsSession; closeTopicSubscribers checkin (Z)V 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; trcString 7(Loracle/mgw/drivers/ProducerParams;)Ljava/lang/String; produce >(Loracle/mgw/common/Message;)Loracle/mgw/drivers/JmsMessageID; getLinkedException ()Ljava/lang/Throwable; oracle/mgw/common/Message getMsgId ()Loracle/mgw/common/MessageID; getCode getReason H(Loracle/mgw/common/MessageID;ILjava/lang/String;Ljava/lang/Throwable;)V oracle/mgw/drivers/aq/AQUtil 1(Loracle/mgw/common/MessageID;)Ljava/lang/String; A(Loracle/mgw/common/MsgConsumer;)Loracle/mgw/drivers/JmsConsumer; 7(Loracle/mgw/drivers/ConsumerParams;)Ljava/lang/String; (J)Loracle/mgw/common/Message; /(Loracle/mgw/common/Message;)Ljava/lang/String; buildSelector_MessageID jmsReceive (J)Ljavax/jms/Message; getDestNativeName getSubName nvl_empty format n(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; getDestination ()Loracle/mgw/common/DestData; setExceptionMsgHandler 6(Ljavax/jms/Message;)Loracle/mgw/drivers/JmsMessageID; +(ILjava/lang/String;Ljava/lang/Throwable;)V m_adminLock commitOph $(Loracle/mgw/drivers/BaseOPHandle;)V J(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; getJmsSession ()Ljavax/jms/Session; getSessionType getJmsDestination -(Ljavax/jms/Session;I)Ljavax/jms/Destination; &(Ljavax/jms/Topic;Ljava/lang/String;)V ()Ljava/lang/Exception; getErrorCode oracle/mgw/common/Event getEntryEvent )(Ljava/lang/String;Ljava/lang/String;II)V requestOCIPool ,()Loracle/jdbc/pool/OracleOCIConnectionPool; (Z)Ljava/lang/StringBuilder; k(Loracle/mgw/drivers/aq/AQLinkParamsNFactory;Loracle/jdbc/pool/OracleDataSource;Loracle/mgw/common/Trace;)V createConnection $()Loracle/mgw/drivers/JmsConnection; setOPHandleFactory .(Loracle/mgw/drivers/PooledOPHandleFactory;Z)V m_adminOphPool destroyHandles oracle/mgw/drivers/JmsConnection releaseOCIPool )(Loracle/mgw/drivers/JmsConsumerParams;)V )(Loracle/mgw/drivers/JmsProducerParams;)V getDBConnection ()Ljava/sql/Connection; retrieveQueueNTableData <(Ljava/sql/Connection;Ljava/lang/String;)[Ljava/lang/Object; getQueueName getOwner getQueueTable getPayloadObjectType isMultipleConsumers ?(Loracle/mgw/common/DestParams;Loracle/mgw/common/MsgLink;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZZLoracle/mgw/common/Trace;)V getPayloadType java/lang/String equalsIgnoreCase getWrappedException getErrorNumber java/lang/System getProperty java/lang/Boolean FALSE Ljava/lang/Boolean; setProperty 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; !45 67 8 9 :7 8 ;<