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.
...
- 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.Info 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.
Info 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
Anchor | ||||
---|---|---|---|---|
|
...
Install Apache ActiveMQ JMS.
Info 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>
Info 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.
Code Block 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.Info 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.
Info 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.
...
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.
...