activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: help required regarding mirror queue
Date Tue, 14 Sep 2010 17:41:42 GMT
the message table is shared across all destinations, one of the
columns contains the destination id.

On 14 September 2010 18:21, pp <preeti.padalia@gmail.com> wrote:
>
> hiii
>
> In our project we are using activemq with mysql as external database. we
> enabled mirror queue in the activemq.xml file.but still it does not save the
> messages or topics in the broker. there are only 3 tables namely
>  activemq_acks,
> activemq_msgs,
> activemq_lock.
>
> is it not working or wherev the messages ,topics are saved. my xml file is
>
> <!--
>    Licensed to the Apache Software Foundation (ASF) under one or more
>    contributor license agreements.  See the NOTICE file distributed with
>    this work for additional information regarding copyright ownership.
>    The ASF licenses this file to You under the Apache License, Version 2.0
>    (the "License"); you may not use this file except in compliance with
>    the License.  You may obtain a copy of the License at
>
>    http://www.apache.org/licenses/LICENSE-2.0
>
>    Unless required by applicable law or agreed to in writing, software
>    distributed under the License is distributed on an "AS IS" BASIS,
>    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
>    See the License for the specific language governing permissions and
>    limitations under the License.
> -->
>
>
>
>
>
> <beans
>  xmlns="http://www.springframework.org/schema/beans"
>  xmlns:amq="http://activemq.apache.org/schema/core"
>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
>
>  xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>  http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd">
>
>    <!-- Allows us to use system properties as variables in this
> configuration file -->
>    <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>        <property name="locations">
>            <value>file:${activemq.base}/conf/credentials.properties</value>
>        </property>
>    </bean>
>
>
> <bean id="mysql-ds"
>       class="org.apache.commons.dbcp.BasicDataSource"
>       destroy-method="close">
>    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
>    <property name="url"
>            value="jdbc:mysql://localhost/activemq?database=activemq
> relaxAutoCommit=true"/>
>    <property name="username" value="root"/>
>    <property name="password" value="opelin"/>
>    <property name="poolPreparedStatements" value="true"/>
>  </bean>
>
>
>
>    <!--
>        The <broker> element is used to configure the ActiveMQ broker.
>    -->
>    <broker xmlns="http://activemq.apache.org/schema/core"
> brokerName="localhost" dataDirectory="${activemq.base}/activemq-data"
>
> destroyApplicationContextOnStop="true" persistent="true"
> enableStatistics="true" useMirroredQueues="true" >
>
>
>        <!--
>                        For better performances use VM cursor and small
> memory limit.
>                        For more information, see:
>
>            http://activemq.apache.org/message-cursors.html
>
>            Also, if your producer is "hanging", it's probably due to
> producer flow control.
>            For more information, see:
>            http://activemq.apache.org/producer-flow-control.html
>        -->
>
>                 <destinationInterceptors>
>          <mirroredQueue copyMessage = "true" postfix=".frm" prefix=""/>
>
>                        <virtualDestinationInterceptor>
>        <virtualDestinations>
>
>         <virtualTopic name=">" prefix="VirtualTopicConsumers.*."
> selectorAware="false"/>
>        </virtualDestinations>
>      </virtualDestinationInterceptor>
>
>
>         </destinationInterceptors>
>
>
>
>
>
>
>
>
>
>        <destinationPolicy>
>            <policyMap>
>              <policyEntries>
>                <policyEntry topic=">" producerFlowControl="true"
> memoryLimit="1mb">
>                  <pendingSubscriberPolicy>
>                    <vmCursor />
>                  </pendingSubscriberPolicy>
>                </policyEntry>
>                <policyEntry queue=">" producerFlowControl="true"
> memoryLimit="1mb">
>                  <!-- Use VM cursor for better latency
>                       For more information, see:
>
>                       http://activemq.apache.org/message-cursors.html
>
>
>
>
>
>
>
>
>                  <pendingQueuePolicy>
>                    <vmQueueCursor/>
>                  </pendingQueuePolicy>
>                  -->
>                </policyEntry>
>              </policyEntries>
>            </policyMap>
>        </destinationPolicy>
>
>
>        <!--
>            The managementContext is used to configure how ActiveMQ is
> exposed in
>            JMX. By default, ActiveMQ uses the MBean server that is started
> by
>            the JVM. For more information, see:
>
>            http://activemq.apache.org/jmx.html
>        -->
>        <managementContext>
>            <managementContext createConnector="false"/>
>        </managementContext>
>
>        <!--
>            Configure message persistence for the broker. The default
> persistence
>            mechanism is the KahaDB store (identified by the kahaDB tag).
>            For more information, see:
>
>            http://activemq.apache.org/persistence.html
>        -->
>
>
>
>
>
>
>
>  <persistenceAdapter>
>
>      <jdbcPersistenceAdapter
>            dataDirectory="${activemq.base}/activemq-data"
>            dataSource="#mysql-ds"/>
>    </persistenceAdapter>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>          <!--
>            The systemUsage controls the maximum amount of space the broker
> will
>            use before slowing down producers. For more information, see:
>
>            http://activemq.apache.org/producer-flow-control.html
>
>        <systemUsage>
>            <systemUsage>
>                <memoryUsage>
>                    <memoryUsage limit="20 mb"/>
>                </memoryUsage>
>                <storeUsage>
>                    <storeUsage limit="1 gb"/>
>                </storeUsage>
>                <tempUsage>
>                    <tempUsage limit="100 mb"/>
>                </tempUsage>
>            </systemUsage>
>        </systemUsage>
>                -->
>
>        <!--
>            The transport connectors expose ActiveMQ over a given protocol
> to
>            clients and other brokers. For more information, see:
>
>            http://activemq.apache.org/configuring-transports.html
>        -->
>        <transportConnectors>
>            <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
>        </transportConnectors>
>
>    </broker>
>
>    <!--
>        Uncomment to enable Camel
>        Take a look at activemq-camel.xml for more details
>
>    <import resource="camel.xml"/>
>    -->
>
>    <!--
>        Enable web consoles, REST and Ajax APIs and demos
>        Take a look at activemq-jetty.xml for more details
>    -->
>    <import resource="jetty.xml"/>
>
> </beans>
>
>
> THANKS IN ADVANCE
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/help-required-regarding-mirror-queue-tp2539330p2539330.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

Mime
View raw message