Skip Headers
Oracle® Objects for OLE C++ Class Library Developer's Guide
10g Release 2 (10.2)

Part Number B14308-01
Go to Documentation Home
Home
Go to Book List
Book List
Go to Table of Contents
Contents
Go to Index
Index
Go to Master Index
Master Index
Go to Feedback page
Contact Us

Enqueuing Messages

This topic includes examples for enqueuing RAW (string of characters) and user-defined type messages.

Note: For more information about sample code, see Sample Code and Applications.

Enqueuing RAW (String of Characters) Messages:

#include <oracl.h>

OSession osess ;

int EnqueueRaw();

int main(int argc, char **argv)

{

int retVal = 0;

OStartup(OSTARTUP_MULTITHREADED);

try

{

osess.Open();

if ( ! osess.IsOpen() )

{

cout << "Session not opened: Error: " << osess.GetErrorText() << endl;

osess.Close();

OShutdown();

return -1;

}

// Enqueue a payload of raw type

retVal = EnqueueRaw();

osess.Close();

OShutdown();

}

catch(OException oerr)

{

cout << "Exception while dequeuing message : " << oerr.GetErrorText() << endl;

retVal = -1;

}

return retVal;

}

// This function enqueues a message of default

// type (string of characters) to the queue.

// Sets the message attributes and queue attributes before enqueuing

int EnqueueRaw()

{

ODatabase odb;

const char *msgid = 0;

OAQ oaq;

OAQMsg oaqmsg;

odb.Open(osess, "ExampleDB", "SCOTT", "TIGER");

// Open the 'raw_msg_queue'

oaq.Open(odb,"raw_msg_queue");

// Get an instance of the default message(of RAW type)

oaqmsg.Open(oaq);

// Enqueue the message

// Set the actual message value

OValue oval = "My first message through OO4O ClassLibrary";

oaqmsg.SetValue(oval);

msgid = oaq.Enqueue();

const char *msgval = oval;

if ( msgid )

cout<<"Message : '"<<msgval<<"' Enqueued Successfully"<<endl;

// Set Message attributes - priority,Correlation identifier etc

oaqmsg.SetPriority(-6);

oaqmsg.SetCorrelation("FOR AQ");

// Set the actual message value

oval = "Another message";

oaqmsg.SetValue(oval);

// Enqueue the message

msgid = oaq.Enqueue();

msgval = oval;

if ( msgid )

cout<<"Message : '"<<msgval<<"' Enqueued Successfully"<<endl;

// Close all of the objects

oaqmsg.Close();

oaq.Close();

odb.Close();

return 0;

}

Enqueuing User-Defined Type Messages:

// This function enqueues a message of user-defined type MESSAGE_TYPE

// from the msg_queue.

// Sets the message attributes and queue attributes before enqueuing

int EnqueueObject()

{

OAQMsg oaqmsg;

OAQ oaq;

ODatabase odb;

const char *msgid = 0;

OValue oval;

char text[255];

odb.Open(osess, "ExampleDB", "SCOTT", "TIGER");

// Open the 'msg_queue'

oaq.Open(odb,"msg_queue");

// Get an instance of the udt MESSAGE_TYPE

// (check out schema for details)

oaqmsg.Open(oaq, OTYPE_OBJECT,"MESSAGE_TYPE");

// Enqueue a message

// Set the actual message value

OObject msgval(odb,"MESSAGE_TYPE");

msgval.SetAttrValue("SUBJECT", "BUY");

msgval.SetAttrValue("text", "ORCL >= 87");

oval = msgval;

oaqmsg.SetValue(oval);

msgid = oaq.Enqueue();

msgval.GetAttrValue("text",text,255);

if ( msgid )

cout<<"Message : '"<<text<< "' Enqueued Successfully"<<endl;

// Set Message attributes - priority,Correlation identifier etc

oaqmsg.SetPriority(-6);

oaqmsg.SetCorrelation("FOR SCOTT");

// Set the actual message value

msgval.SetAttrValue("subject", "SELL");

msgval.SetAttrValue("text", "MSFT < 120");

oval = msgval;

oaqmsg.SetValue(oval);

// Enqueue a message

msgid = oaq.Enqueue();

msgval.GetAttrValue("text",text,255);

cout<<"Message : '"<<text<<"' Enqueued Successfully"<<endl;

// Close all of the objects

oaqmsg.Close();

oaq.Close();

odb.Close();

return 0;

}