MyCQ.QueueManager Interface Reference

Manages queues of a MyCQ Server. More...

List of all members.

Public Member Functions

void createP2PQueue (string queueName, QueueSchema queueSchema, int queueSize)
 Create a P2PQueue.
P2PQueue getP2PQueue (string queueName)
 Get a P2PQueue.
void close (P2PQueue p2pQueue)
 Close a P2PQueue.
void createTopicQueue (string queueName, QueueSchema queueSchema, int queueSize)
 Create a TopicQueue.
TopicQueue getTopicQueue (string queueName)
 Get a TopicQueue.
void close (TopicQueue topicQueue)
 Close a TopicQueue.
CQResultQueue getCQResultQueue (string queueName)
 Get a CQResultQueue.
void close (CQResultQueue cqResultQueue)
 Close a CQResultQueue.
List< string > getAllQueueNames ()
 Get all the queue names of a MyCQ Server.
List< string > getAllP2PQueueNames ()
 Get all the p2p queue names of a MyCQ Server.
List< string > getAllTopicQueueNames ()
 Get all the topic queue names of a MyCQ Server.
List< string > getAllCQResultQueueNames ()
 Get all the cq result queue names of a MyCQ Server.
void deleteQueue (string queueName)
 Delete a queue in a MyCQ Server.
void deleteAllQueues ()
 Delete all queues in a MyCQ Server.

Detailed Description

Manages queues of a MyCQ Server. 

using System;
using System.Collections.Generic;
using MyCQ;

namespace MyCQClientNETExample
{
    class ExamQueueManager
    {
        void examSetQueueSchema(QueueSchema queueSchema)
        {
            queueSchema.addBoolean("boolean");
            queueSchema.addByte("byte");
            queueSchema.addShort("short");
            queueSchema.addUShort("ushort");
            queueSchema.addInt("int");
            queueSchema.addLong("long");
            queueSchema.addFloat("float");
            queueSchema.addDouble("double");
            queueSchema.addDate("date");
            queueSchema.addTime("time");
            queueSchema.addDateTime("datetime");
            queueSchema.addString("string", 100);
            queueSchema.addVarString("varstring");
            queueSchema.addBinary("binary", 100);
            queueSchema.addVarBinary("varbinary");

            //columns
            //col 0: boolean
            //col 1: byte
            //col 2: short
            //col 3: ushort
            //col 4: int
            //col 5: long
            //col 6: float
            //col 7: double
            //col 8: date
            //col 9: time
            //col10: datetime
            //col11: string
            //col12: varstring
            //col13: binary
            //col14: varbinary
        }

        public void sample()
        {
            //get client instance
            MyCQClient client = MyCQFactory.getMyCQClient();

            try
            {
                //connect
                client.connect("localhost", 3030, "root", "1234");

                //get queue manager
                QueueManager queueManager = client.getQueueManager();

                queueManager.deleteAllQueues();

                //Queue Schema
                //get queue schema instance
                QueueSchema queueSchema = MyCQFactory.getQueueSchema();

                //set queue schema
                examSetQueueSchema(queueSchema);


                //P2P Queue
                //create p2p queue
                queueManager.createP2PQueue("p2pQueue", queueSchema, 100);

                //get p2p queue
                P2PQueue p2pQueue = queueManager.getP2PQueue("p2pQueue");

                //close p2p queue
                queueManager.close(p2pQueue);

                //delete queue
                queueManager.deleteQueue("p2pQueue");


                //TOPIC Queue
                //create a topic queue
                queueManager.createTopicQueue("topicQueue", queueSchema, 100);

                //get topic queue
                TopicQueue topicQueue = queueManager.getTopicQueue("topicQueue");

                //close topic queue
                queueManager.close(topicQueue);

                //delete queue
                queueManager.deleteQueue("topicQueue");


                //create queues
                for (int i = 0; i < 100; i++)
                {
                    string temp = "";

                    //p2p queue name
                    temp += "p2pQueue";
                    temp += i;
                    queueManager.createP2PQueue(temp, queueSchema, 100);

                    //topic queue name
                    temp = "";
                    temp += "topicQueue";
                    temp += i;
                    queueManager.createTopicQueue(temp, queueSchema, 100);

                }

                //get queues
                P2PQueue[] p2pQueues = new P2PQueue[100];
                TopicQueue[] topicQueues = new TopicQueue[100];

                for (int i = 0; i < 100; i++)
                {
                    string temp = "";

                    //p2p queue name
                    temp += "p2pQueue";
                    temp += i;
                    p2pQueues[i] = queueManager.getP2PQueue(temp);

                    //topic queue name
                    temp = "";
                    temp += "topicQueue";
                    temp += i;
                    topicQueues[i] = queueManager.getTopicQueue(temp);
                }

                //close queues
                for (int i = 0; i < 100; i++)
                {
                    queueManager.close(p2pQueues[i]);
                    queueManager.close(topicQueues[i]);
                }

                List<string> result;

                //get all queue names
                result = queueManager.getAllQueueNames();
                foreach (string str in result)
                {
                    Console.WriteLine(str);
                }

                //get all p2p queue names
                result = queueManager.getAllP2PQueueNames();
                foreach (string str in result)
                {
                    Console.WriteLine(str);
                }

                //get all topic queue names
                result = queueManager.getAllTopicQueueNames();
                foreach (string str in result)
                {
                    Console.WriteLine(str);
                }

                //delete all queues
                queueManager.deleteAllQueues();
            }
            catch (MyCQException ex)
            {
                Console.WriteLine("code:" + ex.getCode() + ", message:" + ex.getMessage());
            }

            //close connection
            client.close();
        }
    }
}

Member Function Documentation

void MyCQ.QueueManager.close ( CQResultQueue  cqResultQueue  ) 

Close a CQResultQueue.

Parameters:
cqResultQueue A reference of a cq result queue.
Exceptions:
MyCQException An error occurred while closing a cq result queue.
void MyCQ.QueueManager.close ( TopicQueue  topicQueue  ) 

Close a TopicQueue.

Parameters:
topicQueue A reference of a topic queue.
Exceptions:
MyCQException An error occurred while closing a p2p queue.
void MyCQ.QueueManager.close ( P2PQueue  p2pQueue  ) 

Close a P2PQueue.

Parameters:
p2pQueue A reference of a p2p queue.
Exceptions:
MyCQException An error occurred while closing a p2p queue.
void MyCQ.QueueManager.createP2PQueue ( string  queueName,
QueueSchema  queueSchema,
int  queueSize 
)

Create a P2PQueue.

Parameters:
queueName A queue name of a p2p queue to create. (size:= under 64). A queue name is a combination of alphabets and numerics which starts with alphabet character.
queueSchema A reference of a queue schema, that will be the queue schema of a p2p queue to create.
queueSize An integer greater than zero that will be the size of a p2p queue to create.
Exceptions:
MyCQException An error occurred while creating a new p2p queue.
void MyCQ.QueueManager.createTopicQueue ( string  queueName,
QueueSchema  queueSchema,
int  queueSize 
)

Create a TopicQueue.

Parameters:
queueName A queue name of a topic queue to create. (size:= under 64). A queue name is a combination of alphabets and numerics which starts with alphabet character.
queueSchema A reference of a queue schema, that will be the queue schema of a topic queue to create.
queueSize An integer greater than zero that will be the size of a topic queue to create.
Exceptions:
MyCQException An error occurred while creating a new topic queue.
void MyCQ.QueueManager.deleteAllQueues (  ) 

Delete all queues in a MyCQ Server.

Exceptions:
MyCQException An error occurred while deleting a queue.
void MyCQ.QueueManager.deleteQueue ( string  queueName  ) 

Delete a queue in a MyCQ Server.

Parameters:
queueName A queue name to delete.
Exceptions:
MyCQException An error occurred while deleting a queue.
List<string> MyCQ.QueueManager.getAllCQResultQueueNames (  ) 

Get all the cq result queue names of a MyCQ Server.

Returns:
Queue name list.
Exceptions:
MyCQException An error occurred while getting the queue name list.
List<string> MyCQ.QueueManager.getAllP2PQueueNames (  ) 

Get all the p2p queue names of a MyCQ Server.

Returns:
Queue name list.
Exceptions:
MyCQException An error occurred while getting the queue name list.
List<string> MyCQ.QueueManager.getAllQueueNames (  ) 

Get all the queue names of a MyCQ Server.

Returns:
Queue name list.
Exceptions:
MyCQException An error occurred while getting the queue name list.
List<string> MyCQ.QueueManager.getAllTopicQueueNames (  ) 

Get all the topic queue names of a MyCQ Server.

Returns:
Queue name list.
Exceptions:
MyCQException An error occurred while getting the queue name list.
CQResultQueue MyCQ.QueueManager.getCQResultQueue ( string  queueName  ) 

Get a CQResultQueue.

Parameters:
queueName A queue name of a cq result queue to get.
Returns:
A reference of a cq result queue.
Exceptions:
MyCQException An error occurred while getting a cq result queue.
P2PQueue MyCQ.QueueManager.getP2PQueue ( string  queueName  ) 

Get a P2PQueue.

Parameters:
queueName A queue name of a p2p queue to get.
Returns:
A reference of a p2p queue.
Exceptions:
MyCQException An error occurred while getting a p2p queue.
TopicQueue MyCQ.QueueManager.getTopicQueue ( string  queueName  ) 

Get a TopicQueue.

Parameters:
queueName A queue name of a topic queue to get.
Returns:
A reference of a topic queue.
Exceptions:
MyCQException An error occurred while getting a topic queue.
The documentation for this interface was generated from the following file:
 All Classes Functions Variables Properties
MyCQ .NET User's Document. Copyright@MyCQ Inc., All Rights Reserved.