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

Detailed Description

Manages queues of a MyCQ Server. 

import java.util.List;

import mycq.*;

public class ExamQueueManager {

            void examSetQueueSchema(QueueSchema queueSchema) {
                        try {

                                    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

                        } catch (MyCQException ex) {
                                    System.out.println("code:" + ex.getCode() + ", message:"
                                                            + ex.getMessage());
                        }
            }

            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();

                                    CQManager cqm = client.getCQManager();
                                    cqm.deleteAllCQ();

                                    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();
                                    for (String str : result) {
                                                System.out.println(str);
                                    }

                                    // get all p2p queue names
                                    result = queueManager.getAllP2PQueueNames();
                                    for (String str : result) {
                                                System.out.println(str);
                                    }

                                    // get all topic queue names
                                    result = queueManager.getAllTopicQueueNames();
                                    for (String str : result) {
                                                System.out.println(str);
                                    }

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

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

Member Function Documentation

void mycq.QueueManager.close ( CQResultQueue  cqResultQueue  )  throws MyCQException

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  )  throws MyCQException

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  )  throws MyCQException

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 
) throws MyCQException

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 
) throws MyCQException

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 (  )  throws MyCQException

Delete all queues in a MyCQ Server.

Exceptions:
MyCQException An error occurred while deleting a queue.
void mycq.QueueManager.deleteQueue ( String  queueName  )  throws MyCQException

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 (  )  throws MyCQException

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 (  )  throws MyCQException

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 (  )  throws MyCQException

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 (  )  throws MyCQException

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  )  throws MyCQException

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  )  throws MyCQException

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  )  throws MyCQException

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.
 All Classes Namespaces Functions Variables Enumerations
MyCQ Java User's Document. Copyright@MyCQ Inc., All Rights Reserved.