CHOReVOLUTION
evolution-service-bus

Repository

Add repository :

<repository>
  <id>ow2-nexus-releases</id>
  <name>OW2 Release Repository</name>
  <url>http://repository.ow2.org/nexus/content/repositories/releases</url>
</repository>

Add dependecy :

<dependency>
    <groupId>eu.chorevolution.vsb</groupId>
    <artifactId>vsb-manager-api</artifactId>
    <version>2.1.2</version>
</dependency>
VsbManager vsbm = new VsbManager();
vsbm.setServiceEndpoint("HOST-IP_TEMPERATURE_SENSOR", "HOST-PORT_TEMPERATURE_SENSOR");
vsbm.setBusEndpoint("HOST-IP_CLIENT","HOST-PORT_CLIENT");
vsbm.generateWar(PATH_TO_GIDL, ProtocolType.REST, "REST_to_COAP");
<dependency>
	<groupId>eu.chorevolution.vsb</groupId>
	<artifactId>monitor</artifactId>
	<version>2.1.2</version>
</dependency>
// To initialize the Agent object
Agent agent = new Agent("NAME_OF_SERVICE_OR_THING_TO_MONITOR", "HOST_ADDRESS_OF_SERVICE_OR_THING_TO_MONITOR", PORT_NUMBER_OF_SERVICE_OR_THING_TO_MONITOR);
// To fire an event to the listener
String event = "event";
agent.fire(event);

/* This method fires the below information :
event-time+"-"+event+"-NAME_OF_SERVICE_OR_THING_TO_MONITOR";*/
// To initialize the AgentListener object
AgentListener listener = new AgentListener("NAME_OF_SERVICE_OR_THING_TO_MONITOR", "HOST_ADDRESS_OF_SERVICE_OR_THING_TO_MONITOR", "PORT_NUMBER_OF_SERVICE_OR_THING_TO_MONITOR");

// To open connection with the SERVICE_OR_THING_TO_MONITOR
listener.connect();

// To get the monitored informations
while(listener.isConnect()){

    String data = listener.getMessageListened();
    System.out.println(data);
}
// To close connection with the SERVICE_OR_THING_TO_MONITOR
listener.disconnect();