Skip to content

EventFabric/java-api

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

61 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Event Fabric API Client

Java and Scala implementation of Event Fabric API to send events.

Setup

To build the project use Maven 2

you will need a recent version installed, then do:

//If you are using Eclipse IDE, just call:
mvn eclipse:eclipse

// to compile
mvn compile

// to test
mvn test

// to create a jar
mvn package

//Now you'll want to install the artifact you've generated (the JAR file) in your local repository (~/.m2/repository is the default location)
mvn install

Usage

Watch this video to understand how to connect your Java Application to Event Fabric. In this video we use examples/salesapp to explain step by step how to do it.

http://youtu.be/kuEUG5s5Tow

see examples folder for more examples.

using java:

import com.eventfabric.api.client.EventClient;
import com.eventfabric.model.Event;

YourEntity yourEntity = new YourEntity();

EventClient eventClient = new EventClient(this.efUsername, this.efPassword);
try {
    boolean authenticated = eventClient.authenticate();
    if (authenticated) {
        ObjectMapper mapper = new ObjectMapper();
        ObjectNode value = (ObjectNode) mapper.valueToTree(yourEntity);
        Event event = new Event("my.channel", value);
        Response response = eventClient.send(event);
        if (response.getStatus() == 201) {
            System.out.println("Sale sent to Event Fabric");
        } else {
            System.out.println("Error sending Sale to Event Fabric");
        }
    }
    } catch (IOException e) {
    e.printStackTrace();
}

pom.xml:

<dependency>
    <groupId>com.eventfabric</groupId>
    <artifactId>api</artifactId>
    <version>0.1.0</version>
</dependency>

using scala:

import com.eventfabric.api.client.EventClient
import com.eventfabric.model.Event

// create client
val client = new EventClient("admin", "notadmin")

// authenticate

val success = client.authenticate()
println("successful? " + success)

// create the event value to send

val value = new java.util.LinkedHashMap[String, Object]()
value.put("count", 4:java.lang.Integer)
value.put("price", 12.3:java.lang.Double)
value.put("yes", true:java.lang.Boolean)

// create the event to send
val event = new Event("my.channel", value)

// send the event
val response = client.send(event)

// do something with the response
println(response.getStatus)
println(response.getResult)

if your endpoint is not the default one you have to create a custom event client pointing to your API instance:

import com.eventfabric.api.client.{EventClient, EndPointInfo}
val eventEndpoint = new EndPointInfo("localhost", "/ef/api/event", 8080, false)
val sessionEndpoint = new EndPointInfo("localhost", "/ef/api/session", 8080, false)

// create client
val client = new EventClient("admin", "notadmin", eventEndpoint, sessionEndpoint)

License

MIT

About

Java and Scala implementation of Event Fabric API

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages