Connecting-Expertise OpenApi

Authorization: Bearer eyJhbGciOiJSUzI1NiIsInR5cCIgOiAiSldUIiwia2lkIiA6ICJqb19wZC1HeHMxQUZscUhvNGUxMXo5Zm9sN083aFAzMVhjMS1fYmhabENRIn0eyJleHAiOjE2NDAxMTQ2MDksImlhdCI6MTY0MDExNDMwOSwianRpIjoiNTJhZGE5ZTQtNTQyZS00MTc2LWJiMWUtZGVlZDFmNzI2Y2Y3IiwiaXNzIjoiaHR0cHM6Ly9hdXRoLW5vbnByb2QuY29ubmVjdGluZy1leHBlcnRpc2UuY29tL2F1dGgvcmVhbG1zL2RldmVsb3AiLCJhdWQiOiJhY2NvdW50Iiwic3ViIjoiYzRmMTNjNTYtNzhmYi00Y2RhLTg3NDQtYmVmM2Y5OGUxNDZlIiwidHlwIjoiQmVhcmVyIiwiYXpwIjoic3VwcGxpZXJUZXN0Iiwic2Vzc2lvbl9zdGF0ZSI6IjgzYjc3ZGM0LWEyMjItNGY5MS1hYzIwLWQyYTE3YjdiNTU0ZCIsImFjciI6IjEiLCJyZWFsbV9hY2Nlc3MiOnsicm9sZXMiOlsiZGVmYXVsdC1yb2xlcy1kZXZlbG9wIiwib2ZmbGluZV9hY2Nlc3MiLCJ1bWFfYXV0aG9yaXphdGlvbiJdfSwicmVzb3VyY2VfYWNjZXNzIjp7ImFjY291bnQiOnsicm9sZXMiOlsibWFuYWdlLWFjY291bnQiLCJtYW5hZ2UtYWNjb3VudC1saW5rcyIsInZpZXctcHJvZmlsZSJdfX0sInNjb3BlIjoicHJvZmlsZSBlbWFpbCIsImVtYWlsX3ZlcmlmaWVkIjp0cnVlLCJwcmVmZXJyZWRfdXNlcm5hbWUiOiJhcGlAY29udGluZ2VudC5jb20iLCJlbWFpbCI6FDFwaUBjb250aW5nZW50LmNvbSJ9eQacAr_tvEgHrIQpE5vzhp1yDXpv_QDviFWr6Rf2zWJD_mBFA12S25cu3qq8fZq9NtHpvg6nhQ2hbilHHLez3g3YiuZKu1ZG6pf9dwQ1w0TMOEDxIgWduMHt_g0r9YCCHmy3y1Af5rIeq3g8_uySQ1iSJy9IKWMeGaHfRBmrhaalu0UU5jzKy4vEXc81TDtDVMP2vdwJUwxoQTsHEcdw3Ul024qonxOcUHRCs1pIOiu2d_ViRgdf9P0DPiWfPdYuoheUJQHoTPTChuXYCXtjTRwLZAcuySUUeORVb7ty7WXD0wkKJjQTMgg5yGrw9wn5iOl4ByCLHdUw
...

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
import paho.mqtt.client as mqtt
import time
import requests

connection_result_codes = {
	0: "Connection successful",
	1: "Connection refused - incorrect protocol version",
	2: "Connection refused - invalid client identifier",
	3: "Connection refused - server unavailable",
	4: "Connection refused - bad username or password",
	5: 'Connection refused - not authorised'
}

authorisation_request = requests.post(
	'https://auth-nonprod.connecting-expertise.com/realms/emi-mars/protocol/openid-connect/token',
	data = dict(
        grant_type = "password",
	    username = "eventmessageinbox@contingent.com", // (1)
	    password = "_ContingentIsTheWayToGo_", // (2)
	    client_id = "Xvz1evFS4wEEPTGEFPHBog_", // (3)
	    client_secret = "L8qq9PZyRg6ieKGEKhZolGC0vJWLw8iEJ66DRdyFHH_" // (4)
    )
)

open_id_token = authorisation_request.json()['access_token']


# Callback procedure when the client app receives a MQTT CONNACK response from the server

print(f"new token {open_id_token}")

def on_connection(client, userdata, flags, rc):
    print(f"{connection_result_codes[rc]} with code {rc} flags {flags} ")

    # Subscribing in on_connection() means that a connection interrupt and reconnection result in renewed subscriptions
    main_topic = "5b50e671-63dd-11ec-87e9-525400118a56/#" // (5)
    client.subscribe(main_topic)
    print(f"Subscribing to topic {main_topic}")


# Callback procedure when a PUBLISH message is received from the server

def on_message(client, userdata, msg):
    print("Incoming message: " + msg.topic + " " + str(msg.payload))

def on_disconnect(client, userdata, rc):
    if rc != 0:
        print(f"Unexpected disconnection. Result code {rc}")

def on_log(client, userdata, level, buf):
    print("Log: ", buf)

client = mqtt.Client(client_id="MQTTSupplierApplication1", protocol=mqtt.MQTTv31) // (6)

client.tls_set()
client.username_pw_set(
    username = "emi:eventmessageinbox@contingent.com", // (7)
	password = open_id_token
) # access_token response eyJhbGciOiJSUzI1NiIsInR5cC...
client.on_connection = on_connection
client.on_message = on_message
client.on_log=on_log
client.on_disconnect = on_disconnect

client.connect("emi-mars.connecting-expertise.com", {url_OpenApiEMI_Port}, 5)


# Blocking call that processes network traffic, dispatches callbacks and handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a manual interface.
client.loop_start()
time.sleep(5)
client.loop_stop()

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
import com.fasterxml.jackson.databind.ObjectMapper;
import kong.unirest.HttpResponse;
import kong.unirest.Unirest;
import org.eclipse.paho.client.mqttv3.IMqttClient;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.util.Arrays;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class SubscriberMqtt {

    public static void main(String[] args) {

        class MqttMessageCallback implements MqttCallback {

            @Override
            public void connectionLost(Throwable throwable) {
                System.out.println("connection lost");
            }

            @Override
            public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
                System.out.println("message arrived callback");
                System.out.println("reply topic  : " + s);
                System.out.println("reply payload: " + mqttMessage.toString());
            }
        }

        try {

            // Request identity server (Keycloak) token
            // ----------------------------------------
            HttpResponse<String> httpResponse = Unirest.post("https://auth-nonprod.connecting-expertise.com/realms/emi-mars/protocol/openid-connect/token")
                .header("Content-Type", "application/x-www-form-urlencoded")
                .field("grant_type", "password")
                .field("username", "eventmessageinbox@contingent.com") // (1)
                .field("password", "_ContingentIsTheWayToGo_") // (2)
                .field("client_id", "Xvz1evFS4wEEPTGEFPHBog_") // (3)
                .field("client_secret", "L8qq9PZyRg6ieKGEKhZolGC0vJWLw8iEJ66DRdyFHH_") // (4)
                .asString();

            ObjectMapper objectMapper = new ObjectMapper();
            KeyCloak keyCloak = objectMapper.readValue(httpResponse.getBody(), KeyCloak.class);

            // Connect
            // -------
            MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
            mqttConnectOptions.setAutomaticReconnect(true);
            mqttConnectOptions.setCleanSession(false); // (5)
            mqttConnectOptions.setConnectionTimeout(10);
            mqttConnectOptions.setUserName("emi:eventmessageinbox@contingent.com"); // (6)
            mqttConnectOptions.setPassword(keyCloak.getAccess_token().toCharArray()); // password = bearerToken

            String mqttServerUri = "ssl://emi-mars.connecting-expertise.com";
            String mqttClientId = "Supplier_All_Messages"; // your event message subscription/queue name
            IMqttClient mqttClient = new MqttClient(mqttServerUri, mqttClientId);
            mqttClient.connect(mqttConnectOptions);

            // Subscribe to all messages in your event message inbox
            // -----------------------------------------------------
            String mqttTopic = "5b50e671-63dd-11ec-87e9-525400118a56/#"; // (7)

            subscriber.setCallback(new MqttMessageCallback());
            subscriber.subscribe(mqttTopic);

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}