Notice: this Wiki will be going read only early in 2024 and edits will no longer be possible. Please see: https://gitlab.eclipse.org/eclipsefdn/helpdesk/-/wikis/Wiki-shutdown-plan for the plan.
Difference between revisions of "SMILA/Documentation/QueueWorker/BrokerConnectionService"
< SMILA | Documentation | QueueWorker
(New page: == What is Broker Connection Service== The main goal of Broker Connection Service is to provide common cached connection pool to JMS brokers for [[SMILA/Documentation/QueueWorker/Router|R...) |
|||
Line 15: | Line 15: | ||
Configuration is a list of JMS broker connection specific properties like URL, user, password and connection type (factory). | Configuration is a list of JMS broker connection specific properties like URL, user, password and connection type (factory). | ||
+ | Also it should be specified unique Id for each connection configuration. | ||
== Configuration Sample== | == Configuration Sample== |
Revision as of 09:38, 20 August 2008
What is Broker Connection Service
The main goal of Broker Connection Service is to provide common cached connection pool to JMS brokers for Router and Listener.
Interface
public interface BrokerConnectionService { Connection getConnection(QueueConnectionType connectionType, boolean cached) throws BrokerConnectionException; }
Configuration
Schema:org.eclipse.eilf.connectivity.queue.worker/schemas/QueueWorkerConfig.xsd
Configuration is a list of JMS broker connection specific properties like URL, user, password and connection type (factory). Also it should be specified unique Id for each connection configuration.
Configuration Sample
<ConnectionsConfig xmlns="http://www.eclipse.org/eilf/queue" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd" > <ConnectionConfig Id="broker1"> <URL>tcp://localhost:61616</URL> <User>any</User> <Password>any</Password> <ConnectionFactory>org.apache.activemq.ActiveMQConnectionFactory</ConnectionFactory> </ConnectionConfig> <ConnectionConfig Id="broker_alernate"> <URL>tcp://10.0.0.1:61616</URL> <User>me</User> <Password>mypass</Password> <ConnectionFactory>org.apache.activemq.ActiveMQConnectionFactory</ConnectionFactory> </ConnectionConfig> </ConnectionsConfig>