Introduction
Developing services and component for use in a JBI (Java Business Integration) environment can seem a little complex at first and, since the JBI (JSR-208) specification is very open-ended, it can be difficult to get started sometimes. The purpose of the ServiceMix Spring Client Toolkit (SSCT) is to allow you to get up and running quickly with either with new components or services, or maybe simply by JBI-enabling your existing Java code, so that you can use it in a JBI environment.
...
You should see the Maven start-up, and then be prompted for the name of your new component. As a good starting point, please use 'myFirstComponent'. Maven will then create the required directory structure underneath the /work directory.
| No Format |
|---|
__ __
| \/ |__ _Apache__ ___
| |\/| / _` \ V / -_) ' \ ~ intelligent projects ~
|_| |_\__,_|\_/\___|_||_| v. 1.0.2
Enter the name for your new JBI project:
myFirstComponent
build:start:
jbi:createArchetype:
[mkdir] Created dir: C:\work\myFirstComponent\src\main\java
[mkdir] Created dir: C:\work\myFirstComponent\src\main\test
[mkdir] Created dir: C:\work\myFirstComponent\src\main\merge
[mkdir] Created dir: C:\work\myFirstComponent\src\main\jbi\META-INF
[copy] Copying 1 file to C:\work\myFirstComponent
[copy] Copying 1 file to C:\work\myFirstComponent\src\main\jbi\META-INF
[copy] Copying 1 file to C:\work\myFirstComponent\src\main\merge
BUILD SUCCESSFUL
Total time: 53 seconds
Finished at: Thu Aug 18 16:05:01 EDT 2005
|
...
You should end up with a class looking much like the following:
| Code Block |
|---|
|
package org.servicemix.tutorial;
import javax.jbi.JBIException;
import org.servicemix.client.ServiceContext;
import org.servicemix.client.ServiceLifeCycleImplementation;
/**
* A simple Timer based component
*
* @author <a hrefxhref="mailto:pdodds@unity-systems.com">Philip Dodds </a>
*/
public class TimerComponent implements ServiceLifeCycleImplementation {
/* (non-Javadoc)
* @see org.servicemix.client.ServiceLifeCycleImplementation#init(org.servicemix.client.ServiceContext)
*/
public void init(ServiceContext serviceContext) throws JBIException {
// TODO Auto-generated method stub
}
/* (non-Javadoc)
* @see org.servicemix.client.ServiceLifeCycleImplementation#start()
*/
public void start() throws JBIException {
// TODO Auto-generated method stub
}
/* (non-Javadoc)
* @see org.servicemix.client.ServiceLifeCycleImplementation#stop()
*/
public void stop() throws JBIException {
// TODO Auto-generated method stub
}
}
|
...
| Code Block |
|---|
|
package org.servicemix.tutorial;
import java.util.Timer;
import java.util.TimerTask;
import javax.jbi.JBIException;
import org.servicemix.client.ServiceContext;
import org.servicemix.client.ServiceLifeCycleImplementation;
/**
* A simple Timer-based component
*
* @author <a hrefxhref="mailto:pdodds@unity-systems.com">Philip Dodds </a>
*/
public class TimerComponent extends TimerTask implements
ServiceLifeCycleImplementation {
private Timer timer;
private ServiceContext serviceContext;
/*
* (non-Javadoc)
*
* @see org.servicemix.client.ServiceLifeCycleImplementation#init(org.servicemix.client.ServiceContext)
*/
public void init(ServiceContext serviceContext) throws JBIException {
this.serviceContext = serviceContext;
timer = new Timer();
}
/*
* (non-Javadoc)
*
* @see org.servicemix.client.ServiceLifeCycleImplementation#start()
*/
public void start() throws JBIException {
timer.schedule(this, 5000);
}
/*
* (non-Javadoc)
*
* @see org.servicemix.client.ServiceLifeCycleImplementation#stop()
*/
public void stop() throws JBIException {
timer.cancel();
}
/*
* (non-Javadoc)
*
* @see java.util.TimerTask#run()
*/
public void run() {
}
}
|
...
| Code Block |
|---|
|
/*
* (non-Javadoc)
*
* @see java.util.TimerTask#run()
*/
public void run() {
try {
InOnly inOnly = serviceContext.createInOnly(new QName(
"http://tempuri.org/logger", "log"));
NormalizedMessage message = inOnly.createMessage();
message.setContent(new StreamSource(new StringReader(
"<hello>world</hello>")));
serviceContext.done(inOnly);
} catch (MessagingException e) {
e.printStackTrace();
}
}
|
...
| Code Block |
|---|
|
<services binding-component="false"
xmlns:logger="http://tempuri.org/logger">
<consumes interface-name="logger:log"
service-name="logger:myLogger" />
</services>
|
...
| Code Block |
|---|
|
<beans>
<!-- This is going to be where we declare the beans that we want the
SpringComponent container to build -->
<bean id="myTimer"
class="org.servicemix.tutorial.TimerComponent">
</bean>
</beans>
|
The final step in building the JBI component is actually creating the component, this can be done using the Maven JBI plugin by running the following command from your myFirstComponent directory:
...
| Code Block |
|---|
|
package org.servicemix;
import javax.jbi.messaging.MessageExchange;
import javax.xml.namespace.QName;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.servicemix.client.ServiceContext;
import org.servicemix.client.ServiceInterfaceImplementation;
/**
* A simple Logger based component
*
* @author <a hrefxhref="mailto:pdodds@unity-systems.com">Philip Dodds </a>
*/
public class LoggerComponent implements ServiceInterfaceImplementation {
private static final Log log = LogFactory.getLog(LoggerComponent.class
.getName());
/* (non-Javadoc)
* @see org.servicemix.client.ServiceInterfaceImplementation#getInterfaceName()
*/
public QName getInterfaceName() {
return new QName(
"http://tempuri.org/timer", "notification");
}
/* (non-Javadoc)
* @see org.servicemix.client.ServiceImplementation#setServiceContext(org.servicemix.client.ServiceContext)
*/
public void setServiceContext(ServiceContext arg0) {
}
/* (non-Javadoc)
* @see org.servicemix.client.ServiceImplementation#onMessage(javax.jbi.messaging.MessageExchange)
*/
public void onMessage(MessageExchange exchange) {
log.info("I got my exchange "+exchange);
}
}
|
...
| Code Block |
|---|
|
<!-- This is where we are able to declare the ins and outs of the Service
as it consumes and provides elements, the service-names and EndPoints
will be used to activate the JBI EndPoints, and you can use the
interface-name to determine which one you want to call and which
bean is going to receive the actual JBI exchange -->
<services binding-component="false"
xmlns:timer="http://tempuri.org/timer"
xmlns:logger="http://tempuri.org/logger">
<provides interface-name="timer:notification"
service-name="logger:write" />
</services>
|
...
| Code Block |
|---|
|
<beans>
<!-- This is going to be where we declare the beans that we want the
SpringComponent container to build -->
<bean id="myLogger"
class="org.servicemix.tutorial.LoggerComponent">
</bean>
</beans>
|
This now completes the writing of the receiving component's code. As with the first component, you need to build the receiving component so that it is ready for deployment using the maven jbi:generateInstaller goal onto a JBI server (in our case the wonderful ServiceMix).
...
| No Format |
|---|
ServiceMix ESB: null
Loading ServiceMix from servicemix.xml on the CLASSPATH
Aug 19, 2005 11:13:13 AM org.springframework.beans.factory.xml.XmlBeanDefinitionReader
loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [servicemix.xml]
Aug 19, 2005 11:13:13 AM org.springframework.context.support.AbstractRefreshableApplicationContext
refreshBeanFactory
INFO: Bean factory for application context [org.springframework.context.support.
ClassPathXmlApplicationContext;hashCode=14737862]: org.springframework.beans.factory.support.
DefaultListableBeanFactory defining beans [transactionManager,jmsFactory,jbi]; root of BeanFactory hierarchy
Aug 19, 2005 11:13:14 AM org.springframework.context.support.AbstractApplicationContext
refresh
..........
Aug 19, 2005 11:13:15 AM org.springframework.beans.factory.support.DefaultListableBeanFactory
preInstantiateSingletons
INFO: Pre-instantiating singletons in factory [org.springframework.beans.factory.support.
DefaultListableBeanFactory defining beans [myLogger]; root of BeanFactory hierarchy]
Aug 19, 2005 11:13:15 AM org.springframework.beans.factory.support.AbstractBeanFactory getBean
INFO: Creating shared instance of singleton bean 'myLogger'
Aug 19, 2005 11:13:15 AM org.servicemix.jbi.framework.ComponentContextImpl activateEndpoint
INFO: Component: mySecondComponent activated endpoint: {http://tempuri.org/logger}write : default
Aug 19, 2005 11:13:15 AM org.servicemix.jbi.framework.AutoDeploymentService$1 run
INFO: Directory: install: Finished installation of archive: mySecondComponent-1.0-jbi-installer.zip
Aug 19, 2005 11:13:20 AM org.servicemix.tutorial.LoggerComponent onMessage
INFO: I got my exchange org.servicemix.jbi.messaging.InOnlyImpl@15ad5c6
|
...
