JavaSpace Component
Available as of Camel 2.1
The javaspace: component is a transport for working with any JavaSpace compliant implementation , and this component has been tested with both the Blitz implementation and the GigaSpace implementation .
This component can be used for sending and receiving any object inheriting from the Jini net.jini.core.entry.Entry
class, it's . It is also possible to pass an id (Spring Bean) the bean ID of a template that can be used for reading/taking the entries from the space.
This component can be also used for sending/receiving any serializable object acting as a sort of generic transport. The JavaSpace component contains a special optimization for dealing with the BeanExchange
. It can be used , then, for invoking remotely to invoke a POJO remotely, using a JavaSpace as a transport a JavaSpace.
This latter feature can be used for an easy provide a simple implementation of the master/worker pattern, where a POJO provides the business logic for the worker.
Look at the test cases for examples of various use cases for seeing the various usage option for this component.this component.
Maven users will need to add the following dependency to their pom.xml
for this component:
Code Block | ||||
---|---|---|---|---|
| ||||
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-javaspace</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>
|
URI format
Code Block |
---|
javaspace:jini://host[?options] |
You can append query options to the URI in the following format, ?option=value&option=value&...
Options
Div | |||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| |||||||||||||||||||||
|
Examples
Sending and Receiving Entries
No Formatcode |
---|
//Sending sending route from("direct:input") .to("javaspace:jini://localhost?spaceName=mySpace"); //Receiving receiving Route from("javaspace:jini://localhost?spaceName=mySpace&templateId=template&verb=take&concurrentConsumers=1") .to("mock:foo"); |
In this case the payload can be any object inheriting that inherits from the Jini Entry
type.
Sending and receiving serializable objects
Using the preceding routes as above , it 's is also possible to send and receive any serializable object. The camel JavaSpace component detects that the payload is not a Jini Entry
and then it automatically wraps the payload into with a Camel Jini Entry
. In this way, a JavaSpace can be used as a generic transport mechanism.
Options
Name | Default Value | Description |
---|---|---|
spaceName | null | This is the JavaSpace name |
verb | take | This is the verb for getting JavaSpace entries, it can be: take or read |
transactional | false | if true, sending and receiving of entries is performed under a transaction |
transactionalTimeout | Long.MAX_VALUE | the transaction timeout |
concurrentConsumers | 1 | the number of concurrent consumer getting entries from the JavaSpace |
templateId | null | if present, this option it's a Spring Bean id to be used as a template for reading/taking entries |
Using camel-javaspace
To use this module you need to use the FUSE Mediation Router distribution. Or you could just add the following to your pom.xml, substituting the version number for the latest & greatest release.
Code Block |
---|
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-parent</artifactId>
<version>1.4.0.0-fuse</version>
</dependency>
|
And ensure you are pointing at the maven repo
Code Block |
---|
<repository>
<id>open.iona.m2</id>
<name>IONA Open Source Community Release Repository</name>
<url>http://repo.open.iona.com/maven2</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
<releases>
<enabled>true</enabled>
</releases>
</repository>
|
Building From Source
The source for camel-javaspace is available here: https://projects.open.iona.com/projects/svn/iona/camel/trunk/components/camel-javaspace/
You'll need to register with http://open.iona.com to be able to access subversion.
The full FUSE distro is here: https://projects.open.iona.com/projects/svn/iona/camel/trunk/
Using JavaSpace as a remote invocation transport
The JavaSpace component has been tailored to work in combination with the Camel bean component. It is therefore possible to call a remote POJO using JavaSpace as the transport:
Code Block |
---|
// client side
from("direct:input")
.to("javaspace:jini://localhost?spaceName=mySpace");
// server side
from("javaspace:jini://localhost?concurrentConsumers=10&spaceName=mySpace")
.to("mock:foo");
|
In the code there are two test cases showing how to use a POJO to realize the master/worker pattern. The idea is to use the POJO to provide the business logic and rely on Camel for sending/receiving requests/replies with the proper correlation.
Include Page | |||
---|---|---|---|
| |||
Include Page | |||
|