August 17, 2023

cMQConnectionFactory – Docs for ESB 5.x

cMQConnectionFactory

cmqconnectionfactory_icon32_white.png

cMQConnectionFactory properties

Component Family

Context

Function

cMQConnectionFactory encapsulates
a set of connection configuration parameters to connect to a MQ
server. This component replaces the former cJMSConnectionFactory and provides some
enhancements.

Purpose

cMQConnectionFactory is used to
create a connection to a MQ server that can be called by multiple
cJMS, cAMQP or cMQTT
components in a Route.

 

MQ Server

Select an MQ server from ActiveMQ, WebSphere MQ,
AMQP 1.0, MQTT, or Customized.

 

Use Transaction

(for ActiveMQ, WebSphere MQ, and Customized only)

Select this check box to enable local transaction in the current
Route.

 

Broker URI

(for ActiveMQ only)

Type in the URI of the message broker.

For intra-Route message handling, you can simply use the default
URI vm://localhost?broker.persistent=false for ActiveMQ.

 

HTTP Transport

(for ActiveMQ only)

Select this check box to enable the HTTP based
connection to the ActiveMQ broker.
 

Use PooledConnectionFactory

(for ActiveMQ only)

Select this check box to use
PooledConnectionFactory.
 

Max Connections

(for ActiveMQ only)

Specify the maximum number of connections of the
PooledConnectionFactory. This field is available only when the Use PooledConnectionFactory check box is
selected.
 

Max Active

(for ActiveMQ only)

Specify the maximum number of sessions per connection.
This field is available only when the Use
PooledConnectionFactory
check box is selected.
 

Idle Timeout (in ms)

(for ActiveMQ only)

Specify the maximum waiting time (in milliseconds)
before the connection breaks. This field is available only when the
Use PooledConnectionFactory check
box is selected.
 

Expiry Timeout (in ms)

(for ActiveMQ only)

Specify the time (in milliseconds) before the connection
breaks since it is used for the first time. The default value is 60000.
The expiry is disabled if 0 is specified. This field is available only
when the Use PooledConnectionFactory
check box is selected.
 

Host Name

(for WebSphere MQ, AMQP 1.0 and MQTT only)

Type in the name or IP address of the host on which the IBM
WebSphere MQ server or the MQTT broker is running. For WebSphere MQ and AMQP 1.0, the default is localhost. For
MQTT, the default is
127.0.0.1.

 

Port

(for WebSphere MQ, AMQP 1.0 and MQTT only)

Type in the port of the MQ server. For WebSphere MQ, the default is
1414. For AMQP
1.0
, the default is 5672. For
MQTT, the default is
1883.
 

Transport Type

(for WebSphere MQ only)

Select a type of message transport between the IBM
WebSphere MQ server and the WebSphere MQ broker from Bindings, Bindings then
Client
, and Client.
 

Queue Manager

(for WebSphere MQ only)

Type in the name of the queue manager, or specify the
name of the IBM WebSphere MQ server to find a queue manager.
 

Authentication

(for ActiveMQ, WebSphere MQ, and AMQP 1.0 only)

Select this check box and provide the username and
password for the MQ server to validate the access permission. To enter
the password, click the […] button
next to the password field, and then in the pop-up dialog box enter the
password between double quotes and click OK to save the settings.
 

Dependencies

(for WebSphere MQ and Customized only)

Specify additional libraries required by the MQ broker.

 

Use SSL

(for AMQP 1.0 and MQTT only)

Select this check box to connect to the MQ server over the SSL
protocol. For MQTT, specify the
TrustStore file containing the list of certificates that the MQ
server trusts and enter the password used to check the integrity of
the TrustStore data.

 

Connect Attempts

(for MQTT only)

The maximum number of attempts to establish an initial
connection, -1 by default to use unlimited
attempts.

 

Reconnect Attempts

(for MQTT only)

The maximum number of attempts to re-establish a connection after
a failure, -1 by default to use unlimited
attempts.

 

Reconnect Delay

(for MQTT only)

The time in milliseconds between attempts to re-establish an
initial or failed connection, 10 by
default.

 

Quality of Service

(for MQTT only)

The MQTT Quality of Service to use for message exchanges. It can
be one of AtMostOnce, AtLeastOnce or ExactlyOnce.

 

Connect Wait In Seconds

(for MQTT only)

Delay in seconds that the component will wait for a connection to
be established to the MQTT broker, 10 by
default.

 

Disconnect Wait In Seconds

(for MQTT only)

The number of seconds the component will wait for a valid
disconnect from the MQTT broker, 5 by
default.

 

Send Wait In Seconds

(for MQTT only)

The maximum time the component will wait for a receipt from the
MQTT broker to acknowledge a published message before throwing an
exception, 5 by default.

 

Codes

(for Customized only)

Write a piece of code to specify the MQ connection factory to be
used for message handling.

Usage

cMQConnectionFactory cannot be
added directly in a Route.

Limitation

Due to the license incompatibility, one or more JAR files required to use this component are
not provided. You can install these missing JAR files by clicking the Install button in the Basic settings view
of the Component tab. For more information, see the section
about how to configure the Studio of the Talend Installation and Upgrade Guide.

Related scenario:

For a related scenario, see Scenario 1: Sending and receiving a message from a JMS queue.


Document get from Talend https://help.talend.com
Thank you for watching.
Subscribe
Notify of
guest
0 Comments
Inline Feedbacks
View all comments
0
Would love your thoughts, please comment.x
()
x