Hi Nick,
who is setting the_driver field/ calling setTranslatorService() ?
Note, that the pipelets are created by the SMILA infrastructure objects, such as the BPEL processor and not the OSGi/SCR runtime and hence this method needs to be called somehow which I guess it isn’t, hence NPE.
What you need is for instance an Activator that binds to the serverice by way of SCR or through the use of service trackers.
See for the latter case how it is done for the SearchService in e.g. org.eclipse.smila.solr.Activator.start(BundleContext).
Of course you can do the service tracker in your pipelet itself but since I guess the instance doesn’t change that much I just do it once in the activator.
Thomas Menzel @ brox IT-Solutions GmbH
From: smila-user-bounces@xxxxxxxxxxx [mailto:smila-user-bounces@xxxxxxxxxxx] On Behalf Of Nick
Sent: Mittwoch, 16. November 2011 18:03
To: smila-user@xxxxxxxxxxx
Subject: [smila-user] Call an OSGI bundle service from a pipelet
Hi,
I'm trying to call a dummy service from a pipelet (TranslatorPipelet). Such service is implemented in an OSGi bundle (TranslatorService). The service interface is ITranslatorService.
interface ITranslatorService
package org.eclipse.smila.integration. pipelet.interfaces;
public interface ITranslatorService {
public String getTranslation(String sentence);
}
bundle TranslatorService
package it.polimi.osgi. traslatorservice.internal;
import org.eclipse.smila.integration.pipelet.interfaces.ITranslatorService;
public class TranslatorService implements ITranslatorService {
@Override
public String getTranslation(String sentence) {
return "No translation available";
}
}
MANIFEST.MF (bundle TranslatorService)
Manifest-Version: 1.0
Bundle-ManifestVersion: 2
Bundle-Name: Traslatorservice
Bundle-SymbolicName: it.polimi.osgi.
traslatorservice
Bundle-Version: 1.0.0
Bundle-Activator: it.polimi.osgi.traslatorservice.Activator
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
Import-Package: org.eclipse.smila.integration.pipelet.interfaces,
org.osgi.framework;version="1.3.0"
Export-Package: it.polimi.osgi.traslatorservice
Service-Component: OSGI-INF/TranslatorService.xml
TranslatorService.xml
<?xml version="1.0" encoding="UTF-8"?>
<scr:component xmlns:scr="http://www.osgi.org/xmlns/scr/v1.1.0" immediate="true" name="it.polimi.osgi.traslatorservice">
<implementation class="it.polimi.osgi.traslatorservice.internal.TranslatorService"/>
<service>
<provide interface="org.eclipse.smila.integration.pipelet.interfaces.ITranslatorService"/>
</service>
</scr:component>
Pipelet
package org.eclipse.smila.integration.pipelet;
...
public class TranslatorPipelet implements Pipelet {
....
private ITranslatorService _driver;
/** {@inheritDoc}
* @throws ProcessingException */
@Override
public String[] process(final Blackboard blackboard, final String[] recordIds) throws ProcessingException{
final ParameterAccessor paramAccessor = new ParameterAccessor(blackboard, _config);
final ResultCollector resultCollector = new ResultCollector(paramAccessor, _log, ProcessingConstants.DROP_ON_ERROR_DEFAULT);
for (final String id : recordIds) {
try {
paramAccessor.setCurrentRecord(id);
String inValue = "";
String outValue = "";
// get parameter either from record or configuration via parameter accessor.
final String sourceAttr = paramAccessor.getRequiredParameter(SOURCE_ATT);
final String targetAttr = paramAccessor.getRequiredParameter(TARGET_ATT);
if (blackboard.getMetadata(id).containsKey(sourceAttr)) {
inValue = blackboard.getMetadata(id).getStringValue(sourceAttr);
}
outValue = this.getTranslation(inValue);
....
} catch (final Exception e) {
resultCollector.addFailedResult(id, e);
}
}
return resultCollector.getResultIds();
}
/** {@inheritDoc} */
@Override
public void configure(final AnyMap config) {
_config = config;
}
public String getTranslation(String sentence){
return _driver.getTranslation(sentence);
}
public void setTranslatorService(ITranslatorService driver){
_driver=driver;
}
}
MANIFEST.MF (Pipelet)
Manifest-Version: 1.0
Bundle-ManifestVersion: 2
Bundle-Name: Example bundle for pipelet development
Bundle-SymbolicName: org.eclipse.smila.integration.pipelet
Bundle-Version: 0.9.0
Bundle-Vendor: Eclipse RT SMILA project
Bundle-RequiredExecutionEnvironment: JavaSE-1.6
Import-Package: org.apache.commons.logging;version="1.1.1",
org.eclipse.smila.blackboard;version="0.8.0",
org.eclipse.smila.datamodel;version="0.8.0",
org.eclipse.smila.processing;version="0.8.0",
org.eclipse.smila.processing.parameters;version="0.9.0",
org.eclipse.smila.processing.util;version="0.9.0",
org.eclipse.smila.utils;version="0.9.0",
org.osgi.framework
Export-Package: org.eclipse.smila.integration.pipelet;version="0.9.0",
org.eclipse.smila.integration.pipelet.interfaces
SMILA-Pipelets: org.eclipse.smila.integration.pipelet.TranslatorPipelet
Service-Component: OSGI-INF/TranslatorPipelet.xml
Bundle-Activator: org.eclipse.smila.integration.pipelet.Activator
TranslatorPipelet.xml
<?xml version="1.0" encoding="UTF-8"?>
<scr:component xmlns:scr="http://www.osgi.org/xmlns/scr/v1.1.0" name="org.eclipse.smila.integration.pipelet" immediate="true">
<implementation class="org.eclipse.smila.integration.pipelet.TranslatorPipelet"/>
<reference bind="setTranslatorService" cardinality="1..1" interface="org.eclipse.smila.integration.pipelet.interfaces.ITranslatorService" name="ITranslatorService" policy="static"/>
</scr:component>
SMILA launch
osgi> Persistence bundle starting...
Persistence bundle started.
ProviderTracker: New service detected...
ProviderTracker: Added service org.eclipse.persistence.jpa.osgi.PersistenceProviderOSGi
TranslatorService started!
....
....
....
[INFO ] HTTP server started successfully on port 8080.
When running SMILA from Eclipse what I obtain as soon as the pipelt call the bundle method getTranslation() is this exception:
2011-11-16 08:56:21,035 WARN [ODEServerImpl-1 ] pipelet.TranslatorPipelet - Error while processing record with id 'web:<Url="" href="http://wiki.eclipse.org/SMILA">http://wiki.eclipse.org/SMILA>'.
java.lang.NullPointerException
at org.eclipse.smila.integration.pipelet.TranslatorPipelet.process(TranslatorPipelet.java:64)
at org.eclipse.smila.processing.bpel.PipeletManager.doInvoke(PipeletManager.java:294)
at org.eclipse.smila.processing.bpel.PipeletManager.invokePipelet(PipeletManager.java:252)
at org.eclipse.smila.processing.bpel.PipeletManager.invokeActivity(PipeletManager.java:190)
at org.eclipse.smila.processing.bpel.SMILAExtensionBundle$InvokePipeletActivity.run(SMILAExtensionBundle.java:67)
at org.eclipse.smila.processing.bpel.SMILAExtensionBundle$InvokePipeletActivity.run(SMILAExtensionBundle.java:79)
at org.apache.ode.bpel.rtrep.v2.EXTENSIONACTIVITY.run(EXTENSIONACTIVITY.java:62)
at sun.reflect.GeneratedMethodAccessor66.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:616)
at org.apache.ode.jacob.vpu.JacobVPU$JacobThreadImpl.run(JacobVPU.java:451)
at org.apache.ode.jacob.vpu.JacobVPU.execute(JacobVPU.java:139)
at org.apache.ode.bpel.rtrep.v2.RuntimeInstanceImpl.execute(RuntimeInstanceImpl.java:639)
at org.apache.ode.bpel.engine.BpelRuntimeContextImpl.execute(BpelRuntimeContextImpl.java:593)
at org.apache.ode.bpel.engine.BpelRuntimeContextImpl.executeCreateInstance(BpelRuntimeContextImpl.java:581)
at org.apache.ode.bpel.engine.ODEProcess.executeCreateInstance(ODEProcess.java:373)
at org.apache.ode.bpel.engine.ODEProcess$2.call(ODEProcess.java:295)
at org.apache.ode.bpel.engine.ODEProcess$2.call(ODEProcess.java:294)
at org.apache.ode.bpel.engine.ODEProcess$ProcessCallable.call(ODEProcess.java:1206)
at org.apache.ode.bpel.engine.BpelInstanceWorker.doInstanceWork(BpelInstanceWorker.java:174)
at org.apache.ode.bpel.engine.BpelInstanceWorker.execInCurrentThread(BpelInstanceWorker.java:108)
at org.apache.ode.bpel.engine.ODEProcess.doInstanceWork(ODEProcess.java:487)
at org.apache.ode.bpel.engine.ODEProcess.invokeProcess(ODEProcess.java:293)
at org.apache.ode.bpel.engine.MyRoleMessageExchangeImpl.doInvoke(MyRoleMessageExchangeImpl.java:122)
at org.apache.ode.bpel.engine.UnreliableMyRoleMessageExchangeImpl$1.call(UnreliableMyRoleMessageExchangeImpl.java:44)
at org.apache.ode.bpel.engine.UnreliableMyRoleMessageExchangeImpl$1.call(UnreliableMyRoleMessageExchangeImpl.java:43)
at org.apache.ode.bpel.engine.ODEProcess$ProcessCallable.call(ODEProcess.java:1206)
at org.apache.ode.bpel.engine.Contexts.execTransaction(Contexts.java:106)
at org.apache.ode.bpel.engine.BpelServerImpl$TransactedCallable.call(BpelServerImpl.java:968)
at org.apache.ode.bpel.engine.BpelServerImpl$ServerCallable.call(BpelServerImpl.java:948)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
at java.util.concurrent.FutureTask.run(FutureTask.java:166)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
at java.lang.Thread.run(Thread.java:679)
Any idea?
Thank you,
Nicolò Aquilini
