@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "SampleReport")
public class SampleReport implements Serializable {

  @XmlAttribute(required = true, name = "sensorId")
  @XmlSchemaType(name = "anyURI")
  private String sensorId;

  @XmlAttribute(required = false, name = "sampleType")
  private String sampleType;

  @XmlElement(required = false, name = "dailySampleReport")
  private List<DailySampleReport> dailySampleReports;

<xs:complexType name="SampleReport">
  <xs:attribute name="sensorId" type="xs:anyURI" use="required"/>
  <xs:attribute name="sampleType" type="xs:string"/>
  <xs:sequence>
    <xs:element name="dailySampleReport" type="tns:DailySampleReport"
          maxOccurs="unbounded" minOccurs="0" />
  </xs:sequence>
</xs:complexType>

public class SensormixServiceJpaImpl implements SensormixService, SensormixAdminInterface {

  private EntityManagerFactory entityManagerFactory;

  @Override
  public List<String> listSensorsIds() {
    List<String> result = new ArrayList<String>();

    try {
      EntityManager em = entityManagerFactory.createEntityManager();
      TypedQuery<String> q = em.createQuery("SELECT s.id FROM JpaSensor s", String.class);

      result.addAll(q.getResultList());

      em.close();
    } catch (Exception e) {
      logger.log(Level.SEVERE, "Error during sensors list retrieving", e);
    }

    return result;
  }

<bean id="emf" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
  <property name="persistenceUnitName" value="sensormix_db" />
  <property name="jpaVendorAdapter">
    <bean class="org.springframework.orm.jpa.vendor.EclipseLinkJpaVendorAdapter">
      <property name="showSql" value="true" />
    </bean>
  </property>
  <property name="jpaProperties">
    <props>
      <prop key="eclipselink.ddl-generation">create-tables</prop>
      <prop key="eclipselink.logging.level">INFO</prop>
      <prop key="eclipselink.weaving">false</prop>
      <prop key="javax.persistence.jdbc.driver">${sensormix_db.driverClassName}</prop>
      <prop key="javax.persistence.jdbc.url">${sensormix_db.url}</prop>
      <prop key="javax.persistence.jdbc.user">${sensormix_db.username}</prop>
      <prop key="javax.persistence.jdbc.password">${sensormix_db.password}</prop>
    </props>
  </property>
</bean>

<bean id="sensormixService"
  class="com.google.developers.gdgfirenze.dataservice.SensormixServiceJpaImpl">
  <property name="entityManagerFactory" ref="emf" />
</bean>

<route>
  <from uri="netty:tcp://0.0.0.0:10082/?decoders=#length-decoder&amp;sync=false" />
  <unmarshal>
    <protobuf instanceClass="com.google.developers
      .gdgfirenze.protobuf.SensormixProtos$SampleMessage" />
  </unmarshal>
  <bean ref="sampleAdapter" method="transform" />
  <to uri="seda:serviceEntry" />
</route>

<bean id="sampleAdapter" 
  class="com.google.developers.gdgfirenze.integration.SampleAdapter" />

package com.google.developers.gdgfirenze.integration;

public class SampleAdapter {
  public SamplesPayload transform(SampleMessage message) {
    SamplesPayload ret = new SamplesPayload();
    // process 'SampleMessage' and return the adapted 'SamplesPayload'
    return ret;
  }
}

<instructions>
  <Bundle-SymbolicName>${project.artifactId}</Bundle-SymbolicName>
  <Bundle-Description>${project.description}</Bundle-Description>

  <Web-ContextPath>/${project.artifactId}</Web-ContextPath>

  <Bundle-ClassPath>.,WEB-INF/classes</Bundle-ClassPath>

  <Import-Package>
    com.google.gwt.user.client.rpc.*,
    com.google.gwt.user.client.rpc.core.com.google.gwt.core.shared,
    com.google.gwt.user.client.rpc.core.java.lang,
    com.google.gwt.user.client.rpc.core.java.math,
    com.google.gwt.user.client.rpc.core.java.sql,
    com.google.gwt.user.client.rpc.core.java.util,
    com.google.gwt.user.client.rpc.core.java.util.logging,
    com.google.gwt.user.server.rpc.core.java.lang,
    com.google.gwt.user.server.rpc.core.java.util,
    !com.google.gwt.*.client.*,
    *
  </Import-Package>
</instructions>

Nel file SensormixAdminApp.gwt.xml:

  <inherits name='com.google.developers.gdgfirenze.Sensormix' />

Nel pom.xml:

<dependency>
  <groupId>com.google.developers.gdgfirenze</groupId>
  <artifactId>sensormix-datamodel-api</artifactId>
  <version>${project.version}</version>
</dependency>
<dependency>
  <groupId>com.google.developers.gdgfirenze</groupId>
  <artifactId>sensormix-datamodel-api</artifactId>
  <version>${project.version}</version>
  <classifier>sources</classifier>
</dependency>

Instanziare la service interface usando GWT.create():

GwtSensormixServiceAsync sensormixService 
    = GWT.create(GwtSensormixService.class);

Fare la chiamata al servizio:

sensormixService.listSensorsIds(new AsyncCallback() {
  @Override
  public void onFailure(Throwable caught) {
    // handle the request failure
  }

  @Override
  public void onSuccess(List result) {
    // handle the response from the service
  }
});

SensormixServiceProxy.java è un servizio GWT che usa un servizio OSGi. Nella inizializazione ottiene dei riferimenti al servizio utilizzando le API del Framework.

public void init() throws ServletException {

  final BundleContext context = FrameworkUtil.getBundle(this.getClass()).getBundleContext();
  tracker = new ServiceTracker(context, SensormixService.class.getName(), null);
  tracker.open();
}

Come viene usata l’istanza del servizio OSGi?

private SensormixService getService() {
  return (SensormixService) tracker.waitForService(10000);
}

public List<String> listSensorsIds() {
  return getService().listSensorsIds();
}