Ravichandra C's List: oracle

• ADD_TABLE_RULES
• ADD_TABLE_RULES
• 'capture'
• strmadmin.streams_queue
• 'apply',
• 'strmadmin.streams_queue'
• 'strmadmin.streams_queue'
• 'dequeue'
• strmadmin.streams_queue

7 more annotations...

• Next, an apply process dequeues these row LCRs from the same queue, reenqueues them into this queue, and sends them to a DML handler.
• 
• streams_type => 'capture',
• queue_name => 'strmadmin.streams_queue',
• streams_type => 'dequeue',
• queue_name => 'strmadmin.streams_queue',
• queue_name => 'strmadmin.streams_queue',
• streams_type => 'apply',
• queue_name => 'strmadmin.streams_queue',
• queue_name => 'strmadmin.streams_queue'

8 more annotations...

• • All possible things with Qs

  • Grouping by transactions -PLSQL
  • 2 more sticky notes...

  • • Handling of raw datatypes

    • dequeuing oracle object types by java
• Enqueuing and Dequeuing Object Type Messages (CustomDatum interface) Using Java
• Enqueuing and Dequeuing Object Type Messages (using SQLData interface) Using Java
• Dequeuing Messages Using Java
• Dequeuing Messages in Browse Mode Using Java
• Enqueuing and Dequeuing Messages Using Message Grouping Using PL/SQL
• -compatible=CustomDatum
• -usertypes=oracle
• c. Create the queue table and queue with ADT payload
• d. Enqueue and dequeue messages containing object payloads
• -usertypes=jdbc
• Example 2-30 Enqueuing and Dequeuing Messages Using Message Grouping Using PL/SQL

  • Grouping by transaction. Dequeuing by PLSQL

  • Grouping by transaction
• FOR mesgno
• msggroup_queue
• END LOOP
• COMMIT;
• msggroup_queue
• How do you do transformation of XML data?

16 more annotations...

• SYS.AQ$_AGENT('explicit_dq', NULL, NULL);

  • name
    
    
    Name of a producer or consumer of a message. The name must follow object name guidelines in the Oracle9i SQL Reference with regard to reserved characters.
    
    address
    
    
    Protocol-specific address of the recipient. If the protocol is 0, then the address is of the form [schema.]queue[@dblink].
    
    For example, a queue named emp_messages in the hr queue at the site dbs1.net has the following address:
    
    hr.emp_messages@dbs1.net
    
    protocol
    
    
    Protocol to interpret the address and propagate the message.

  • Identifies a producer or a consumer of a message.
    Syntax
    
    TYPE SYS.AQ$_AGENT IS OBJECT (
    name VARCHAR2(30),
    address VARCHAR2(1024),
    protocol NUMBER DEFAULT 0);
• SYS.AQ$_AGENT
• oe.get_oe_action

1 more annotation...

• In that sense LISTEN is not 'fair' in monitoring the queues.

• Example 11-9 Creating a JMS Connection and Session. Creating a Receiver to Receive Messages
• receiver
• receiver

1 more annotation...

• "performance", "delays", mysterious hangs without error messages
• problem only occurs with OCI drivers, with THIN drivers it worked fine

• When the Messaging Gateway agent processes a propagation job, it dequeues messages from the source queue and enqueues the messages to the destination queue.

  • does by polling

• 22.6 Propagating User-Enqueued LCRs from ANYDATA Queues to Typed Queues
• You can propagate user-enqueued LCRs to an appropriate typed queue, but propagation of captured LCRs to a typed queue is not supported.

• 1.7 Dequeue Features

  • Oracle recommends that you use a nonzero wait time for the first dequeue call on a queue in a session, and then use a zero wait time with the NEXT_MESSAGE navigation option for subsequent dequeue calls. If
• 4.6.5 Synonyms on Queue Tables and Queues
• 5.2.5 Creating Indexes on a Queue Table
• 22.6 Propagating User-Enqueued LCRs from ANYDATA Queues to Typed Queues

  • You can propagate user-enqueued LCRs to an appropriate typed queue, but propagation of captured LCRs to a typed queue is not supported.
• 22.6 Propagating User-Enqueued LCRs from ANYDATA Queues to Typed Queues

3 more annotations...

• 8.3.1 Creating a Transformation
• transformation

  • Specifies a transformation that will be applied when this subscriber dequeues the message. The source type of the transformation must match the type of the queue. If the subscriber is remote, then the transformation is applied before propagation to the remote queue.

• Transformations are exported with a schema or a full database export. If an AQ table is exported the transformation corresponding to the queue table will also be exported.
  
  

• Example 23-25 Dequeuing Messages Explicitly

  • Yes

  • can we deq the LCRs enqueued by capture process???

• Also, you can modify an LCR using an apply handler or a rule-based transformation. You can modify both LCRs captured by a capture process and LCRs constructed and enqueued by a user or application.

• Oracle recommends that you use a nonzero wait time for the first dequeue call on a queue in a session, and then use a zero wait time with the NEXT_MESSAGE navigation option for subsequent dequeue calls.

• Unconditional log groups log the before images of specified columns when the table is changed, regardless of whether the change affected any of the specified columns. Unconditional log groups are sometimes referred to as "always log groups." Conditional log groups log the before images of all specified columns only if at least one of the columns in the log group is changed.

  • is the entire column of table stored/ only the respective row??

• Displaying Supplemental Log Groups at a Source Database

• Supplemental Logging in a Streams Environment

• shows that a client browsing messages in a queue is not guaranteed a definite order with enqueue time ordering.

• one_animal
• queueopts.correlation := corr_id (customer_in, animal_in);
• one_animal (customer_in, animal_in);

1 more annotation...