Page History

private void execute() throws Exception {
    Variable_set params = spooler_task.params();
    params.merge(spooler_task.order().params());
    spooler_log.debug9(params.xml());
    String protocol = spooler_task.params().value("MQ_Protocol");
    spooler_log.debug9("Received protocol: " + protocol);
    String messageHost = spooler_task.params().value("MQ_Host");
    spooler_log.debug9("Received MQ Host: " + messageHost);
    String messagePort = spooler_task.params().value("MQ_Port");
    spooler_log.debug9("Received MQ port: " + messagePort);
    String queueName = spooler_task.params().value("MQ_QueueName");
    spooler_log.debug9("Received Queue name: " + queueName);
    String message = spooler_task.params().value("message");
    spooler_log.debug9("Received message: " + message);
    if(protocol == null || (protocol != null && protocol.isEmpty())){
        protocol = DEFAULT_PROTOCOL;
    }
    if(queueName == null || (queueName != null && queueName.isEmpty())){
        queueName = DEFAULT_QUEUE_NAME;
    }
    String connectionUrl = createConnectionUrl(protocol, messageHost, messagePort);
    if(message != null && !message.isEmpty()){
        write(message, connectionUrl, queueName);
    } else {
        spooler_log.error("Message is empty, nothing to send to message server");
    }
}