Monitoring the Object Graph

Context:

import com.exalead.consolidationapi.client.answer.Arc;
import com.exalead.consolidationapi.client.answer.Arcs;
import com.exalead.consolidationapi.client.answer.Document;
import com.exalead.consolidationapi.client.answer.DocumentDetails;
import com.exalead.consolidationapi.client.answer.Documents;
import com.exalead.consolidationapi.client.answer.Vertices;
import com.exalead.consolidationapi.client.answer.Type;
import com.exalead.consolidationapi.client.answer.Types;
import com.exalead.consolidationapi.client.query.GetDocumentQuery;
import com.exalead.consolidationapi.client.query.ListArcsQuery;
import com.exalead.consolidationapi.client.query.ListDocumentsQuery;
import com.exalead.consolidationapi.client.query.ListVerticesQuery;
import com.exalead.consolidationapi.client.query.ListTypesQuery;
import com.exalead.consolidationapi.client.answer.Vertex;
/**
 * Demonstrate the use of the Consolidation Server introspection client
 */
public class IntrospectionClientDemo {
    public static void main(String[] args) {
        final IntrospectionClient iC = new IntrospectionClientImpl("localhost", "10553");
 // product host name, Consolidation Server monitoring port
        try {
   // ------------------
   // Graph introspection
   // ------------------
   // List arcs from uris "project-1" & "project-2", using a max exploration depth of 5
            final Arcs arcs = iC.listArcs(new ListArcsQuery().withUris("project-1", "project-2")
.withMaxExplorationDepth(5));
            for (final Arc arc : arcs) {
                System.out.println("Arc:  " + arc.getSource() + " -> " + arc.getTarget());
            }
   // List arc types starting with prefix "rel", and returns only five types
            Types types = iC.listArcTypes(new ListTypesQuery("rel").withLimit(5));
            for (final Type type : types) {
                System.out.println("Arc type starting by 'rel': " + type.getName());
            }
   // List vertex types starting with prefix "a", and returns an unlimited number of types
            types = iC.listVertexTypes(new ListTypesQuery("a").withLimit(0));
            for (final Type type : types) {
                System.out.println("Vertex type starting by 'a': " + type.getName());
            }
   // List vertices starting with prefix "a", returns only five nodes
            final Vertices nodes = iC.listVertices(new ListVerticesQuery("a").withLimit(5));
            for (Vertex vertex : vertices) {
                System.out.println("Vertex with a uri starting by 'a' : " + vertex.getUri() + "
 [type='" + vertex.getType() + "']");
            }
   // ------------------
   // Storage introspection
   // ------------------
   // List documents with uri starting with prefix "a", and print details for each
            final Documents documents = iC.listDocuments(new ListDocumentsQuery("a"));
            for (final Document document : documents) {
                System.out.println("Stored document with a uri starting by 'a': " + document.getUri());
                System.out.println("Details");
                final DocumentDetails details = iC.getDocument(new GetDocumentQuery(document.getUri()));
                if (details != null) {
                    System.out.println("No. of metas: " + details.getMetas().size());
                    System.out.println("No. of directives: " + details.getDirectives().size());
                    System.out.println("No. of parts: " + details.getParts().size());
                }
            }
        } catch (final IntrospectionClientException e) {
            System.err.println("An error happened during introspection: " + e.getMessage());
        }
    }
}