Edit D:\app\Administrator\product\11.2.0\dbhome_1\owb\lib\int\oracle\sysman\vbo\vbos\VbosQueueImpl.class
?? /? ?F ?G ?H ?I ?J ?K ?L ?M ?N ?O ?PQ F ?R ?ST F ?U ?VW X YZ ?[ ?\ ?] ?^ ?_ ?` ?a bc ?de fghi #j ?k l m n o p q r s t 1uv w 4uxy ?z ?{| 8F ?} ?~ ? ?? 8?? $??? ?? ??? EF ?? E?? E? ?????? ?? ?? ?? 8? ?? ??? ?? ?????? ?? ?? 1? 1? 1? ?? ?? ?? ?? ?? ?? ?? 4? 4? ? 4? ? ?? ? ? ?? ?? ? ?? ?? ???? f???? {? ?? ??? {?? ?j?? ?? ?? ?????? ?? ?? ?? ?? ?? ?? ????? ?j? ?? ??? ?? ?? ??? ?? ??? ?? 1? ?? 1?? ?? ??? ?? ?? ??? ?? ?? ?? ?? ?? ?? ?? ?? ?? 4? ? ? ? ? $?? E ? 1 1 $ ? ? $ $ 1 1 ? 1 ? ? ! ? $"#$% ??&' ??( ?) 1*+ 1, 1-./0123 ?456789: 4;< 4=>?@A 4BCD E 4,F G ?HIJKL ?M ?NOPQRSTUVWX ?Y ?Z ?[ ?\ ?] ?^_`a 1F 1b 1c 4F 4d ?e fg ?hi jk ?lmnop ?qrs 9tu ?vw 9?xyz{|}~?? ?\ ?] ?? ??? ?? J? c ?? ? ?? ?? ? ?? ???? ????? ? ????? ?? T? J? T? T?? ?? J? ?? J? ?? ??? T?? j??? ?? ?? ??? ??? ? ?? ?? ??? ?? ?? ?? ????? original ,Loracle/sysman/vbo/vbos/VbosQueueAttributes; current COMPARE_BY_NAME S ConstantValue COMPARE_BY_ORDINAL COMPARE_BY_BODY columnsCompareFlag _81rdbms Ljava/lang/Boolean; _804rdbms _82rdbms _92rdbms _NP_SINGLE_QTABLE Ljava/lang/String; _NP_MULTI_QTABLE _NORMAL_QUEUE _EXCEPTION_QUEUE _NON_PERSISTENT_QUEUE? m_bMultiSubscribers Z m_queueTable81Compatible I m_sites Ljava/util/Vector; m_dbLinks m_repSites ![Loracle/sysman/vbo/vbos/RepSite; m_repDBLinks #[Loracle/sysman/vbo/vbos/RepDBLink; m_bCancelRefreshTopology m_bTransInitialized _LOCAL_LINK _PRESENTABLE_LOCAL_LINK <init> ()V Code LineNumberTable getTieObject ()Loracle/sysman/vbo/VboObject; getImplObject @(Loracle/sysman/vbo/VboObject;)Loracle/sysman/vbo/VboObjectImpl; getQueueImplObject getCurrent )()Loracle/sysman/vbo/VboAttributesObject; getOriginal setCurrent *(Loracle/sysman/vbo/VboAttributesObject;)V setOriginal initFromDataSource (I)V Exceptions validate saveSelectiveState doSQL (S)V getRemoveWarning ()Ljava/lang/String; removeFromDataSource getSubs #(Loracle/sysman/vdb/VdbParamList;)V initializeGeneral getQueueTable setQueueTable (Ljava/lang/String;)V setSchemaName getMaxRetries setMaxRetries getUserComment setUserComment getRetryDelay setRetryDelay getRetention setRetention getQueueType setQueueType isEnqueueEnabled ()Z setEnqueueEnabled (Z)V isDequeueEnabled setDequeueEnabled internalCompare |(Loracle/sysman/vbo/VboAttributesObject;Loracle/sysman/vbo/VboAttributesObject;Loracle/sysman/vbz/vbzu/VbzuDiffCollection;)V applyDiff )(Loracle/sysman/vbz/vbzu/VbzuDiffEntry;)Z? initializeSubscribers subscriberIsNew <(Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber;)Z getNextSubscriberOrdinal ()S getCurrentSubscribers .()Loracle/sysman/vbo/vbos/VbosQSubscriberList; getOriginalSubscribers getSubscribers <()[Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber; setSubscriberName (SLjava/lang/String;)V setSubscriberAddress setSubscriberDBLink setSubscriberRule setSubscriberTransformation addSubscriber <(Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber;)V removeSubscriber columnAt <(S)Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber; insertANewColumnInDiffColl h(Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber;Loracle/sysman/vbz/vbzu/VbzuDiffCollection;I)V insertANewColumnInDiffCol2 U(Loracle/sysman/vbo/vbos/VbosQSchedule;Loracle/sysman/vbz/vbzu/VbzuDiffCollection;I)V addSubscriberClause N(Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber;S)Ljava/lang/String; removeSubscriberClause modifyRuleClause initializeSchedules setCurrentDBLink setPropagationStartTime setPropagationNextTime setPropagationLatency setPropagationDuration setPropagationSchedule getCurrentScheduleInformation (()Loracle/sysman/vbo/vbos/VbosQSchedule; getIsScheduled (Ljava/lang/String;)Z isInScheduleList getScheduleLinkNames ()[Ljava/lang/String; getCurrentDBLinkName getPropagationStartTime getPropagationNextTime getPropagationLatency getPropagationDuration addSchedule addScheduleClause ;(Loracle/sysman/vbo/vbos/VbosQSchedule;S)Ljava/lang/String; _(Loracle/sysman/vbo/vbos/VbosQSchedule;SLjava/lang/String;Ljava/lang/String;)Ljava/lang/String; diffASchedule O(Loracle/sysman/vbo/vbos/VbosQSchedule;Loracle/sysman/vbo/vbos/VbosQSchedule;)Z modifyScheduleClause enabledScheduleClause getSupportsMultiSubscribers getStatistics revert updateDataSource getPropStats '(Ljava/lang/String;)[Ljava/lang/String; isPropagationEnabled setPropagationEnabled isQueueTable81Compatible isNPQueue _isNPQueue _is92rdbms _is82rdbms _is81rdbms _is804rdbms setInitFlags setCreating getSites #()[Loracle/sysman/vbo/vbos/RepSite; getDBLinks %()[Loracle/sysman/vbo/vbos/RepDBLink; initializeConfiguration initializeStatus addToRepDBLinks '(Ljava/util/Vector;Ljava/lang/String;)V findRepSite 4(Ljava/lang/String;)Loracle/sysman/vbo/vbos/RepSite; findRepDBLink H(Ljava/lang/String;Ljava/lang/String;)Loracle/sysman/vbo/vbos/RepDBLink; refreshSitesStatus $([Loracle/sysman/vbo/vbos/RepSite;)V refreshDBLinksStatus &([Loracle/sysman/vbo/vbos/RepDBLink;)V markNotConnected 8([Loracle/sysman/vbo/vbos/RepDBLink;Ljava/lang/String;)V initializeGlobalName getDatabaseGlobalName getServiceName initWrapper cancelRefreshTopology initializeTransformations getTransformationsList getTransformationsListType <clinit> SourceFile VbosQueueImpl.java?????????????????????? *oracle/sysman/vbo/vbos/VbosQueueAttributes???? java/util/Vector???? %oracle/sysman/vbo/vbos/_tie_VbosQueue???? oracle/sysman/vbo/VboObjectImpl????????-?.??????? 1506??? &oracle/sysman/vbo/VboValidateException java/lang/String???????????????????????? *oracle/sysman/vbo/vbos/VbosQSubscriberList?? (oracle/sysman/vbo/vbos/VbosQScheduleList ???? oracle/sysman/vdb/VdbParamList??%???"?? AQ$_MEM_SC?? FALSE TRUE????? java/lang/StringBuffer???? .???? NORMAL_QUEUE DBMS_AQADM.NORMAL_QUEUE EXCEPTION_QUEUE DBMS_AQADM.EXCEPTION_QUEUE????????????? CreateNPQueue???? CreateQueue AlterQueue StartAdvQueue StopAdvQueue???????????????????????? ????? java/lang/Object 4512? DropQueue ,oracle/sysman/vdb/VdbLostConnectionException GVbosQueueImpl.java: removeFromDataSource(): VdbLostConnectionException ?? ? .oracle/sysman/vbo/VboDataSourceUpdateException? 4558 !oracle/sysman/vdb/VdbSQLException <VbosQueueImpl.java: removeFromDataSource(): VdbSQLException ? sys.dba_tables owner table_name GetAdvQueueInfo@???? DVbosQueueImpl.java: initializeGeneral(): VdbLostConnectionException )oracle/sysman/vbo/VboInitFailureException 1508 9VbosQueueImpl.java: initializeGeneral(): VdbSQLException ?? .oracle/sysman/vbo/VboInsufficientInitException???? *oracle/sysman/vbz/vbzu/VbzuStringDiffValue?? ! (oracle/sysman/vbz/vbzu/VbzuBoolDiffValue??"???#$ $oracle/sysman/vbz/vbzu/VbzuDiffEntry%&'( *oracle/sysman/vbz/vbzu/VbzuDiffSubobjectId?)?*+, .oracle/sysman/vbz/vbzu/VbzuUniquenessException??$?-?./??0?0??1?2?3?4?56 SMP_OEM_DBAPP_$$_tmpTable %CreateSmpAdvancedQueueSubscriberTable HVbosQueueImpl.java: initializeSubscribers(): VdbLostConnectionException =VbosQueueImpl.java: initializeSubscribers(): VdbSQLException Oracle Error: ?7 #DropSmpAdvancedQueueSubscriberTable&? CreateListQueueSubscribers GetListQueueSubscribers8?9? @#:;? Local Database<?=>=???? ? GetSubscriberTransformation ZVbosQueueImpl.java: initializeSubscribers(): VdbSQLException (GetSubscriberTransformation)@A GetSubscriberRule 7**** e.oracleError == 4063 *************************** 6**** e.oracleError == 942 ***************************#?BCDEFGHIJK?L JVbosQueueImpl.java: initializeSubscribers(): VboInsufficientInitException java/sql/SQLException :VbosQueueImpl.java: initializeSubscribers(): SQLException java/io/IOException 9VbosQueueImpl.java: initializeSubscribers(): IOException java/lang/ExceptionM?N? 7oracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriberOP?? <schema.queuename> 0 , rule=> ' ' , transformation=> ' ' AddSubscriber?? RemoveSubscriber AlterSubscriberRuleTrans AlterSubscriberRule DD-MON-YYYY HH.MI.SS AM , schedule_disabled GetQueueScheduleQ? AQ$_LOCALR to_date(' ',' ') YS FVbosQueueImpl.java: initializeSchedules(): VdbLostConnectionException ;VbosQueueImpl.java: initializeSchedules(): VdbSQLException TU $oracle/sysman/vbo/vbos/VbosQScheduleV? NULL SchedulePropagation UnSchedulePropagation DisableSchedulePropagation EnableSchedulePropagation AQ$_MEM_MC $DoesQTableSupportMultipleSubscribers 1 NVbosQueueImpl.java: getSupportsMultiSubscribers(): VdbLostConnectionException CVbosQueueImpl.java: getSupportsMultiSubscribers(): VdbSQLException GetQueueID GetQueueStatistics @VbosQueueImpl.java: getStatistics(): VdbLostConnectionException 5VbosQueueImpl.java: getStatistics(): VdbSQLException ?W?????(?X? CVbosQueueImpl.java: updateDataSource(): VdbLostConnectionException 1509 8VbosQueueImpl.java: updateDataSource(): VdbSQLException Y?Z[\]??^? %oracle/sysman/vbo/VboAttributesObject?? GetPropStats_`ab ?VbosQueueImpl.java: getPropStats(): VdbLostConnectionException 4VbosQueueImpl.java: getPropStats(): VdbSQLException isQTable81Compatible 8.1cd KVbosQueueImpl.java: isQueueTable81Compatible(): VdbLostConnectionException @VbosQueueImpl.java: isQueueTable81Compatible(): VdbSQLException e? 9.2f: java/lang/Boolean CVbosQueueTableImpl.java: _is92rdbms(): VdbLostConnectionException: 8VbosQueueTableImpl.java: _is92rdbms(): VdbSQLException: 8.2 CVbosQueueTableImpl.java: _is82rdbms(): VdbLostConnectionException: 8VbosQueueTableImpl.java: _is82rdbms(): VdbSQLException: >VbosQueueImpl.java: _is81rdbms(): VdbLostConnectionException: 3VbosQueueImpl.java: _is81rdbms(): VdbSQLException: 8.0.4 ?VbosQueueImpl.java: _is804rdbms(): VdbLostConnectionException: 4VbosQueueImpl.java: _is804rdbms(): VdbSQLException: ;?g? GetAllScheduledSites oracle/sysman/vbo/vbos/RepSitehij?kljm?nj/0op oracle/sysman/vbo/vbos/RepDBLink56 KVbosQueueImpl.java: initializeConfiguration(): VdbLostConnectionException: @VbosQueueImpl.java: initializeConfiguration(): VdbSQLException: 78 DVbosQueueImpl.java: initializeStatus(): VdbLostConnectionException: 9VbosQueueImpl.java: initializeStatus(): VdbSQLException: 7VbosQueueImpl.java: initializeStatus(): VdbSQLExceptionq?rstu?v?34?wx?y?z? GetNumErrors{|}?~jj?j9: TestDBLink?? GetGlobalName?? HVbosQueueImpl.java: initializeGlobalName(): VdbLostConnectionException: =VbosQueueImpl.java: initializeGlobalName(): VdbSQLException: ??????? GetTransforms92? GetTransforms????????? GVbosQueueImpl.java: getTransformationsList(): VboInitFailureException: ? ??? $oracle/sysman/vbo/vbos/VbosQueueImpl +oracle/sysman/vbo/vbos/VbosSchemaObjectImpl *oracle/sysman/vbo/vbos/VbosQueueOperations NON_PERSISTENT_QUEUE ,oracle/sysman/vbo/VboDiffNotAppliedException /(Loracle/sysman/vbo/vbos/VbosQueueOperations;)V _delegate .()Loracle/sysman/vbo/vbos/VbosQueueOperations; setInit getObjectName %oracle/sysman/vxx/vxxn/VxxnStringUtil isValidOracleID vboMsgBundle .Loracle/sysman/emSDK/common/nls/MessageBundle; ,oracle/sysman/emSDK/common/nls/MessageBundle getMessage '(Ljava/lang/String;Z)Ljava/lang/String; )(ILjava/lang/String;[Ljava/lang/String;)V queueTable maxRetries userComment retryDelay retention queueType enqueueEnabled dequeueEnabled subscribers ,Loracle/sysman/vbo/vbos/VbosQSubscriberList; clone ()Ljava/lang/Object; schedules *Loracle/sysman/vbo/vbos/VbosQScheduleList; isCreating DEFINITION isInitialized (I)Z addItem equals (Ljava/lang/Object;)Z oracle/sysman/vxx/VxxString quoteApostrophe &(Ljava/lang/String;)Ljava/lang/String; getSchemaName append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; toString clearParameters EXECUTE 'oracle/sysman/vbo/vbos/VbosQueueSQLList sqlList )Loracle/sysman/vbo/vbos/VbosQueueSQLList; getSQLItem 2(Ljava/lang/String;)Loracle/sysman/vdb/VdbSQLItem; executeDDL A(Loracle/sysman/vdb/VdbSQLItem;Loracle/sysman/vdb/VdbParamList;)V SHOW_SQL doShowSQLText R(Loracle/sysman/vdb/VdbSQLItem;Loracle/sysman/vdb/VdbParamList;)Ljava/lang/String; size ()I subscriberAtIndex <(I)Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber; findPartialMatch t(Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber;)Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber; bToClone isNew rule scheduleAtIndex )(I)Loracle/sysman/vbo/vbos/VbosQSchedule; destinationName scheduleWithName :(Ljava/lang/String;)Loracle/sysman/vbo/vbos/VbosQSchedule; bScheduled enabled setSQLText setDefinitionText :(Ljava/lang/String;Z[Ljava/lang/Object;)Ljava/lang/String; reason oracle/sysman/vxx/vxxt/VxxtTRACE out stackTrace oracleError sqlStmt createStatement `(Loracle/sysman/vdb/VdbSQLItem;Loracle/sysman/vdb/VdbParamList;)Loracle/sysman/vdb/VdbStatement; executeQuery B(Loracle/sysman/vdb/VdbStatement;)Loracle/sysman/vdb/VdbResultSet; oracle/sysman/vdb/VdbResultSet next getString (I)Ljava/lang/String; getBoolean oracle/sysman/vdb/VdbStatement close checkInit (oracle/sysman/vbz/vbzu/VbzuDiffAttribute ON_SCHEMA *Loracle/sysman/vbz/vbzu/VbzuDiffAttribute; )oracle/sysman/vbz/vbzu/VbzuDiffCollection insertScalarEntry y(Loracle/sysman/vbz/vbzu/VbzuDiffAttribute;Loracle/sysman/vbz/vbzu/VbzuDiffValue;Loracle/sysman/vbz/vbzu/VbzuDiffValue;)V findExactMatch indexOf (Ljava/lang/Object;)I NAME (oracle/sysman/vbz/vbzu/VbzuDiffSubobject COLUMN *Loracle/sysman/vbz/vbzu/VbzuDiffSubobject; (Ljava/lang/String;I)V ?(Loracle/sysman/vbz/vbzu/VbzuDiffAttribute;Loracle/sysman/vbz/vbzu/VbzuDiffSubobject;Loracle/sysman/vbz/vbzu/VbzuDiffSubobjectId;Loracle/sysman/vbz/vbzu/VbzuDiffValue;Loracle/sysman/vbz/vbzu/VbzuDiffValue;)V insert )(Loracle/sysman/vbz/vbzu/VbzuDiffEntry;)V transformation EXISTENCE name *Loracle/sysman/vbz/vbzu/VbzuBoolDiffValue; startTime nextTime latency duration valueOf (Z)Ljava/lang/String; (I)Ljava/lang/StringBuffer; removeAllSubscribers createASubscriber (Ljava/lang/String;)I address dbLink substring (II)Ljava/lang/String; subscriberOrdinal subscriberWithName M(Ljava/lang/String;)Loracle/sysman/vbo/vbos/VbosQueuePackage/VbosQSubscriber; getClob (I)Loracle/sql/CLOB; oracle/sql/CLOB length ()J getCharacterStream ()Ljava/io/Reader; java/io/Reader read ([C)I ([C)V ordinal subscriberWithOrdinal elementAt (I)Ljava/lang/Object; removeAllSchedules createASchedule )(Loracle/sysman/vbo/vbos/VbosQSchedule;)V currentSchedule &Loracle/sysman/vbo/vbos/VbosQSchedule; destination isModified saveState copyThisSubscriber addElement (Ljava/lang/Object;)V copyThisSchedule N(Loracle/sysman/vbo/vbos/VbosQSchedule;)Loracle/sysman/vbo/vbos/VbosQSchedule; partialClone oracle/sysman/vdb/VdbSQLItem doSubs 4(Loracle/sysman/vdb/VdbParamList;)Ljava/lang/String; ((Ljava/lang/String;)[[Ljava/lang/String; compareVersion '(Ljava/lang/String;Ljava/lang/String;)I booleanValue compareDBVersionTo removeAllElements oracle/sysman/vbo/vbos/SiteType QUEUE !Loracle/sysman/vbo/vbos/SiteType; 7(Ljava/lang/String;Loracle/sysman/vbo/vbos/SiteType;I)V DATABASE_LINK globalName DATABASE copyInto ([Ljava/lang/Object;)V isEmpty elements ()Ljava/util/Enumeration; java/util/Enumeration hasMoreElements nextElement ((Ljava/lang/String;Ljava/lang/String;Z)V dbName sourceDB targetDB getInt (I)I numPropErrors DATABASE_ERRORS type DATABASE_LINK_ERRORS connected getStatement getSession *()Loracle/sysman/vdb/VdbAutoCommitSession; &oracle/sysman/vdb/VdbAutoCommitSession getService init @(Loracle/sysman/vdb/VdbSQLItem;)Loracle/sysman/vdb/VdbStatement; transformations 0Loracle/sysman/vbo/vbos/VbosQTransformationList; .oracle/sysman/vbo/vbos/VbosQTransformationList removeAllTransformations createATransformation A([Ljava/lang/String;)Loracle/sysman/vbo/vbos/VbosQTransformation; addTransformation /(Loracle/sysman/vbo/vbos/VbosQTransformation;)V getTransformationNames !?? ? ?? ?? ?? ? ? ?? ? ? ?? ? ? ?? ?? ?? ?? ?? ?? ? ? ?? ? ?? ? L ?? ? N ?? ? ? ?? ?? ?? ?? ?? ?? ?? ?? ?? ? ? ?? ? ? r ?? ? ? c*? *? *? *? *? *? *? *? *? *? *? *? Y? ? *? Y? ? *? Y? ? *? Y? ? ? ? B { ] ^ _ ` l m "