Java IoT Authors: Pat Romanski, Elizabeth White, Liz McMillan, Yeshim Deniz, Mehdi Daoudi

Related Topics: Java IoT, IBM Cloud, Weblogic, Machine Learning

Java IoT: Article

Systems Integration with Openadaptor

Business system integration with little or no custom programming

Perhaps the best way to demonstrate the ease and simplicity of assembling adaptors is by example. Two adaptors will be constructed, both of which are going to be expressed as Spring framework configuration files (full configuration listings are included as part of the latest Openadaptor distribution).

Before we proceed, setting up an environment to run the examples shown here should be straightforward and not take too long. For the first example all that is required is the Openadaptor distribution (www.openadaptor.org/downloads.html) and a JRE 1.4+ installed on the system. After unzipping the package, the CLASSPATH should be set appropriately to run the examples. The XML configurations presented here, together with detailed instructions on setting the CLASSPATH and running the adaptors, can be found in openadaptor\example\spring\demo\*.xml in the standard Openadaptor distribution. The second example uses a JMS write connector that requires running a (default) JBoss implementation (to provide the JMS service). It also illustrates reading data from a database, for simplicity Hypersonic (a.k.a. HSQLDB) is assumed, and again should be available. Familiarity with JBoss or Hypersonic is not required. See Resources for Openadaptor, JBoss, Hypersonic and JRE download links.

Example One
The first adaptor exposes a servlet interface to receive data, which is then forwarded to an XML convertor that in turn passes it to a console printer (see Figure 4). The adaptor is deliberately contrived and simplistic in order to make it easy to run and experiment with. In the second example it will be replaced with a more realistic scenario. Data may be injected into the adaptor via a test web page. The XML configuration will hold four bean definitions. One of the beans is a servlet (IReadConnector) that will await HTTP requests to deliver input data into the adaptor. When a request comes in, it will be passed to an XML convertor that will turn the tabular data in the form of a Map into an XML document. Last, a write connector will print the resulting XML document on the screen. Listing 1 provides the three bean definitions.

Normally, bean definitions are reasonably terse as Java classes that provide their implementations take sensible defaults. The server bean, when instantiated, will start an HTTP server and listen for requests on port 9999. It will by default convert the data it receives to an ordered map, which will then be passed on to the toXMLConvetor, which will make an attempt to convert it to an XML document. The last component in the pipeline, the file writer, defaults to console (stdout) output if no file name is provided.

The last required definition is that of the adaptor (see Listing 2). The adaptor's messageProcessor property may be used to arrange the components into what is loosely referred to as a processing pipeline.

Before continuing, it's worth noting the optional JMX monitoring feature. Should it be required, it is possible to monitor the state of the adaptor by exposing the components (including the Adaptor) as MBeans that will be accessible via a JMX console. To do so, it suffices to add the following bean definition shown to the configuration.

<bean class="org.openadaptor.core.jmx.MBeanServer">
    <property name="port" value="8082"/>

Figure 4 illustrates the structure of the adaptor; note the data from a sample request and the format it takes when passing between components. The payload type, as might be expected, changes from an ordered map to a String containing an XML document in the toXMLConvertor.

The adaptor's XML configuration is now complete. After starting the adaptor from the command line, opening the test page within a web browser will allow test data to be injected (download test page here). After sending a sample request, the adaptor's console output should be similar to the example1output.html. (The source code for this article can be downloaded from the online version of this article at http://java.sys-con.com.)

Example Two
In this example several more advanced features will be presented, such as an enrichment processor, a fan-out (splitting of the processing pipeline into multiple branches), and exception handling. The job of the adaptor will be to read a comma-delimited file, filter out records of interest, enrich them with relevant data stored in a relational database, and finally publish data to a JMS queue. Records that do not have the expected format will be caught by the exception handler and written to an error log file. Apart from writing to a JMS destination, the output data will also be written to a flat file. Reading of the input file will be throttled - records will be read in with a one second interval in between (see Figure 5).

Please note: if you want to run this example in its full version, you will need to download, install, and run the JBoss application server and Hypersonic database engine (see Resources for download links). Optionally, if you cannot or don't want to install JBoss, remove the jmsPublisher component from the processing pipeline. Likewise, if you take out the dbBasedEnricher component, you won't need the Hypersonic database to be available.

The first bean definition will be of a file reader that sources data from a simple comma-delimited file (input/delim.txt) located in the input folder, relative to the location the adaptor is executed from. This is the file's content (note that the second record is missing the last field):

palinm, Michael Palin, 1
chapmang, Graham Chapman
jonest, Terry Jones, 3
idlee, Eric Idle, 4

More Stories By Kris Lachor

Kris Lachor is a senior software developer at Dresdner Kleinwort.

Comments (2)

Share your thoughts on this story.

Add your comment
You must be signed in to add a comment. Sign-in | Register

In accordance with our Comment Policy, we encourage comments that are on topic, relevant and to-the-point. We will remove comments that include profanity, personal attacks, racial slurs, threats of violence, or other inappropriate material that violates our Terms and Conditions, and will block users who make repeated violations. We ask all readers to expect diversity of opinion and to treat one another with dignity and respect.

IoT & Smart Cities Stories
Codete accelerates their clients growth through technological expertise and experience. Codite team works with organizations to meet the challenges that digitalization presents. Their clients include digital start-ups as well as established enterprises in the IT industry. To stay competitive in a highly innovative IT industry, strong R&D departments and bold spin-off initiatives is a must. Codete Data Science and Software Architects teams help corporate clients to stay up to date with the mod...
There are many examples of disruption in consumer space – Uber disrupting the cab industry, Airbnb disrupting the hospitality industry and so on; but have you wondered who is disrupting support and operations? AISERA helps make businesses and customers successful by offering consumer-like user experience for support and operations. We have built the world’s first AI-driven IT / HR / Cloud / Customer Support and Operations solution.
At CloudEXPO Silicon Valley, June 24-26, 2019, Digital Transformation (DX) is a major focus with expanded DevOpsSUMMIT and FinTechEXPO programs within the DXWorldEXPO agenda. Successful transformation requires a laser focus on being data-driven and on using all the tools available that enable transformation if they plan to survive over the long term. A total of 88% of Fortune 500 companies from a generation ago are now out of business. Only 12% still survive. Similar percentages are found throug...
Druva is the global leader in Cloud Data Protection and Management, delivering the industry's first data management-as-a-service solution that aggregates data from endpoints, servers and cloud applications and leverages the public cloud to offer a single pane of glass to enable data protection, governance and intelligence-dramatically increasing the availability and visibility of business critical information, while reducing the risk, cost and complexity of managing and protecting it. Druva's...
BMC has unmatched experience in IT management, supporting 92 of the Forbes Global 100, and earning recognition as an ITSM Gartner Magic Quadrant Leader for five years running. Our solutions offer speed, agility, and efficiency to tackle business challenges in the areas of service management, automation, operations, and the mainframe.
The Jevons Paradox suggests that when technological advances increase efficiency of a resource, it results in an overall increase in consumption. Writing on the increased use of coal as a result of technological improvements, 19th-century economist William Stanley Jevons found that these improvements led to the development of new ways to utilize coal. In his session at 19th Cloud Expo, Mark Thiele, Chief Strategy Officer for Apcera, compared the Jevons Paradox to modern-day enterprise IT, examin...
With 10 simultaneous tracks, keynotes, general sessions and targeted breakout classes, @CloudEXPO and DXWorldEXPO are two of the most important technology events of the year. Since its launch over eight years ago, @CloudEXPO and DXWorldEXPO have presented a rock star faculty as well as showcased hundreds of sponsors and exhibitors! In this blog post, we provide 7 tips on how, as part of our world-class faculty, you can deliver one of the most popular sessions at our events. But before reading...
DSR is a supplier of project management, consultancy services and IT solutions that increase effectiveness of a company's operations in the production sector. The company combines in-depth knowledge of international companies with expert knowledge utilising IT tools that support manufacturing and distribution processes. DSR ensures optimization and integration of internal processes which is necessary for companies to grow rapidly. The rapid growth is possible thanks, to specialized services an...
At CloudEXPO Silicon Valley, June 24-26, 2019, Digital Transformation (DX) is a major focus with expanded DevOpsSUMMIT and FinTechEXPO programs within the DXWorldEXPO agenda. Successful transformation requires a laser focus on being data-driven and on using all the tools available that enable transformation if they plan to survive over the long term. A total of 88% of Fortune 500 companies from a generation ago are now out of business. Only 12% still survive. Similar percentages are found throug...
Scala Hosting is trusted by 50 000 customers from 120 countries and hosting 700 000+ websites. The company has local presence in the United States and Europe and runs an internal R&D department which focuses on changing the status quo in the web hosting industry. Imagine every website owner running their online business on a fully managed cloud VPS platform at an affordable price that's very close to the price of shared hosting. The efforts of the R&D department in the last 3 years made that pos...