Discussion :

[Cafeinoman]

Bonsoir,

Je bosse actuellement sur une plateforme web utilisant des repository jcr pour ses données. Travaillant avec Wildfly (8.2), j'ai donc installé un sous-système Modeshape(4.1). Tout marche bien, sauf pour la gestion des repository : j'ai besoin de pouvoir déployer de nouveaux repo depuis l'application.
En passant par jboss-cli, aucun soucis pour effectuer la manipulation. Par contre, depuis l'application, impossible.
J'ai tenté de lancer un script avec un ProcessBuilder, aucun résultat, alors que le même script lancé depuis le Shell fonctionne.
J'ai tenté l'api dédié de jboss, impossible d'avoir une connexion.

Si quelqu'un a une alternative, merci d'avance.

[hasalex]

Tu as techniques pour accéder au management de ton wildfly. Par contre, je ne sais pas s'il existe une façon d'y accéder en local, sans connaitre le port de management (9990 par défaut).

Si tu connais le port, il y a jboss-cli, qui n'est pas très pratique depuis une appli, l'API java, l'API HTTP/JSON ou encore JMX.

Personnellement, j'aurais une préférence pour HTTP/JSON car c'est une API qui n'impose pas de dépendance particulière, il faut juste un client HTTP avec un parser JSON.

Pour l'API java, il faut que ton application ait une dépendance vers les modules de management.

J'ai tenté l'api dédié de jboss, impossible d'avoir une connexion.

Comment as-tu fait ton essai et quelle erreur as-tu ?

[Cafeinoman]

Je n'ai pas mon code sous la main, mais j'ai scrupuleusement suivi la doc, en passant la sortie dans le log pour simplement avoir les infos sur undertow.

Je posterai la stack demain, mais l'exception racine est une connection Time out, et undertow fait tout crasher, au point de devoir tuer le processus du serveur. Le standalone est celui du kit modeshape.

Une idée?

[Cafeinoman]

Bon, je suis un boulet, j'utilisais la dépendance AS7, et donc le protocole remote://

Par contre, maintenant que ça marche, impossible de passer la bonne commande. Dans le cli, je vais dans le subsytem modes harpe et je lance ./repository=test:add , et ça m'ajoute le repo. En revanche, si je lui donne cette opération là avec l'adresse du subsytem dans mon code, il me dit qu'elle n'existe pas et renvoie un failed. Si je rajoute le repository=test à l'adresse, il me dit qu'il n'existe pas (logique).

Une idée de comment formater la requête?

[Cafeinoman]

Voilà ou j'en suis :

J'ai mon code json qui stocke la commande dans un fichier du classpath test.json :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
{"operation": "add",
    "address": [
    {
        "subsystem": "modeshape",
        "repository":"test"
    }
]}

Et une classe utilitaire qui parse le json en ModelNode avant d'exécuter la commande.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
 
package org.javacrea.web.jcr.engine;
 
import org.jboss.as.controller.client.ModelControllerClient;
import org.jboss.dmr.ModelNode;
import org.jboss.threads.AsyncFuture;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import javax.json.Json;
import javax.json.JsonObject;
import javax.json.JsonValue;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
 
/**
 * Created by francois on 19/12/14.
 */
public class RepoUtil {
 
    private static Logger log = LoggerFactory.getLogger(RepoUtil.class);
 
 
    private RepoUtil() {
    }
 
    public static void deployRepo(String name) {
 
        ModelControllerClient client = null;
        try {
            InetAddress adress = InetAddress.getByName("localhost");
            log.info("connecting " + adress.getHostName() + " at " + adress.getHostAddress());
            client = ModelControllerClient.Factory.create(
                    adress, 9990);
            log.info("client connected");
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        if (client != null) {
            log.info(client.toString());
        } else {
            log.info("null client");
        }
 
        try (InputStream stream = Thread.currentThread().getContextClassLoader().getResourceAsStream("META-INF/test" +
                ".json")) {
            JsonObject object = Json.createReader(stream).readObject();
 
            ModelNode create = parseJson(object);
 
 
            log.info("ModelNode operation = " + create.resolve().toJSONString(true));
            AsyncFuture<ModelNode> returnVal;
            if (client != null) {
                returnVal = client.executeAsync(create, (severity, message) -> {
                    switch (severity) {
 
                        case INFO:
                            log.info(message);
                            break;
                        case WARN:
                            log.warn(message);
                            break;
                        case ERROR:
                            log.error(message);
                            break;
                    }
                });
                int i = 1;
                while (returnVal.await(10, TimeUnit.SECONDS) == AsyncFuture.Status.WAITING && i < 6) {
                    log.info(returnVal.getStatus().toString() + " since " + (i++ * 10) + "sec");
                }
                if (returnVal.isDone()) {
                    try {
                        log.info(returnVal.get().toJSONString(true));
                    } catch (ExecutionException e) {
                        log.error("Erreur = " + e.getMessage());
                    }
                }
                if (returnVal.getStatus().equals(AsyncFuture.Status.WAITING)) {
                    log.info("Interruption");
                    returnVal.asyncCancel(true);
                } else {
                    log.info(returnVal.getStatus().toString());
                }
 
            }
 
        } catch (IOException | InterruptedException e) {
            e.printStackTrace();
        } finally {
            if (client != null) {
                try {
                    client.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
 
    }
 
    private static ModelNode parseJson(JsonObject object) {
        ModelNode create = new ModelNode();
        for (Map.Entry<String,JsonValue> v : object.entrySet()) {
            switch (object.get(v.getKey()).getValueType()) {
                case ARRAY: {
                    log.info("parsing array");
                    for (int i = 0; i < object.getJsonArray(v.getKey()).size(); i++) {
                            log.info(v.getKey() + " " + v.getValue() + " " + v.getValue().getValueType());
                            log.info("use get");
                            create.get(v.getKey()).set(parseJson(object.getJsonArray(v.getKey()).getJsonObject(i)));
                    }
                    break;
                }
                case OBJECT:
                        create.get(v.getKey()).set(parseJson(object.getJsonObject(v.getKey())));
                        log.info("use get");
                        log.info(v.getKey() + " " + v.getValue() + " " + v.getValue().getValueType());
                    break;
                case STRING:
                        log.info(v.getKey() + " " + v.getValue() + " " + v.getValue().getValueType());
                        log.info("use get");
                        create.get(v.getKey()).set(object.getString(v.getKey()));
                    break;
                case NUMBER:
                        log.info(v.getKey() + " " + v.getValue() + " " + v.getValue().getValueType());
                        log.info("use get");
                        create.get(v.getKey()).set(object.getInt(v.getKey()));
                    break;
                case TRUE:
                        log.info(v.getKey() + " " + v.getValue() + " " + v.getValue().getValueType());
                        log.info("use get");
                        create.get(v.getKey()).set(object.getBoolean(v.getKey()));
                    break;
                case FALSE:
                        log.info(v.getKey() + " " + v.getValue() + " " + v.getValue().getValueType());
                        log.info("use get");
                        create.get(v.getKey()).set(object.getBoolean(v.getKey()));
                    break;
                case NULL:
                    break;
            }
        }
        return create;
    }
 
}

Avec d'autres commandes, par exemple read-attribute sur le repository sample présent par défaut, le retour est bon. En revanche, cette commande reste sur l'état WAITING jusqu'à être interrompue. La même commande lancé par curl dans un Shell retourne le résultat attendu.
Le soucis ne semble donc venir ni de la connexion, ni du parsing. La méthode deployRepo est appelée dans un ejb singleton @Startup, dans son Postconstruct.

Pour moi, ça sent le bug, et si je n'ai pas trouvé d'ici un ou deux jours j'ouvrirai un ticket sur le JIRA de Wildfly. Mais si quelqu'un voit une bêtise, qu'il n'hésite pas.

[hasalex]

Je ne connais pas modeshape, mais l'address a une forme étrange. Ce ne serait pas plutôt ça :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
{"operation": "add",
    "address": [
    {
        "subsystem": "modeshape",
    },
    {
        "repository":"test"
    }
]}

[Cafeinoman]

A priori, les deux syntaxes sont justes, et renvois dans mon cas une tache asynchrone qui refuse de s'exécuter

en utilisant

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

curl --digest 'http://login:mdp@localhost:9990/management' --header "Content-Type: application/json" -d '{"operation" : "add", "address" : [{"subsystem" : "modeshape"}, {"repository" : "test"}]}'

ou

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

curl --digest 'http://login:mdp@localhost:9990/management' --header "Content-Type: application/json" -d '{"operation" : "add", "address" : {"subsystem" : "modeshape", "repository" : "test"}}'

,ce qui correspond aux commandes lancée depuis le code (les [] des arrays sont dégagé...),ca fonctionne...

[Cafeinoman]

En lançant en synchrone, je fini par avoir ça :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
 
11:37:24,062 WARN  [com.arjuna.ats.arjuna] (Transaction Reaper) ARJUNA012117: TransactionReaper::check timeout for TX 0:ffffc0a8050a:-2045a113:54954fc1:a in state  RUN
11:37:24,064 WARN  [com.arjuna.ats.arjuna] (Transaction Reaper Worker 0) ARJUNA012095: Abort of action id 0:ffffc0a8050a:-2045a113:54954fc1:a invoked while multiple threads active within it.
11:37:24,064 WARN  [com.arjuna.ats.arjuna] (Transaction Reaper Worker 0) ARJUNA012108: CheckedAction::check - atomic action 0:ffffc0a8050a:-2045a113:54954fc1:a aborting with 1 threads active!
11:37:24,064 WARN  [com.arjuna.ats.arjuna] (Transaction Reaper Worker 0) ARJUNA012121: TransactionReaper::doCancellations worker Thread[Transaction Reaper Worker 0,5,main] successfully canceled TX 0:ffffc0a8050a:-2045a113:54954fc1:a

[Cafeinoman]

J'ai trouvé! Le soucis vient à priori du fait que j'appelais la méthode dans un EJB, et donc effectuais une opération I/O, ce qui semble-t-il viole la spec. En changeant ça en un "simple" bean CDI, et en l'appelant depuis un page, ça marche!
Merci quand même du coup de main hasalex.