From users-return-9317-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Fri Jun 01 12:35:38 2007
Return-Path: <users-return-9317-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 17776 invoked from network); 1 Jun 2007 12:35:37 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 1 Jun 2007 12:35:37 -0000
Received: (qmail 86917 invoked by uid 500); 1 Jun 2007 11:35:42 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 86887 invoked by uid 500); 1 Jun 2007 11:35:42 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 86878 invoked by uid 99); 1 Jun 2007 11:35:42 -0000
Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Jun 2007 04:35:41 -0700
X-ASF-Spam-Status: No, hits=1.4 required=10.0
	tests=SPF_NEUTRAL
X-Spam-Check-By: apache.org
Received-SPF: neutral (herse.apache.org: 70.62.123.51 is neither permitted nor denied by domain of dsteigerwald@mcclatchyinteractive.com)
Received: from [70.62.123.51] (HELO zeppelin) (70.62.123.51)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Jun 2007 04:35:35 -0700
Received: from [127.0.0.1] (localhost [127.0.0.1])
	by zeppelin (Postfix) with ESMTP id 3EFC01C20B;
	Fri,  1 Jun 2007 07:35:16 -0400 (EDT)
Message-ID: <46600474.10508@mcclatchyinteractive.com>
Date: Fri, 01 Jun 2007 07:35:16 -0400
From: Doug Steigerwald <dsteigerwald@mcclatchyinteractive.com>
User-Agent: Thunderbird 2.0.0.0 (X11/20070326)
MIME-Version: 1.0
To:  users@activemq.apache.org
Subject: MySQL datastore
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit
X-Virus-Checked: Checked by ClamAV on apache.org

I'm currently trying to set up ActiveMQ to use MySQL as the data store.  ActiveMQ connects to the 
database and creates some tables if it needs to, but nothing is stored in the ACTIVEMQ_MSGS table 
when I send messages via stomp (we're going to be using perl and an extended Net::Stomp to connect 
and post messages).  We're only using queues at the moment.

Am I missing something?  We've been impressed with the performance we've seen when testing ActiveMQ 
using Kaha, but we really want a MySQL data store.

I'm using the ActiveMQ 4.2 snapshot from 5/30 and MySQL 4.1.2.  Here's my config.

<?xml version="1.0" encoding="UTF-8"?>
<beans>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
   <broker xmlns="http://activemq.org/config/1.0" useJmx="true" brokerName="broker" 
useShutdownHook="true" persistent="true" deleteAllMessagesOnStartup="false">
     <managementContext>
       <managementContext createConnector="true"/>
     </managementContext>

     <persistenceAdapter>
       <jdbcPersistenceAdapter dataSource="#dataSource" statements="#statements"/>
     </persistenceAdapter>

     <networkConnectors>
       <networkConnector name="default-nc" uri="multicast://default"/>
     </networkConnectors>

     <transportConnectors>
       <transportConnector uri="stomp://localhost:61613" />
     </transportConnectors>

   </broker>

   <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
     <property name="url" value="jdbc:mysql://db_host/db_db?relaxAutoCommit=true"/>
     <property name="username" value="db_user"/>
     <property name="password" value="db_password"/>
     <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
     <property name="poolPreparedStatements" value="true"/>
   </bean>

   <bean id="statements" class="org.apache.activemq.store.jdbc.Statements">
   </bean>

   <commandAgent xmlns="http://activemq.org/config/1.0"/>
   <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
     <connectors>
       <nioConnector port="8161" />
     </connectors>

     <handlers>
       <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" 
logUrlOnStart="true" />
       <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" 
logUrlOnStart="true" />
     </handlers>
   </jetty>
</beans>


Thanks.
-- 
Doug Steigerwald

-- 
Doug Steigerwald
Software Developer
McClatchy Interactive
dsteigerwald@mcclatchyinteractive.com
919.861.1287