<dependencies>
...
<dependency>
<groupId>org.osgi.enroute.easse</groupId>
<artifactId>org.osgi.enroute.easse.simple.adapter</artifactId>
<version>1.0.0</version>
</dependency>
...
</dependencies>
import org.osgi.service.easse.EasseEvent;
public class EasseMessageReceiver {
public void handleMessage(EasseEvent event) {
String message = event.getProperty("message").toString();
System.out.println("Received message: " + message);
}
}
import org.osgi.enroute.easse.simple.adapter.SimpleAdapter;
public class EasseMessageReceiverActivator extends SimpleAdapter {
@Override
public void activate() {
registerMessageReceiver(new EasseMessageReceiver());
}
@Override
public void deactivate() {
unregisterMessageReceiver();
}
}
properties
osgi.server.address=localhost
osgi.server.scheme=http
osgi.server.port=8080
