Installation
Configuration
The configuration of the ActiveMQ sink connector has the following properties.ActiveMQ sink connector configuration
Name | Type | Required | Sensitive | Default | Description |
---|---|---|---|---|---|
protocol | String | true | false | ”tcp” | The ActiveMQ protocol. |
host | String | true | false | ” ” (empty string) | The ActiveMQ host. |
port | int | true | false | 5672 | The ActiveMQ port. |
username | String | false | true | ” ” (empty string) | The username used to authenticate to ActiveMQ. |
password | String | false | true | ” ” (empty string) | The password used to authenticate to ActiveMQ. |
queueName | String | false | false | ” ” (empty string) | The ActiveMQ queue name that messages should be read from or written to. |
topicName | String | false | false | ” ” (empty string) | The ActiveMQ topic name that messages should be read from or written to. |
activeMessageType | String | false | false | 0 | The ActiveMQ message simple class name. |
Configure ActiveMQ sink connector
Before using the ActiveMQ sink connector, you need to create a configuration file through one of the following methods.-
JSON
-
YAML
Usage
-
Prepare ActiveMQ service.
-
Put the
pulsar-io-activemq-2.5.1.nar
in the pulsar connectors catalog. -
Start Pulsar in standalone mode.
-
Run ActiveMQ sink locally.
-
Send Pulsar messages.
-
Consume ActiveMQ messages.
Use the test method
receiveMessage
of the classorg.apache.pulsar.ecosystem.io.activemq.ActiveMQDemo
to consume ActiveMQ messages.