Systemintegration is the part of a software architectur. It helps to connect components or
subsystems together. Certain patterns are used in the industry today. Using and learning
EIP (“Enterprise Integration Pattterns”) with Apache Camel is the goal of this Project.
The Example for this project is all about earthquake data from around the world. The
Application is able to read earthquake data from various rss Feeds and processes it. During
the processing the data will be in form of XML and Java Objects. The data will be enriched,
splitted, sorted, aggregated, normalized, marshalled umarshalled and finally provided again
in form of a restful service.
The specified task is as follows:
- Read Earthquake Data continously from those two RSS Streams
• http://geofon.gfz-potsdam.de/db/eqinfo.php?fmt=rss
• http://earthquake.usgs.gov/eqcenter/catalogs/eqs1day-M2.5.xml - enrich this data with other related information like the weather in this area at this
time. Data can be from here: http://www.programmableweb.com. - sort the earthquakes by the earthparts where they appear
- if the earthquake has a strength of more than “M 5.5” than send an formated warning
email to an email adress. - provide this data via a Restful interface in form of a list of the earthparts with an xlink to detailed information of the earthquakes.
SHOW REPRO
i did this for my friends at the university, its in German … the rest stuff is in english
SCREENCAST GETTING THIS DONE / video tutorial
i am still working on it, but this works so far:
i am going to install appfuse with a new entity “Person”.
The Method findByLastName is accessible through REST WS.
for more operations on cxf restfull services see JAX-RS (JSR-311)
this doc is explaining everythig For example: retrieving Collections needs an extra wrapper class.
there is still an error while listing the services: CXF-1695
<pre>mvn archetype:create -DarchetypeGroupId=org.appfuse.archetypes -DarchetypeArtifactId=appfuse-basic-spring -DremoteRepositories=http://static.appfuse.org/releases -DarchetypeVersion=2.0.2 -DgroupId=org.appfuse.tutorial -DartifactId=tutorial cd tutorial mvn appfuse:full-source edit pom.xml for database login (jdbc) mvn install eclipse:eclipse |
edit the pom.xml file:
update the spring version to 2.5.6 below <!– Framework dependency versions –>
delete the dependency with the artifactId ‘xfire-java5′ and ‘xfire-spring’
insert the cxf dependencies:
<dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-api</artifactId> <version>2.1.3</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxws</artifactId> <version>2.1.3</version> <exclusions> <!-- http://www.jroller.com/melix/entry/apache_cxf_maven_javamail_awful --> <exclusion> <groupId>org.apache.geronimo.specs</groupId> <artifactId>geronimo-javamail_1.4_spec</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-frontend-jaxrs</artifactId> <version>2.1.3</version> </dependency> <dependency> <groupId>javax.xml</groupId> <artifactId>jaxb-api</artifactId> <version>2.1</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-transports-http</artifactId> <version>2.1.3</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-core</artifactId> <version>2.1.3</version> </dependency> <dependency> <groupId>javax.ws.rs</groupId> <artifactId>jsr311-api</artifactId> <version>0.8</version><!--!!!!!!!!!!!!ACTUAL VERSION IS 1.0!!!!!!!!!!!!(missing methods and classes ;( will be fixed in the next cxf version 2.1.4) --> </dependency> <dependency> <groupId>org.apache.cxf</groupId> <artifactId>cxf-rt-databinding-aegis</artifactId> <version>2.1.3</version> </dependency> |
exclude asm and the cglib from the hibernate dependency
<exclusion> <groupId>asm</groupId> <artifactId>asm</artifactId> </exclusion> <exclusion> <groupId>asm</groupId> <artifactId>asm-attrs</artifactId> </exclusion> <exclusion> <groupId>cglib</groupId> <artifactId>cglib</artifactId> </exclusion> |
insert the asm-all and cglib dependencies to the top level <dependencies> above the cxf dependencies:
<dependency> <groupId>asm</groupId> <artifactId>asm-all</artifactId> <version>3.1</version> </dependency> <dependency> <groupId>cglib</groupId> <artifactId>cglib</artifactId> <version>2.2</version> </dependency> |
insert the spring-core and spring-web dependency:
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring.version}</version> </dependency> |
edit the web.xml file and change /WEB-INF/xfire-servlet.xml in the <param-value> of the <!– Context Configuration locations for Spring XML files to /WEB-INF/cxf-servlet.xml
also replace the servlet named xfire with
<servlet> <servlet-name>CXFServlet</servlet-name> <servlet-class>org.apache.cxf.transport.servlet.CXFServlet</servlet-class> <load-on-startup>1</load-on-startup> </servlet> |
and replace the xfire servlet mapping with
<servlet-mapping> <servlet-name>CXFServlet</servlet-name> <url-pattern>/services/*</url-pattern> </servlet-mapping> |
delete WEB-INF/xfire-servlet.xml and create a new file there called cxf-servlet.xml which has this content:
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xmlns:jaxrs="http://cxf.apache.org/jaxrs" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> <import resource="classpath:META-INF/cxf/cxf.xml" /> <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" /> <import resource="classpath:META-INF/cxf/cxf-extension-jaxrs-binding.xml" /> <import resource="classpath:META-INF/cxf/cxf-servlet.xml" /> <!-- #errorManager points to my manager(with the @webservice annotation) defined in my applicationContext.xml --> <jaxws:endpoint id="personServiceSOAP" implementor="#personManager" address="/PersonServiceSOAP" > </jaxws:endpoint> <jaxrs:server id="personService1" address="/PersonService"> <jaxrs:serviceBeans> <ref bean="personManager" /> </jaxrs:serviceBeans> </jaxrs:server> </beans> |
add Person.java Model:
package org.appfuse.tutorial.model; import javax.persistence.Column; import javax.persistence.Entity; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.Id; import javax.persistence.Table; import javax.xml.bind.annotation.XmlRootElement; @Entity @Table(name="person") @XmlRootElement(name = "Person") public class Person extends BaseObject { private Long id; private String firstName; private String lastName; @Id @GeneratedValue(strategy = GenerationType.AUTO) public Long getId() { return id; } public void setId(Long id) { this.id = id; } @Column(name=("first_name"), length=50) public String getFirstName() { return firstName; } public void setFirstName(String firstName) { this.firstName = firstName; } @Column(name=("last_name"), length=50) public String getLastName() { return lastName; } public void setLastName(String lastName) { this.lastName = lastName; } public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; Person person = (Person) o; if (firstName != null ? !firstName.equals(person.firstName) : person.firstName != null) return false; if (lastName != null ? !lastName.equals(person.lastName) : person.lastName != null) return false; return true; } public int hashCode() { int result; result = (firstName != null ? firstName.hashCode() : 0); result = 31 * result + (lastName != null ? lastName.hashCode() : 0); return result; } public String toString() { return "Person{" + "id=" + id + ", firstName='" + firstName + ''' + ", lastName='" + lastName + ''' + '}'; } } |
execute mvn appfuse:gen -Dentity=Person
add the PersonDao:
package org.appfuse.tutorial.dao; import java.util.List; import org.appfuse.tutorial.model.Person; /** * @author mraible * public interface PersonDao extends GenericDao<Person, Long> { public List<Person> findByLastName(String lastName); } |
add personDaoHibernate:
package org.appfuse.tutorial.dao.hibernate; import java.util.List; import org.appfuse.tutorial.dao.PersonDao; import org.appfuse.tutorial.model.Person; public class PersonDaoHibernate extends GenericDaoHibernate<Person, Long> implements PersonDao { public PersonDaoHibernate() { super(Person.class); } public List<Person> findByLastName(String lastName) { return getHibernateTemplate().find("from Person where lastName=?", lastName); } } |
add the PersonManager interface and class:
package org.appfuse.tutorial.service; import java.util.List; import javax.jws.WebService; import org.appfuse.tutorial.model.Person; @WebService public interface PersonManager extends GenericManager<Person, Long> { public Person findByLastName(String lastName); } |
package org.appfuse.tutorial.service.impl; import java.util.List; import javax.jws.WebService; import javax.ws.rs.GET; import javax.ws.rs.Path; import javax.ws.rs.PathParam; import org.appfuse.tutorial.dao.PersonDao; import org.appfuse.tutorial.model.Person; import org.appfuse.tutorial.service.PersonManager; @WebService(serviceName = "PersonService", endpointInterface = "org.appfuse.tutorial.service.PersonManager") @Path("/personservice/") public class PersonManagerImpl extends GenericManagerImpl<Person, Long> implements PersonManager { PersonDao personDao; public PersonManagerImpl(PersonDao personDao) { super(personDao); this.personDao = personDao; } @GET @Path("/person/{lastName}") public List<Person> findByLastName(@PathParam("lastName") String lastName) { return personDao.findByLastName(lastName); } } |
add the Dao to applicationContext-Dao.xml and the Manager to dispatcher-servlet.xml and delete the genericManager which was created automatically:
<bean id="personDao" class="org.appfuse.tutorial.dao.hibernate.PersonDaoHibernate"> <property name="sessionFactory" ref="sessionFactory"/> </bean> <bean id="personManager" class="org.appfuse.tutorial.service.impl.PersonManagerImpl"> <constructor-arg ref="personDao"/> </bean> |
register your webservice at cxf-servlet.xml, i have not figured out how to avaid registering every endpoint:
add jsr311-api-0.8.jar to the eclipse project classpath.
execute:
mvn jetty:run |
to see if it “compiles”
try it by calling: http://127.0.0.1:8080/services/PersonService/personservice/person/somelastNameValueFromTheDatabase
in Return you should get this:
<?xml version="1.0" encoding="UTF-8" standalone="yes"?> <Person> <firstName>sdf</firstName> <id>-3</id> <lastName>somelastNameValueFromTheDatabase</lastName> </Person> |
