activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lephix <lep...@163.com>
Subject using apache-activemq-5.1-20080227.125551-32.zip with some problem.
Date Sat, 01 Mar 2008 07:22:01 GMT

i was using AMQ 5.0 for 3 machine. make a network of brokers.
they work well but got some bugs like high-memory, write socket error,
channel inactive too long and so on..

i change the AMQ to 5.1 SNAPSHOT 20080220, lots of bugs seem to be fixed.
but i got a problem. when i send more then 26 packages in a queue(each one
is 1MB), the consumer could receive just 26 packages and then receive
nothing from that time. Means after that the consumer couldn't receive
anything. if i restart the 3 AMQs , the consumer is not work too. 
so , i have to drop the table of MYSQL and restart AMQs. if more than 26
packages the situation is the same like before.

i use BytesMessage for delivery. and producer just send 1 package, after
that, it will be closed. next package will make a new producer. Consumer
will start receiving after producer sending the packages.


i don't know why is 26... 

Soft Environment is: windows 2003. jdk 1.5. 

<beans
  xmlns="http://www.springframework.org/schema/beans"
  xmlns:amq="http://activemq.org/config/1.0"
  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.org/config/1.0
http://activemq.apache.org/schema/activemq-core.xsd
  http://activemq.apache.org/camel/schema/spring
http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">

  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
  
  <broker xmlns="http://activemq.org/config/1.0" brokerName="localhost141"
dataDirectory="${activemq.base}/data">

    <transportConnectors>
       <transportConnector name="openwire" uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
    </transportConnectors>

    <networkConnectors>
		<networkConnector name="141TO142"
uri="static://(tcp://192.9.105.142:61616)"/>
		<networkConnector name="141TO143"
uri="static://(tcp://192.9.105.143:61616)"/>
    </networkConnectors>

    <!-- Use the following if you wish to configure the journal with JDBC
-->
   
    <persistenceAdapter>

    <persistenceAdapter>
        <jdbcPersistenceAdapter dataSource="#mysql-ds"/>
    </persistenceAdapter>
   

	  <!--<systemUsage>
	            <systemUsage>
		            <memoryUsage>
	    	            	<memoryUsage limit="10 mb" percentUsageMinDelta="20"/>
		            </memoryUsage>
		            <tempUsage>
	    	            	<tempUsage limit="100 mb"/>
		            </tempUsage>
		            <storeUsage>
	    	            	<storeUsage limit="1 gb" />
		            </storeUsage>
	            </systemUsage>
	    </systemUsage>-->

  </broker>

  <camelContext id="camel"
xmlns="http://activemq.apache.org/camel/schema/spring">

    <!-- You can use a <package> element for each root package to search for
Java routes -->
    <package>org.foo.bar</package>

    <!-- You can use Spring XML syntax to define the routes here using the
<route> element -->
    <route>
      <from uri="activemq:example.A"/>
      <to uri="activemq:example.B"/>
    </route>
  </camelContext>



  <!-- lets create a command agent to respond to message based admin
commands on the ActiveMQ.Agent topic -->
  <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>

  <!-- MySql DataSource Sample Setup -->
 
  <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?relaxAutoCommit=true"/>
    <property name="username" value="root"/>
    <property name="password" value="test"/>
    <property name="poolPreparedStatements" value="true"/>
  </bean>

</beans>

-- 
View this message in context: http://www.nabble.com/using-apache-activemq-5.1-20080227.125551-32.zip-with-some-problem.-tp15773068s2354p15773068.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message