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 15:34:24 GMT

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.


Mime
View raw message