Page History

package com.sos.jms;

import java.io.StringReader;
import java.net.URI;
import java.util.Base64;

import javax.json.Json;
import javax.json.JsonObject;
import javax.json.JsonReader;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.sos.commons.httpclient.SOSRestApiClient;
import com.sos.jms.consumer.SOSConsumer;
import com.sos.jms.producer.SOSProducer;

public class JmsExecute {

    private static final String JMS_URI = "tcp://[MESSAGE_SERVER_HOST]:61616";
    private static final String JOC_API_URL = "http://[JOC_COCKPIT_HOST]:[JOC_COCKPIT_PORT]/joc/api/";
    private static final String API_ADD_ORDER = "orders/add";
    private static final String API_LOGIN = "authentication/login";
    private static final String API_LOGOUT = "authentication/logout";
    private static final String JOC_API_REQUEST_BODY = "{\"controllerId\":\"testsuite\",\"orders\":[{\"workflowPath\":\"/JS7Demo/01_HelloWorld/jdHelloWorld\",\"scheduledFor\":\"now\"}],\"auditLog\":{}}";
    private static final String ACCESS_TOKEN_HEADER = "X-Access-Token";
    private static final String APPLICATION_JSON = "application/json";
    private static final String CONTENT_TYPE = "Content-Type";
    private static final Logger LOGGER = LoggerFactory.getLogger(JmsExecute.class);

    public static void main(String[] args) {
        if("produce".equals(args[0])) {
            SOSProducer producer = new SOSProducer(JMS_URI);
            producer.write(JOC_API_REQUEST_BODY);
        } else if ("consume".equals(args[0])) {
            SOSConsumer consumer = new SOSConsumer(JMS_URI);
            String consumedMessage = consumer.receiveFromQueue();
            SOSRestApiClient client = setupHttpClient();
            try {
                URI jocUri = URI.create(JOC_API_URL);
                LOGGER.info("send login to: " + jocUri.resolve(API_LOGIN).toString());
                String response = client.postRestService(jocUri.resolve(API_LOGIN), null);
                LOGGER.info("HTTP status code: " + client.statusCode());
                if (client.statusCode() == 200) {
                    JsonReader jsonReader = null;
                    String accessToken = null;
                    try {
                        jsonReader = Json.createReader(new StringReader(response));
                        JsonObject json = jsonReader.readObject();
                        accessToken = json.getString("accessToken", "");
                    } catch(Exception e) {
                        LOGGER.warn("Could not determine accessToken.");
                    } finally {
                        jsonReader.close();
                    }
                    client.addHeader(ACCESS_TOKEN_HEADER, accessToken);
                    client.addHeader(CONTENT_TYPE, APPLICATION_JSON);
                    LOGGER.info("REQUEST: " + API_ADD_ORDER);
                    LOGGER.info("PARAMS: " + consumedMessage);
                    String apiUrl = null;
                    if (!API_ADD_ORDER.toLowerCase().startsWith(JOC_API_URL)) {
                        apiUrl = JOC_API_URL + API_ADD_ORDER;
                    }
                    LOGGER.info("resolvedUri: " + jocUri.resolve(apiUrl).toString());
                    response = client.postRestService(jocUri.resolve(apiUrl), consumedMessage);
                    LOGGER.info("HTTP status code: " + client.statusCode());
                    response = client.postRestService(jocUri.resolve(API_LOGOUT), null);
                    LOGGER.info("HTTP status code: " + client.statusCode());
                }
            } catch (Exception e) {
                LOGGER.error(e.getMessage(), e);
            } finally {
                client.closeHttpClient();
            }

        }
    }
    
    private static SOSRestApiClient setupHttpClient() {
        SOSRestApiClient client = new SOSRestApiClient();
        String basicAuth = Base64.getMimeEncoder().encodeToString(("[USERNAME]:[PASSWORD]").getBytes());
        client.setBasicAuthorization(basicAuth);
        return client;
    }
    
}