Jump to: navigation, search

Difference between revisions of "SMILA/Documentation/QueueWorker/BrokerConnectionService"

(Configuration Sample)
Line 13: Line 13:
 
== Configuration ==
 
== Configuration ==
 
Schema:org.eclipse.smila.connectivity.queue.worker/schemas/QueueWorkerConfig.xsd
 
Schema:org.eclipse.smila.connectivity.queue.worker/schemas/QueueWorkerConfig.xsd
Location: "configuration/org.eclipse.smila.connectivity.queue.worker/ConnectionConfig.xml"
+
Location: "configuration/org.eclipse.smila.connectivity.queue.worker.jms/ConnectionConfig.xml"
  
 
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).

Revision as of 08:09, 7 August 2009

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.smila.connectivity.queue.worker/schemas/QueueWorkerConfig.xsd Location: "configuration/org.eclipse.smila.connectivity.queue.worker.jms/ConnectionConfig.xml"

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/smila/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>