Supporting Different Transports
Follow the relevant section for the steps that need to be carried out before using the required transport to receive and publish events via WSO2 SP.
Kafka transport
To enable WSO2 SP to receive and publish events via the Kafka transport, follow the steps below:
- Download the Kafka broker from here.
- Convert and copy the Kafka client jars from the
<KAFKA_HOME>/libs
directory to the<SP_HOME>/lib
directory as follows.Create a directory in a preferred location in your machine and copy the following JARs to it from the
<KAFKA_HOME>/libs
directory.This directory will be referred to as the
SOURCE_DIRECTORY
in the next steps.kafka_2.11-0.10.2.1.jar
kafka-clients-0.10.2.1.jar
metrics-core-2.2.0.jar
scala-library-2.11.8.jar
scala-parser-combinators_2.11-1.0.4.jar
zkclient-0.10.jar
zookeeper-3.4.9.jar
Create another directory in a preferred location in your machine.
This directory will be referred to as the
DESTINATION_DIRECTORY
in the next steps.- To convert all the Kafka jars you copied into the
<SOURCE_DIRECTORY>
, issue the following command.- For Windows:
<SP_HOME>/bin/jartobundle.bat <SOURCE_DIRECTORY_PATH> <DESTINATION_DIRECTORY_PATH>
- For Linux:
<SP_HOME>/bin/jartobundle.sh <SOURCE_DIRECTORY_PATH> <DESTINATION_DIRECTORY_PATH>
- For Windows:
Copy the converted files from the
<DESTINATION_DIRECTORY>
to the<SP_HOME>/lib
directory.- Copy the jars that are not converted from the
<SOURCE_DIRECTORY>
to the<SP_HOME>/samples/sample-clients/lib
directory.
- The Kafka server should be started before sending events from WSO2 SP to a Kafka consumer.
a. To start the Kafka server you can refer to this document.
JMS transport
Follow the steps to configure the Apache ActiveMQ message broker:
Install Apache ActiveMQ JMS.
This guide uses ActiveMQ versions 5.7.0 - 5.9.0. If you want to use a later version, for instructions on the necessary changes to the configuration steps, go to Apache ActiveMQ Documentation.
- Download the
activemq-client-5.x.x.jar
from here. Register the
InitialContextFactory
implementation according to the OSGi JNDI spec and copy the client jar to the<SP_HOME>/lib
directory as follows.Navigate to the
SP_HOME>/bin
directory and issue the following command.- For Linux:
./icf-provider.sh org.apache.activemq.jndi.ActiveMQInitialContextFactory <Downloaded Jar Path>/activemq-client-5.x.x.jar <Output Jar Path>
- For Windows:
./icf-provider.bat org.apache.activemq.jndi.ActiveMQInitialContextFactory <Downloaded Jar Path>\activemq-client-5.x.x.jar <Output Jar Path>
If required, you can provide privileges via
chmod +x icf-provider.(sh|bat)
.
Once the client jar is successfully converted, theactivemq-client-5.x.x
directory is created. This directory contains the following:
activemq-client-5.x.x.jar
(original jar)
activemq-client-5.x.x_1.0.0.jar
(OSGi-converted jar)
In addition, the following messages are logged in the terminal.
INFO: Executing 'jar uf <absolute_path>/activemq-client-5.x.x/activemq-client-5.x.x.jar -C <absolute_path>/activemq-client-5.x.x /internal/CustomBundleActivator.class' [timestamp] org.wso2.carbon.tools.spi.ICFProviderTool addBundleActivatorHeader - INFO: Running jar to bundle conversion [timestamp] org.wso2.carbon.tools.converter.utils.BundleGeneratorUtils convertFromJarToBundle - INFO: Created the OSGi bundle activemq_client_5.x.x_1.0.0.jar for JAR file <absolute_path>/activemq-client-5.x.x/activemq-client-5.x.x.jar
- For Linux:
- Copy
activemq-client-5.x.x/activemq-client-5.x.x.jar
and place it in the<SP_HOME>/samples/sample-clients/lib
directory. - Copy
activemq-client-5.x.x/activemq_client_5.x.x_1.0.0.jar
and place it in the<SP_HOME>/lib
directory.
Create a directory in a preferred location in your machine and copy the following JARs to it from the
<ActiveMQ_HOME>/libs
directory.This directory is referred to as the
SOURCE_DIRECTORY
in the next steps.hawtbuf-1.9.jar
geronimo-jms_1.1_spec-1.1.1.jar
geronimo-j2ee-management_1.1_spec-1.0.1.jar
Create another directory in a preferred location in your machine.
This directory will be referred to as the
DESTINATION_DIRECTORY
in the next steps.- To convert all the Kafka jars you copied into the
<SOURCE_DIRECTORY>
, issue the following command.- For Windows:
<SP_HOME>/bin/jartobundle.bat <SOURCE_DIRECTORY_PATH> <DESTINATION_DIRECTORY_PATH>
- For Linux:
<SP_HOME>/bin/jartobundle.sh <SOURCE_DIRECTORY_PATH> <DESTINATION_DIRECTORY_PATH>
- For Windows:
Copy the converted files from the
<DESTINATION_DIRECTORY>
to the<SP_HOME>/lib
directory.- Copy the jars that are not converted from the
<SOURCE_DIRECTORY>
to the<SP_HOME>/samples/sample-clients/lib
directory.
MQTT transport
Follow the steps to configure the MQTT message broker:
- Download the
org.eclipse.paho.client.mqttv3-1.1.1.jar
file from here. Place the file you downloaded in the <SP_HOME>/lib
directory.
RabbitMQ transport
Follow the steps below to configure the RabbitMQ message broker:
- Download RabbitMQ from here.
- Create a directory in a preferred location in your machine. This directory is referred to as at the <SOURCE_DIRECTORY> in the rest of the procedure.
- Copy the following files from the
<RabbitMQ_HOME>/plugins
directory to the<SOURCE_DIRECTORY>
you created. - Create another directory in a preferred location in your machine. This directory is referred to as the
<DESTINATION_DIRECTORY>
in this procedure.