Jms.java

package org.objectweb.jonas.ant.jonasbase;

import java.util.StringTokenizer;

import org.objectweb.jonas.ant.JOnASBaseTask;

public class Jms extends Tasks {

    private static final String INFO = "[JMS] ";

    private static final String DEFAULT_PORT = "16010";

    private static final String DEFAULT_TOPIC = "sampleTopic";

    private static final String TOPIC_PROPERTY = "Topic";

    private static final String QUEUE_PROPERTY = "Queue";

    private static final String DEFAULT_QUEUE = "sampleQueue";

    public Jms() {
        super();
    }

    public void setPort(String portNumber) {

        // For JMS
        JReplace propertyReplace = new JReplace();
        propertyReplace.setConfigurationFile(JOnASBaseTask.JORAM_CONF_FILE);
        propertyReplace.setToken(DEFAULT_PORT);
        propertyReplace.setValue(portNumber);
        propertyReplace.setLogInfo(INFO + "Setting Joram port number to : " + portNumber + " in "
                + JOnASBaseTask.JORAM_CONF_FILE + " file.");
        addTask(propertyReplace);

        // for RAR file
        propertyReplace = new JReplace();
        propertyReplace.setConfigurationFile(JOnASBaseTask.JORAM_ADMIN_CONF_FILE);
        propertyReplace.setToken(DEFAULT_PORT);
        propertyReplace.setValue(portNumber);
        propertyReplace.setLogInfo(INFO + "Setting Joram port number to : " + portNumber + " in "
                + JOnASBaseTask.JORAM_ADMIN_CONF_FILE + " file.");
        addTask(propertyReplace);
    }

    public void setInitialTopics(String initialTopics) {
        JReplace propertyReplace = new JReplace();
        propertyReplace.setConfigurationFile(JOnASBaseTask.JORAM_ADMIN_CONF_FILE);
        propertyReplace.setToken(DEFAULT_TOPIC);
        String tokenValue = "";
        StringTokenizer st = new StringTokenizer(initialTopics, ",");

        while (st.hasMoreTokens()) {
            String topic = st.nextToken();
            if (st.hasMoreTokens()) {
                tokenValue += topic + "\n" + TOPIC_PROPERTY + "   ";
            } else {
                tokenValue += topic;
            }
        }

        propertyReplace.setValue(tokenValue);
        propertyReplace.setLogInfo(INFO + "Setting initial topics to : " + initialTopics);
        addTask(propertyReplace);
    }

    public void setInitialQueues(String initialQueues) {
        JReplace propertyReplace = new JReplace();
        propertyReplace.setConfigurationFile(JOnASBaseTask.JORAM_ADMIN_CONF_FILE);
        propertyReplace.setToken(DEFAULT_QUEUE);

        String tokenValue = "";
        StringTokenizer st = new StringTokenizer(initialQueues, ",");

        while (st.hasMoreTokens()) {
            String topic = st.nextToken();
            if (st.hasMoreTokens()) {
                tokenValue += topic + "\n" + QUEUE_PROPERTY + "   ";
            } else {
                tokenValue += topic;
            }
        }

        propertyReplace.setValue(tokenValue);
        propertyReplace.setLogInfo(INFO + "Setting initial queues to : " + initialQueues);
        addTask(propertyReplace);
    }
}

---