<div class="wiki-content maincontent"><h2 id="JDBCMasterSlave-JDBCMasterSlave">JDBC Master Slave</h2>

<p>First supported in ActiveMQ version 4.1</p>

<p>If you are using pure JDBC and not using the high performance journal then you are generally relying on your database as your single point of failure and persistence engine. If you do not have really high performance requirements this approach can make a lot of sense as you have a single persistence engine to backup and manage etc.</p>

<h3 id="JDBCMasterSlave-Startup">Startup</h3>

<p>When using just JDBC as the data source you can use a Master Slave approach, running as many brokers as you wish as this diagram shows. On startup one master grabs an exclusive lock in the broker database - all other brokers are slaves and pause waiting for the exclusive lock.</p>

<p><span class="confluence-embedded-file-wrapper"><img class="confluence-embedded-image" src="jdbc-master-slave.data/Startup.png"></span></p>

<p>Clients should be using the <a shape="rect" href="failover-transport-reference.html">Failover Transport</a> to connect to the available brokers. e.g. using a URL something like the following</p>

<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<pre class="brush: java; gutter: false; theme: Default" style="font-size:12px;">
failover:(tcp://broker1:61616,tcp://broker2:61616,tcp://broker3:61616)
</pre>
</div></div>

<p>Only the master broker starts up its transport connectors and so the clients can only connect to the master.</p>

<h3 id="JDBCMasterSlave-Masterfailure">Master failure</h3>

<p>If the master looses connection to the database or looses the exclusive lock then it immediately shuts down. If a master shuts down or fails, one of the other slaves will grab the lock and so the topology switches to the following diagram</p>

<p><span class="confluence-embedded-file-wrapper"><img class="confluence-embedded-image" src="jdbc-master-slave.data/MasterFailed.png"></span></p>

<p>One of the other other slaves immediately grabs the exclusive lock on the database to them commences becoming the master, starting all of its transport connectors.</p>

<p>Clients loose connection to the stopped master and then the failover transport tries to connect to the available brokers - of which the only one available is the new master.</p>

<h3 id="JDBCMasterSlave-Masterrestart">Master restart</h3>

<p>At any time you can restart other brokers which join the cluster and start as slaves waiting to become a master if the master is shutdown or a failure occurs. So the following topology is created after a restart of an old master...</p>

<p><span class="confluence-embedded-file-wrapper"><img class="confluence-embedded-image" src="jdbc-master-slave.data/MasterRestarted.png"></span></p>

<h3 id="JDBCMasterSlave-ConfiguringJDBCMasterSlave">Configuring JDBC Master Slave</h3>

<p>By default if you use the <strong>&lt;jdbcPersistenceAdapter/&gt;</strong> to avoid the high performance journal you will be using JDBC Master Slave by default. You just need to run more than one broker and point the client side URIs to them to get master/slave. This works because they both try an acquire an exclusive lock on a shared table in the database and only one will succeed.</p>

<p>The following example shows how to configure the ActiveMQ broker in JDBC Master Slave mode</p>

<div class="code panel pdl" style="border-width: 1px;"><div class="codeContent panelContent pdl">
<pre class="brush: java; gutter: false; theme: Default" style="font-size:12px;">
&lt;beans&gt;

  &lt;!-- Allows us to use system properties as variables in this configuration file --&gt;
  &lt;bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/&gt;
  
  &lt;broker xmlns="http://activemq.apache.org/schema/core"&gt;

    &lt;destinationPolicy&gt;
      &lt;policyMap&gt;&lt;policyEntries&gt;
        
          &lt;policyEntry topic="FOO.&gt;"&gt;
            &lt;dispatchPolicy&gt;
              &lt;strictOrderDispatchPolicy /&gt;
            &lt;/dispatchPolicy&gt;
            &lt;subscriptionRecoveryPolicy&gt;
              &lt;lastImageSubscriptionRecoveryPolicy /&gt;
            &lt;/subscriptionRecoveryPolicy&gt;
          &lt;/policyEntry&gt;

      &lt;/policyEntries&gt;&lt;/policyMap&gt;
    &lt;/destinationPolicy&gt;
  
  
    &lt;persistenceAdapter&gt;
        &lt;jdbcPersistenceAdapter dataDirectory="${activemq.base}/activemq-data"/&gt;

        &lt;!-- 
        &lt;jdbcPersistenceAdapter dataDirectory="activemq-data" dataSource="#oracle-ds"/&gt;
        --&gt; 
    &lt;/persistenceAdapter&gt;
  
    &lt;transportConnectors&gt;
       &lt;transportConnector name="default" uri="tcp://localhost:61616"/&gt;
    &lt;/transportConnectors&gt;
    
  &lt;/broker&gt;
  
  &lt;!--  This xbean configuration file supports all the standard spring xml configuration options --&gt;
  
  &lt;!-- Postgres DataSource Sample Setup --&gt;
  &lt;!-- 
  &lt;bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource"&gt;
    &lt;property name="serverName" value="localhost"/&gt;
    &lt;property name="databaseName" value="activemq"/&gt;
    &lt;property name="portNumber" value="0"/&gt;
    &lt;property name="user" value="activemq"/&gt;
    &lt;property name="password" value="activemq"/&gt;
    &lt;property name="dataSourceName" value="postgres"/&gt;
    &lt;property name="initialConnections" value="1"/&gt;
    &lt;property name="maxConnections" value="10"/&gt;
  &lt;/bean&gt;
  --&gt;
  
  &lt;!-- MySql DataSource Sample Setup --&gt;
  &lt;!-- 
  &lt;bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"&gt;
    &lt;property name="driverClassName" value="com.mysql.jdbc.Driver"/&gt;
    &lt;property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/&gt;
    &lt;property name="username" value="activemq"/&gt;
    &lt;property name="password" value="activemq"/&gt;
    &lt;property name="poolPreparedStatements" value="true"/&gt;
  &lt;/bean&gt;
  --&gt;  
   
  &lt;!-- Oracle DataSource Sample Setup --&gt;
  &lt;!--
  &lt;bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"&gt;
    &lt;property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/&gt;
    &lt;property name="url" value="jdbc:oracle:thin:@localhost:1521:AMQDB"/&gt;
    &lt;property name="username" value="scott"/&gt;
    &lt;property name="password" value="tiger"/&gt;
    &lt;property name="poolPreparedStatements" value="true"/&gt;
  &lt;/bean&gt;
  --&gt;
      
  &lt;!-- Embedded Derby DataSource Sample Setup --&gt;
  &lt;!-- 
  &lt;bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource"&gt;
    &lt;property name="databaseName" value="derbydb"/&gt;
    &lt;property name="createDatabase" value="create"/&gt;
  &lt;/bean&gt;
  --&gt;  

&lt;/beans&gt;
</pre>
</div></div>
</div>