Destinations, Topics & Queues

Destinations

In FioranoMQ 6.1 beta upwards, storage type has been introduced in the destinations. Storage types define the type of storage that should be used to store destinations. The possible storage types are file-based and RDBMS based stores. By default, the storage type is file based.

CODE

// For File Based destination
metadata1.setStorageType(IFioranoConstants.FILE_BASED_DATABASE); 
// For RDBMS based destination
metadata1.setStorageType(IFioranoConstants.RDBMS_BASED_DATABASE);

If a destination is file based, then all the persistent messages that are sent on this destination are stored in files. If a destination is RDBMS based, then all the persistent messages are stored in RDBMS.

Storage type is specified at the time of creating a destination.

Below are the steps to create a destination using storage type:

Look up an admin connection factory. Create an Admin connection.
Obtain the Admin Service from the Admin connection.
Create a new metadata. It can be either QueueMetaData or TopicMetaData.
Set the name of the destination.
Set the storage type of the destination.
Create the destination using the admin service.

Topics

This section explains the creation of Topic objects:

Creating the Admin Service

MQ Admin Service creates topics on the FioranoMQ server. The instance of admin service can be obtained from the admin connection.

CODE

acf = (MQAdminConnectionFactory) ic.lookup ("primaryACF");
ac = acf.createMQAdminConnection ("admin", "passwd");
adminService = ac.getMQAdminService();

2. Topic Metadata

Create a Topic metadata, specifying the name, description and the storage type. The storage type of the destination can be RDBMS_BASED_DATABASE or FILE_BASED_DATABASE

CODE

TopicMetaData metadata = new TopicMetaData ();
metadata.setName ("mytopic");
// For RDBMS based storage type
metadata.setStorageType(IFioranoConstants.RDBMS_BASED_DATABASE);

or

CODE

// For file based storage type
metadata.setStorageType(IFioranoConstants.FILE_BASED_DATABASE);

3. Create the Topic

Create the Topic object using the adminService and the topic metadata.

CODE

adminService.createTopic(metadata);

Queues

This section explains the creation of Queue objects:

Creating the Admin Service

MQ admin service creates queues on the FioranoMQ server. The instance of admin service can be obtained from the admin connection.

CODE

acf = (MQAdminConnectionFactory) ic.lookup ("primaryACF");
ac = acf.createMQAdminConnection ("admin", "passwd");
adminService = ac.getMQAdminService();

2. Queue Metadata

Create a queue metadata, specifying the name, description and the storage type. The storage type of the destination can be RDBMS_BASED_DATABASE or FILE_BASED_DATABASE

CODE

QueueMetaData metadata = new QueueMetaData ();
metadata.setName ("myqueue");
// For RDBMS based storage type
metadata.setStorageType(IFioranoConstants.RDBMS_BASED_DATABASE);

or

CODE

// For File based storage type
metadata.setStorageType(IFioranoConstants.FILE_BASED_DATABASE);

3. Create the Queue

Create the Queue object using the adminService and the queue metadata.

CODE

adminService.createQueue (metadata);