Edit D:\app\Administrator\product\11.2.0\dbhome_1\mgw\jlib\oracle\mgw\drivers\aq\AQAdminMgr.class
?? 1? ? ? !" #$ %& ?'() *+ ,- ?. %/ 0123 4 05 ?6 ?789: ,;<=>?@ABC ,DEF G 0HIJKLM #N O& OPQRS ?T OU OVW OX ?YZ [\ ?]^ ?_ `a ?bc ?defghijklm ?n 0o pq `rst Zu ? 0vw ? 0x ?yz{ p|}~ 0???????? p??????????????????? ?? ???????? ?? ?? ??? ?? 0? ?? ???? DEBUG Z ConstantValue DOT Ljava/lang/String; <init> ()V Code LineNumberTable LocalVariableTable this "Loracle/mgw/drivers/aq/AQAdminMgr; getCountForQueue N(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)I trcm errm qtObj msgState conn Ljava/sql/Connection; schema qtable qname stmt Ljava/sql/PreparedStatement; rs Ljava/sql/ResultSet; sql Exceptions getCountForSubscriber `(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)I subName getSubscriberID `(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)J subObj isSubscriber `(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Z sub_type I validSub addQueueSubscriber N(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V queueName rule Ljava/sql/CallableStatement; removeQueueSubscriber <(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)V alterSubscriberRule moveMessage ?(Ljava/sql/Connection;Ljava/lang/String;Loracle/mgw/drivers/aq/AQMessageID;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/AQMessageID; srcQueue msgId #Loracle/mgw/drivers/aq/AQMessageID; destQueue midDest? removeMessage _(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Loracle/mgw/drivers/aq/AQMessageID;)Z sqlE Ljava/sql/SQLException; found describeQueueTable ](Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/QTableData; tableName describeQueue \(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/QueueData; describeTransformation N(Ljava/sql/Connection;Ljava/lang/String;)Loracle/mgw/drivers/aq/TransformData; fullName array [Ljava/lang/String; `(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/TransformData; owner name describeSubscriber ?(Ljava/sql/Connection;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Loracle/mgw/drivers/aq/SubscriberData; subsData &Loracle/mgw/drivers/aq/SubscriberData; toSubscriberData N(Ljava/sql/ResultSet;Ljava/lang/String;)Loracle/mgw/drivers/aq/SubscriberData; agentName agentAddress transformName ruleName subsId J agentProtocol subsType toQueueData 7(Ljava/sql/ResultSet;)Loracle/mgw/drivers/aq/QueueData; qtype enqEnabled deqEnabled s qid maxRetries retryDelay toQTableData 8(Ljava/sql/ResultSet;)Loracle/mgw/drivers/aq/QTableData; multipleConsumers txMsgGrouping objectTypeName sortOrder compatible payloadType toTransformData ;(Ljava/sql/ResultSet;)Loracle/mgw/drivers/aq/TransformData; fromType toType transformId closeStmt (Ljava/sql/Statement;)V Ljava/sql/Statement; closeRSet (Ljava/sql/ResultSet;)V rset toUpper &(Ljava/lang/String;)Ljava/lang/String; isLogLevel (I)Z level trace (Ljava/lang/String;I)V message SourceFile AQAdminMgr.java ? ? java/lang/StringBuffer ?? ?? .AQ$ ?? READY select count(*) from qt ( where qt.msg_state = ? AND qt.queue = ?? ??? ?? OAQAdminMgr.getCountForQueue query: query: {0} qtable={1}, queue={2}, state={3} java/lang/StringBuilder ?? .? ?? ??? ?? Cno result set returned: query: {0} qtable={1}, queue={2}, state={3} java/sql/SQLException ?? ?? AND qt.consumer_name = ? , AND qt.address IS NULL AND qt.protocol = 0 dAQAdminMgr.getCountForSubscriber query: query: {0} qtable={1}, queue={2}, subscriber={3}, state={4} ?? Sno result set returned: query: {0} qtable={1}, queue={2}, subscriber={3}, state={4} .AQ$_ _S select subscriber_id ' where (bitand(subscriber_type,1) = 1) # AND queue_name = ? and name = ? ' AND address IS NULL AND protocol = 0 GAQAdminMgr.getSubscriberID query: query: {0} queue={1}, subscriber={2} ?? <no result set returned: query: {0} queue={1}, subscriber={2} ?? ?? select subscriber_type subs " where name = ? and queue_name = ? DAQAdminMgr.isSubscriber query: query: {0} queue={1}, subscriber={2} 3{call sys.mgw_aqdriver.add_queue_subscriber(?,?,?)} ??? ?? 4{call sys.mgw_aqdriver.remove_queue_subscriber(?,?)} 4{call sys.mgw_aqdriver.alter_subscriber_rule(?,?,?)} /{call sys.mgw_aqdriver.move_message(?,?,?,?,?)} ?? ?? ?? !oracle/mgw/drivers/aq/AQMessageID ?? ?? -{call sys.mgw_aqdriver.remove_message(?,?,?)} ?? Bselect * from all_queue_tables where queue_table = ? and owner = ? ? ? 5select * from all_queues where name = ? and owner = ? ? ?? ?? ? ? Bselect * from sys.dba_transformations where name = ? and owner = ? &select s.subscriber_id, s.queue_name, 3 s.name, s.address, s.protocol, s.subscriber_type, s.trans_name, s.rule_name from s (where (bitand(s.subscriber_type,1) = 1) % and s.queue_name = ? and s.name = ? * and s.address is NULL and s.protocol = 0 JAQAdminMgr.describeSubscriber query: query: {0} queue={1}, subscriber={2} ? ? ??? ?? ?? "queue_name" is null $oracle/mgw/drivers/aq/SubscriberData ?? ? queue_table ?? queue_type "queue_type" is null NORMAL_QUEUE ?? EXCEPTION_QUEUE NON_PERSISTENT_QUEUE max_retries ?? retry_delay enqueue_enabled "enqueue_enabled" is null no dequeue_enabled "dequeue_enabled" is null oracle/mgw/drivers/aq/QueueData ?? "queue_table" is null type "type" is null variant type 'variant' not supported raw RAW object object_type "object_type" is null "owner" is null sort_order recipients "recipients" is null MULTIPLE message_grouping "message_grouping" is null NONE "compatible" is null oracle/mgw/drivers/aq/QTableData ?? transformation_id from_type "from_type" is null to_type "to_type" is null #oracle/mgw/drivers/aq/TransformData ??? ? ?? ?? AQN ?? ?? ? oracle/mgw/drivers/aq/AQAdminMgr java/lang/Object "oracle/mgw/common/GatewayException (I)V append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; toString ()Ljava/lang/String; java/sql/Connection prepareStatement 0(Ljava/lang/String;)Ljava/sql/PreparedStatement; java/sql/PreparedStatement setString (ILjava/lang/String;)V -(Ljava/lang/String;)Ljava/lang/StringBuilder; oracle/mgw/common/MgwUtil format n(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; executeQuery ()Ljava/sql/ResultSet; java/sql/ResultSet next ()Z (Ljava/lang/String;)V getInt (I)I ?(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; \(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/String; ((Ljava/lang/String;Ljava/lang/String;I)V getLong (I)J prepareCall 0(Ljava/lang/String;)Ljava/sql/CallableStatement; java/sql/CallableStatement execute getIDAsBytes ()[B setBytes (I[B)V registerOutParameter (II)V getBytes (I)[B ([B)V getErrorCode ()I oracle/mgw/drivers/aq/AQUtil parseFullName '(Ljava/lang/String;)[Ljava/lang/String; getString (I)Ljava/lang/String; java/lang/String toUpperCase 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; `(JLjava/lang/String;Ljava/lang/String;Ljava/lang/String;IILjava/lang/String;Ljava/lang/String;)V (Ljava/lang/String;)J equalsIgnoreCase (Ljava/lang/String;)Z (Ljava/lang/String;)I ;(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;JI)V `(Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;ZZLjava/lang/String;Ljava/lang/String;)V L(Ljava/lang/String;Ljava/lang/String;JLjava/lang/String;Ljava/lang/String;)V java/sql/Statement close oracle/mgw/common/MgwLog getMgwLogger ()Loracle/mgw/common/MgwLog; exception *(Ljava/lang/String;Ljava/lang/Throwable;)V isLevel (II)Z )(Ljava/lang/String;Ljava/lang/String;II)V ! ? ? ? ? ? ? ? ? ? ? ? ? / *? ? ? ? ? ? ? ? ? ? :::+? L,? M-? N? Yd? +? ? ,? ? ::? Y ? ? ? ? ? ? ? :*? :? -? ? ? ,? Y? +? ? ,? ? -? : ? ? :? ? 0? Y? +? ? ,? ? -? : ? Y ? ?? 6 ? ? ?: ? ? ? ? ? b ? ? ? ? ? ? ? 3 ? 7 ? _ ? i ? s ? | ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? p ? ? ? ? ? ? 3 ? ? ? 7 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? = 1:::+? L,? M-? N? :? Yd? +? ? ,? ? :: ? Y ? ? ? ? ? ? ? !? ? :*? : ? -? ? ? ? ."? Y? +? ? ,? ? - ? #: ? ? :? ? 2$? Y? +? ? ,? ? - ? #: ? Y ? ?? 6 ? ? ?: ? ? ? " "$" ? j J K L O P Q R W :\ >_ pg zh ?i ?j ?l ?n ?s ?v ?x ?{? ???"?)? ? z ? ? ? ? ? : ? ? ? > ? ? ? 1 ? ? 1 ? ? 1 ? ? 1 ? ? 1 ? ? . ? ? + ? ? ( ? ? ? ? ? ? !:::+? L,? M-? N? :? Yd? +? %? ,? &? ? :? Y ? '? ? ? (? )? *? ? :*? :-? ? ? ? ++? Y? +? ? -? ? ? ,: ? ? :? ? 3-? Y? +? ? -? ? ? ,: ? Y .? /?? 0 7 ? ? ?: ? ? ? ? b ? ? ? ? ? ? ? ? ?? l? v? ? ?? ?? ?? ?? ?? ?? ?? ??? ??? ? p ? ? ? ? ? ? ? ? ? ? ! ? ? ! ? ? ! ? ? ! ? ? ! ? ? ? ? ? ? ? ? ? ? ? ? :::+? L,? M-? N? :? Yd? +? %? ,? &? ? :? Y ? 1? ? ? 2? 3? *? ? :*? :? -? ? ? +4? Y? +? ? -? ? ? ,: ? ? :6 ? ? ? 6 ~? 6 6 ? ? ?: ? ? ? ? ? ? ? ? ? j + , - 0 1 2 3 8 ?@ lG vH ?I ?K ?M ?R ?U ?X ?Z ?a ?b ?c ?f ?j ?k ?j ?k ? z ? ? ? ? ? ? ? ? ? ? ? / ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? G:5:*? 6 :+? 7 ,? 7 -? 7 ? 8 W? ? :? ? 4 < < > < ? . ? ? ? ? ? #? ,? 4? 9? <? F? ? > - ? ? G ? ? G ? ? G ? ? G ? ? D ? ? ? ? ? ? ? 7N9:*? 6 N-+? 7 -,? 7 -? 8 W-? ? :-? ? & - - / - ? * ? ? ? ? ? ? &? *? -? 6? ? 4 ? ? 7 ? ? 7 ? ? 7 ? ? 5 ? ? ? ? ? ? ? G:::*? 6 :+? 7 ,? 7 -? 7 ? 8 W? ? :? ? 4 < < > < ? . # , 4 9 < F ? > - ? ? G ? ? G ? ? G ? ? G ? ? D ? ? ? ? ? ? , t::;:*? 6 :+? 7 ,? <? = -? 7 ? 7 ? > ? 8 W? ?Y? @ ? A:? ? :? ?? _ g g i g ? > \ ] a c e f )g 2h <i Fk Nm _q dr gq qt ? R U ? ? t ? ? t ? ? t ? ? t ? ? t ? ? q ? ? n ? ? ? ? ? ? ? > j6:B:*? 6 :+? 7 -? <? = ,? 7 ? 8 W6? ? %:b?? C? ?? ? :? ?? = E = ] E U ] ] _ ] ? J ? ? ? ? ? ? )? 2? :? =? B? E? G? R? U? Z? ]? g? ? R 3 ? ? G ? ? j ? ? j ? ? j ? ? j ? ? g ? ? d ? ? ? ? ? ? - qN::+? L,? MD:*? N-,? -+? -? :? ? ? E:? -? ?:? -? ?:? -? ? H c T W c c e c ? N ? ? ? ? ? ? ? ? '? /? 7? A? H M T? W \ c j ? > q ? ? q ? ? q ? ? o ? ? l ? ? i ? ? ? ? ? ? - qN::+? L,? MF:*? N-,? -+? -? :? ? ? G:? -? ?:? -? ?:? -? ? H c T W c c e c ? N ! $ % * - . '/ /0 72 A3 H9 M: T5 W9 \: c9 j: ? > q ? ? q ? ? q ? ? o ? ? l ? ? i ? ? ? ? ? ? R +? HM*,2,2? I? ? T U ? ? ? ? ? ? ? ? ? ? ? - qN::+? L,? MJ:*? N-,? -+? -? :? ? ? K:? -? ?:? -? ?:? -? ? H c T W c c e c ? N s t u x y } ? ? '? /? 7? A? H? M? T? W? \? c? j? ? > q ? ? q ? ? q ? ? o ? ? l ? ? i ? ? ? ? ? ? ::::+? L,? M-? N? :? Yd? +? %? ,? &? ? : ? Y ? L? M? N? O? ? P? Q? R? S? ? :*? :-? ? ? ? +T? Y? +? ? -? ? ? ,: ? ? :? ? +? U: ? ? ?: ? ? ?: ? ? ? " ? ? ? ? j ? ? ? ? ? ? ? ? "? B? ~? ?? ?? ?? ?? ?? ?? ?? ?? ? ? ?? ? ? ? p ? ? ? B ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ; ?*? ?*? 0 7*? V N-? +-? W? XN? ? YY? ?*? V :*? V :*? 6 *? 6 *? V :*? V :? ZY- ? [? ? : % & ) , . / )1 34 <7 E< NA XD bG lM ? f ? ? ? ? ? ? k ? ? < G ? ? E > ? ? b ! ? ? l ? ? s ? ? N 5 ? ? X + ? ? ? ? ? ? % ?*? ?*\? ] M*^? ] N*_? ` 7*a? ] :*b? ] L+? ? Yc? ?+d? e? 6? $+f? e? 6? +g? e? 6? 6*h? i 6*j? i 6 *k? ] L+? ? Yl? ?+m? e? 6 ? 6 *n? ] L+? ? Yo? ?+m? e? 6 ? 6 ? pY,-? q? ? ~ l m r s t #u -x 6z ;{ E| N} T~ ] c? l? r? u? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ? ? Q ? ? ` ? ? o ? ? ? ? ? ? ? ? ? ? ? 6 ? ? ? ? ? ? ? ? ? - ? ? ? # ? ? ? u x ? ? n ? ? ? d ? ? ? : ? ? ? ? ? ? ? ? ? ? G*? ?*^? ] M,? ,? WM? ? Yr? ?6:*s? ] L+? ? Yt? ?+u? e? 6? Yv? ?+w? e? 6x:? 2+y? e? )6*z? ] :? ? W:? ? Y{? ?*a? ] N-? ? Y|? ?-? WN*}? ] :*~? ] L+? ? Y? ?+?? e? 6? 6*? ] L+? ? Y? ?+? e? 6 ? 6 *? ] :? ? Y? ? ?,- ? ? ? ? , ? ? ? ? ? ? &? )? ,? 5? :? D? M? P? Z? c? f? m? v? y? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ? ? ? ? ? ? !'1 ? z ? ? ? ? ? G ? ? 5 ? ? 7 ? ? ? ? ? ? , ? ? ? ? ? ? ! & ? ) ? ? Z ? ? 0 ? ? ? ? p*? ?*\? ] L*a? ] M*? ` 7*? ] N-? ? Y? ?-? WN*? ] :? ? Y? ?? W:? ?+,-? ? ? : / 0 4 5 : #= ,> 1? ;A @D JE PF ZH aJ ? > p ? ? ` ? ? W ? ? , D ? J & ? # M ? ? ? i *? *? ? ? L? ??+? ? ? W [ a ] ` c ? ? ? ? ? i *? *? ? ? L? ??+? ? ? o s y u x { ? ? ? ? ? > *? *?*? W? ? ? ? ? ? ? ? ? 5 ? ? ? ? ? ? ? ? ? F ? ??* ? ? ? ? ? ? ? ?
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de