|
|---|
|
Über mich |
|
|---|
|
Leistungen |
|
|---|
|
Service |
|
|
| |
Beispiel eines Service Engine
|
Beispiel eines ServiceEngine zur Veranschaulichung von Nachrichtenempfang:
public class HellloSE extends implements Component, ComponentLifeCycle,
LifeCycleMBean implements Runnable{
public HellloSE(){
super(new QName("http://salemi.de/hello/","receiver")); //register service
}
public void run() {
while (ThreadIsRunning) {
MessageExchange exchange = null;
DeliveryChannel channel = getDeliveryChannel(); //provider ready to accepting new message
exchange = channel.accept(); //provider received exchange
if (exchange.getStatus() == ExchangeStatus.DONE) {
continue; //MessageExchange status is done. Do nothing...
}
}
}...
}
Die Methoden start, stop, and shutdown, getLifeCycle, getServiceDescription, getServiceUnitManager, isExchangeWithConsumerOkay,
isExchangeWithProviderOkay, resolveEndpointReference sind gemäß der API zu implementieren.
|
|
|
|
