org.apache.rocketmq.connect.activemq.connector.ActivemqConnector
parameter | effect | required | default |
---|---|---|---|
activemq.url | The URL of the ActiveMQ broker | yes | null |
activemq.username | The username to use when connecting to ActiveMQ | no | null |
activemq.password | The password to use when connecting to ActiveMQ | no | null |
jms.destination.name | The name of the JMS destination (queue or topic) to read from | yes | null |
jms.destination.type | The type of JMS destination, which is either queue or topic | yes | null |
jms.message.selector | The message selector that should be applied to messages in the destination | no | null |
jms.session.acknowledge.mode | The acknowledgement mode for the JMS Session | null | Session.AUTO_ACKNOWLEDGE |
jms.session.transacted | Flag to determine if the session is transacted and the session completely controls. the message delivery by either committing or rolling back the session | null | false |