activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From titexe <tit...@yahoo.Fr>
Subject Re: Broker Blocked (WARN : Broker localhost not started so using DCFR instead)
Date Tue, 10 Nov 2009 17:09:33 GMT

I removed the just waitForStart

Otherwise there's the line
<property name="brokerURL" value="vm://localhost?create=false" /> 



Gary Tully wrote:
> 
> I guess you have tried to un comment:
>  <!-- <property name="brokerURL"
> value="vm://DCFR?create=false&amp;waitForStart=10000" /> -->
> 
> 
> 2009/11/10 titexe <titexe@yahoo.fr>:
>>
>> The context :
>>
>> i have a network broker type duplex.
>> and a route camel : move message to othe queue, and track the message in
>> database.
>>
>>
>> Below my configuration :
>>
>>    <broker xmlns="http://activemq.apache.org/schema/core"
>> brokerName="DCFR"
>> dataDirectory="${activemq.base}/data">
>>
>>        <!-- Destination specific policies using destination names or
>> wildcards -->
>>        <destinationPolicy>
>>            <policyMap>
>>                <policyEntries>
>>                    <policyEntry queue=">" memoryLimit="50mb"/>
>>                    <policyEntry topic=">" memoryLimit="50mb">
>>                    </policyEntry>
>>                </policyEntries>
>>            </policyMap>
>>        </destinationPolicy>
>>
>>        <destinations>
>>                <queue physicalName="AX.OUT"/>
>>        </destinations>
>>
>>        <destinationInterceptors>
>>                <virtualDestinationInterceptor>
>>                <virtualDestinations>
>>          </virtualDestinations>
>>              </virtualDestinationInterceptor>
>>        </destinationInterceptors>
>>        <managementContext>
>>            <managementContext createConnector="false"/>
>>        </managementContext>
>>
>>        <networkConnectors>
>>                <networkConnector name="AX" conduitSubscriptions="true"
>> uri="static://(tcp://192.168.107.87:61616)" duplex="true">
>>                </networkConnector>
>>            </networkConnectors>
>>
>>        <persistenceAdapter>
>>            <amqPersistenceAdapter syncOnWrite="false"
>> directory="${activemq.base}/data" maxFileLength="1 gb"/>
>>        </persistenceAdapter>
>>        <sslContext>
>>            <sslContext keyStore="file:${activemq.base}/conf/broker.ks"
>> keyStorePassword="password"
>> trustStore="file:${activemq.base}/conf/broker.ts"
>> trustStorePassword="password"/>
>>        </sslContext>
>>
>>        <!--  The maximum about of space the broker will use before
>> slowing
>> down producers -->
>>        <systemUsage>
>>            <systemUsage>
>>                <memoryUsage>
>>                    <memoryUsage limit="500 mb"/>
>>                </memoryUsage>
>>                <storeUsage>
>>                    <storeUsage limit="5 gb" name="foo"/>
>>                </storeUsage>
>>                <tempUsage>
>>                    <tempUsage limit="500 mb"/>
>>                </tempUsage>
>>            </systemUsage>
>>        </systemUsage>
>>
>>
>>        <!-- The transport connectors ActiveMQ will listen to -->
>>        <transportConnectors>
>>            <transportConnector name="openwire" uri="tcp://DCFR:61616"/>
>>        </transportConnectors>
>>
>>    </broker>
>>
>>
>>    <camelContext id="camel"
>> xmlns="http://activemq.apache.org/camel/schema/spring">
>>
>>    <route errorHandlerRef="myDeadLetterChannel">
>>                <from uri="activemq:queue:AX.OUT"/>
>>                <to uri="activemq:queue:AX.IN"/>
>>                <setBody>
>>                        <simple> Declare @myDate varchar(50);set
>> @myDate='${date:now:yyyyMMddHHmmssSSS}';UPDATE InterfaceMonitor SET
>> CamelSentToAXTS =
>> convert(datetime,(stuff(stuff(stuff(stuff(stuff(stuff(@myDate,5,0,'-'),8,0,'-'),11,0,'
>> '),14,0,':'),17,0,':'),20,0,'.')),121), CamelSentToAX = CURRENT_TIMESTAMP
>> WHERE MessageGUId = '${in.header.MessageId}'</simple>
>>                </setBody>
>>                <to uri="jdbc:testdb"/>
>>        </route>
>>
>>    </camelContext>
>>
>>
>>        <bean id="myDeadLetterChannel"
>> class="org.apache.camel.builder.DeadLetterChannelBuilder">
>>        <property name="defaultDeadLetterEndpointUri"
>> value="activemq:queue:DLQ.CAMEL.HUBAX"/>
>>        <!-- <property name="redeliveryPolicy" ref="myRedeliveryPolicy"/>
>> -->
>>        </bean>
>>
>>        <bean id="testdb"
>> class="net.sourceforge.jtds.jdbcx.JtdsDataSource">
>>           <property name="serverName" value="10.33.202.64"/>
>>           <property name="portNumber" value="1433"/>
>>           <property name="databaseName"
>> value="IP_MOM_GROUP_FIN_AXINTERFACES"/>
>>           <property name="user" value="appuser_talend"/>
>>           <property name="password" value="P@$$w0rd"/>
>>        </bean>
>>
>>
>>    <!-- configure the camel activemq component to use the current broker
>> -->
>>    <bean id="activemq"
>> class="org.apache.activemq.camel.component.ActiveMQComponent" >
>>        <property name="connectionFactory">
>>          <bean class="org.apache.activemq.ActiveMQConnectionFactory">
>>            <!-- <property name="brokerURL"
>> value="vm://DCFR?create=false&amp;waitForStart=10000" /> -->
>>            <property name="brokerURL" value="vm://localhost?create=false"
>> />
>>            <property name="userName" value="${activemq.username}"/>
>>            <property name="password" value="${activemq.password}"/>
>>          </bean>
>>        </property>
>>    </bean>
>>
>>    <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"/>
>>            <webAppContext contextPath="/fileserver"
>> resourceBase="${activemq.base}/webapps/fileserver" logUrlOnStart="true"/>
>>            <webAppContext contextPath="/console"
>> resourceBase="${activemq.base}/webapps/console" logUrlOnStart="true" />
>>        </handlers>
>>    </jetty>
>>
>> </beans>
>>
>>
>>
>> Gary Tully wrote:
>>>
>>> can you post your configuration and some more context?
>>> The brokerName attribute is relevant to the vm: url you use, localhost
>>> is the default value.
>>> Also, try and enable full debug logging to see if you can extract more
>>> information.
>>>
>>> 2009/11/10 titexe <titexe@yahoo.fr>:
>>>>
>>>> Hello,
>>>>
>>>> My broker can not do anything, nor send or receive messages.
>>>>
>>>> When I look at the console, there's only this error:
>>>>
>>>> 2009-11-10 09:35:21,205 [7638536 @ qtp0-34] WARN BrokerRegistry -
>>>> Broker
>>>> localhost not started so using instead
>>>>
>>>>
>>>> Does someone can help me solve this painful problem ?
>>>>
>>>> Thank you in advance,
>>>>
>>>> titexe
>>>>
>>>> --
>>>> View this message in context:
>>>> http://old.nabble.com/Broker-Blocked-%28WARN-%3A-Broker-localhost-not-started-so-using-DCFR-instead%29-tp26284252p26284252.html
>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>
>>>>
>>>
>>>
>>>
>>> --
>>> http://blog.garytully.com
>>>
>>> Open Source Integration
>>> http://fusesource.com
>>>
>>>
>>
>> --
>> View this message in context:
>> http://old.nabble.com/Broker-Blocked-%28WARN-%3A-Broker-localhost-not-started-so-using-DCFR-instead%29-tp26284252p26285284.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
> 
> 
> 
> -- 
> http://blog.garytully.com
> 
> Open Source Integration
> http://fusesource.com
> 
> 

-- 
View this message in context: http://old.nabble.com/Broker-Blocked-%28WARN-%3A-Broker-localhost-not-started-so-using-DCFR-instead%29-tp26284252p26287292.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message