activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lephix <>
Subject using 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. 


  <broker xmlns="" brokerName="localhost141"

       <transportConnector name="openwire" uri="tcp://localhost:61616"

		<networkConnector name="141TO142"
		<networkConnector name="141TO143"

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

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

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


  <camelContext id="camel"

    <!-- You can use a <package> element for each root package to search for
Java routes -->

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

  <!-- lets create a command agent to respond to message based admin
commands on the ActiveMQ.Agent topic -->
  <commandAgent xmlns=""/>

  <jetty xmlns="">
      <nioConnector port="8161" />

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

  <!-- MySql DataSource Sample Setup -->
  <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="url"
    <property name="username" value="root"/>
    <property name="password" value="test"/>
    <property name="poolPreparedStatements" value="true"/>


View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message