Skip to content
Markus Sabadello edited this page Oct 2, 2013 · 41 revisions

Implementation of XDI messaging functionality [.jar]

Topics

Maven Dependency

<dependency>
	<groupId>xdi2</groupId>
	<artifactId>xdi2-messaging</artifactId>
	<version>0.1-SNAPSHOT</version>
	<scope>compile</scope>
</dependency>

Quick Example

package xdi2.samples;

import xdi2.core.Graph;
import xdi2.core.impl.memory.MemoryGraphFactory;
import xdi2.core.io.XDIReader;
import xdi2.core.io.XDIReaderRegistry;
import xdi2.core.io.XDIWriter;
import xdi2.core.io.XDIWriterRegistry;
import xdi2.core.xri3.impl.XRI3Segment;
import xdi2.messaging.Message;
import xdi2.messaging.MessageCollection;
import xdi2.messaging.MessageEnvelope;
import xdi2.messaging.MessageResult;
import xdi2.messaging.target.impl.graph.GraphMessagingTarget;

public class SimpleMessagingSample {

    public static void main(String[] args) throws Exception {

        XDIReader reader = XDIReaderRegistry.forFormat("XDI DISPLAY", null);
        XDIWriter writer = XDIWriterRegistry.forFormat("XDI/JSON", null);

        // load an XDI graph and create a messaging target

        Graph graph = MemoryGraphFactory.getInstance().openGraph();
        reader.read(graph, SimpleMessagingSample.class.getResourceAsStream("simple.xdi"));
        GraphMessagingTarget graphMessagingTarget = new GraphMessagingTarget();
        graphMessagingTarget.setGraph(graph);

        // create a message

        MessageEnvelope messageEnvelope = new MessageEnvelope();
        MessageCollection messageCollection = messageEnvelope.getMessageCollection(new XRI3Segment("=sender"), true);
        Message message = messageCollection.getMessage(true);
        message.createGetOperation(messageEnvelope.getGraph().getRootContextNode().getXri());

        // execute the message

        MessageResult messageResult = new MessageResult();
        graphMessagingTarget.execute(messageEnvelope, messageResult, null);

        // serialize the result

        writer.write(messageResult.getGraph(), System.out);
    }
}
Clone this wiki locally