activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Smith <joesmithc...@yahoo.com>
Subject Re: Load testing 5.5 - broker pauses between sends
Date Sat, 30 Jul 2011 03:15:24 GMT
Sorry. Could not see the attachment.  Pasting it below.  Sorry for the long trace.


      
ActiveMQ - 5.5.0
JVM - 1.6
OS - Linux


        <destinationPolicy>
            <policyMap>
              <policyEntries>
                <policyEntry topic=">" producerFlowControl="true" memoryLimit="1mb">
                  <pendingSubscriberPolicy>
                    <vmCursor />
                  </pendingSubscriberPolicy>
                </policyEntry>
                  <!-- Use VM cursor for better latency
                       For more information, see:

                       http://activemq.apache.org/message-cursors.htmlß
                  -->
                <policyEntry queue="test.queue" producerFlowControl="false" memoryLimit="400
mb">
                  <pendingQueuePolicy>
                    <vmQueueCursor/>
                  </pendingQueuePolicy>
                </policyEntry>
              </policyEntries>
            </policyMap>
        </destinationPolicy>


        <persistenceAdapter>
            <kahaDB directory="${activemq.base}/data/kahadb"
                        concurrentStoreAndDispatchQueues="true"
                        concurrentStoreAndDispatchTopics="true"
                        cleanupInterval="60000"
                        checkpointInterval="5000"
                />
        </persistenceAdapter>


2011-07-29 22:07:38,603 | DEBUG | test.queue toPageIn: 200, Inflight: 12000, pagedInMessages.size
25160, enqueueCount: 6797729, dequeueCount: 6772328 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:07:38,603 | DEBUG | test.queue toPageIn: 200, Inflight: 11815, pagedInMessages.size
24974, enqueueCount: 6797729, dequeueCount: 6772513 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:07:38,604 | DEBUG | test.queue toPageIn: 200, Inflight: 11626, pagedInMessages.size
24786, enqueueCount: 6797729, dequeueCount: 6772702 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:07:38,604 | DEBUG | test.queue toPageIn: 200, Inflight: 11577, pagedInMessages.size
24736, enqueueCount: 6797729, dequeueCount: 6772751 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:07:38,608 | DEBUG | Main:memory: usage change from: 40% of available memory,
to: 39% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,612 | DEBUG | Main:memory: usage change from: 39% of available memory,
to: 38% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,613 | DEBUG | test.queue toPageIn: 200, Inflight: 11030, pagedInMessages.size
23758, enqueueCount: 6797729, dequeueCount: 6773729 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:07:38,617 | DEBUG | Main:memory: usage change from: 38% of available memory,
to: 37% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,617 | DEBUG | test.queue toPageIn: 42, Inflight: 10779, pagedInMessages.size
23501, enqueueCount: 6797729, dequeueCount: 6774187 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:07:38,621 | DEBUG | Main:memory:queue://test.queue:memory: usage change from:
6% of available memory, to: 5% of available memory | org.apache.activemq.usage.Usage | ActiveMQ
Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,629 | DEBUG | Main:memory: usage change from: 37% of available memory,
to: 36% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031 
2011-07-29 22:07:38,646 | DEBUG | Checkpoint started. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:38,658 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:38,699 | DEBUG | Main:memory: usage change from: 36% of available memory,
to: 35% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,708 | DEBUG | Main:memory: usage change from: 35% of available memory,
to: 34% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,728 | DEBUG | Main:memory: usage change from: 34% of available memory,
to: 33% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,747 | DEBUG | Main:memory: usage change from: 33% of available memory,
to: 32% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,754 | DEBUG | Main:memory: usage change from: 32% of available memory,
to: 31% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,757 | DEBUG | Main:memory:queue://test.queue:memory: usage change from:
5% of available memory, to: 4% of available memory | org.apache.activemq.usage.Usage | ActiveMQ
Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,760 | DEBUG | Main:memory: usage change from: 31% of available memory,
to: 30% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031 
2011-07-29 22:07:38,800 | DEBUG | Main:memory: usage change from: 30% of available memory,
to: 29% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,833 | DEBUG | Main:memory: usage change from: 29% of available memory,
to: 28% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,839 | DEBUG | Main:memory: usage change from: 28% of available memory,
to: 27% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,845 | DEBUG | Main:memory: usage change from: 27% of available memory,
to: 26% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,852 | DEBUG | Main:memory: usage change from: 26% of available memory,
to: 25% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,857 | DEBUG | Main:memory:queue://test.queue:memory: usage change from:
4% of available memory, to: 3% of available memory | org.apache.activemq.usage.Usage | ActiveMQ
Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,857 | DEBUG | Main:memory: usage change from: 25% of available memory,
to: 24% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031 
2011-07-29 22:07:38,862 | DEBUG | Main:memory: usage change from: 24% of available memory,
to: 23% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,867 | DEBUG | Main:memory: usage change from: 23% of available memory,
to: 22% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,874 | DEBUG | Main:memory: usage change from: 22% of available memory,
to: 21% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,887 | DEBUG | Main:memory: usage change from: 21% of available memory,
to: 20% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:38,892 | DEBUG | Main:memory: usage change from: 20% of available memory,
to: 19% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:07:40,535 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@7aaea288
10000 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:40,723 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@66ae0840
10000 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:40,724 | DEBUG | 29999 ms elapsed since last read check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor ReadCheck
2011-07-29 22:07:43,338 | DEBUG | 29999 ms elapsed since last read check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor ReadCheck
2011-07-29 22:07:43,338 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@6d657803
10001 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:43,680 | DEBUG | Checkpoint started. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:43,684 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:45,650 | DEBUG | queue://calculate.queue expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,650 | DEBUG | calculate.queue toPageIn: 0, Inflight: 0, pagedInMessages.size
0, enqueueCount: 0, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[dev1.host]
Scheduler
2011-07-29 22:07:45,650 | DEBUG | queue://calculate.queue expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,677 | DEBUG | queue://test.queue expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,677 | DEBUG | test.queue toPageIn: 0, Inflight: 11808, pagedInMessages.size
11808, enqueueCount: 6797729, dequeueCount: 6785921 | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,683 | DEBUG | queue://test.queue expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,687 | DEBUG | queue://example.A expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,687 | DEBUG | example.A toPageIn: 0, Inflight: 0, pagedInMessages.size
0, enqueueCount: 0, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[dev1.host]
Scheduler
2011-07-29 22:07:45,687 | DEBUG | queue://example.A expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,704 | DEBUG | queue://test.queue expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,704 | DEBUG | test.queue toPageIn: 0, Inflight: 11808, pagedInMessages.size
11808, enqueueCount: 6797729, dequeueCount: 6785921 | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,709 | DEBUG | queue://test.queue expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,709 | DEBUG | queue://results.queue expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,709 | DEBUG | results.queue toPageIn: 0, Inflight: 0, pagedInMessages.size
0, enqueueCount: 0, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[dev1.host]
Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://results.queue expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://example.A expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,710 | DEBUG | example.A toPageIn: 0, Inflight: 0, pagedInMessages.size
0, enqueueCount: 0, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[dev1.host]
Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://example.A expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://calculate.queue expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,710 | DEBUG | calculate.queue toPageIn: 0, Inflight: 0, pagedInMessages.size
0, enqueueCount: 0, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[dev1.host]
Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://calculate.queue expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://results.queue expiring messages .. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,710 | DEBUG | results.queue toPageIn: 0, Inflight: 0, pagedInMessages.size
0, enqueueCount: 0, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | ActiveMQ Broker[dev1.host]
Scheduler
2011-07-29 22:07:45,710 | DEBUG | queue://results.queue expiring messages done. | org.apache.activemq.broker.region.Queue
| ActiveMQ Broker[dev1.host] Scheduler
2011-07-29 22:07:45,819 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@76eb1327
10000 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:48,705 | DEBUG | Checkpoint started. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:48,710 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:50,534 | DEBUG | 29999 ms elapsed since last read check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor ReadCheck
2011-07-29 22:07:50,534 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@7aaea288
9999 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:50,722 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@66ae0840
9999 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:53,338 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@6d657803
10000 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:53,731 | DEBUG | Checkpoint started. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:53,736 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:55,818 | DEBUG | 29999 ms elapsed since last read check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor ReadCheck
2011-07-29 22:07:55,819 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@76eb1327
10000 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:07:58,756 | DEBUG | Checkpoint started. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:07:58,762 | DEBUG | Checkpoint done. | org.apache.activemq.store.kahadb.MessageDatabase
| ActiveMQ Journal Checkpoint Worker
2011-07-29 22:08:00,534 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@7aaea288
10000 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:08:00,723 | DEBUG | org.apache.activemq.transport.InactivityMonitor$2@66ae0840
10001 ms elapsed since last write check. | org.apache.activemq.transport.InactivityMonitor
| InactivityMonitor WriteCheck
2011-07-29 22:08:03,214 | DEBUG | test.queue toPageIn: 1, Inflight: 11808, pagedInMessages.size
11808, enqueueCount: 6797730, dequeueCount: 6785921 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,216 | DEBUG | Main:memory: usage change from: 19% of available memory,
to: 18% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,217 | DEBUG | Main:memory:queue://test.queue:memory: usage change from:
3% of available memory, to: 2% of available memory | org.apache.activemq.usage.Usage | ActiveMQ
Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,217 | DEBUG | test.queue toPageIn: 1, Inflight: 11591, pagedInMessages.size
11592, enqueueCount: 6797732, dequeueCount: 6786139 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,217 | DEBUG | test.queue toPageIn: 1, Inflight: 11561, pagedInMessages.size
11562, enqueueCount: 6797732, dequeueCount: 6786169 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,218 | DEBUG | test.queue toPageIn: 2, Inflight: 11356, pagedInMessages.size
11356, enqueueCount: 6797734, dequeueCount: 6786376 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,218 | DEBUG | test.queue toPageIn: 6, Inflight: 11356, pagedInMessages.size
11358, enqueueCount: 6797740, dequeueCount: 6786376 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,218 | DEBUG | test.queue toPageIn: 7, Inflight: 11359, pagedInMessages.size
11364, enqueueCount: 6797747, dequeueCount: 6786376 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,218 | DEBUG | test.queue toPageIn: 5, Inflight: 11369, pagedInMessages.size
11371, enqueueCount: 6797752, dequeueCount: 6786376 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,219 | DEBUG | test.queue toPageIn: 2, Inflight: 11376, pagedInMessages.size
11376, enqueueCount: 6797753, dequeueCount: 6786376 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,221 | DEBUG | Main:memory: usage change from: 18% of available memory,
to: 17% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,221 | DEBUG | test.queue toPageIn: 79, Inflight: 11020, pagedInMessages.size
11020, enqueueCount: 6797833, dequeueCount: 6786735 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,229 | DEBUG | Main:memory: usage change from: 17% of available memory,
to: 16% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,238 | DEBUG | Main:memory: usage change from: 16% of available memory,
to: 15% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,244 | DEBUG | Main:memory: usage change from: 15% of available memory,
to: 14% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,245 | DEBUG | Main:memory: usage change from: 14% of available memory,
to: 15% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.39:49454
2011-07-29 22:08:03,246 | DEBUG | test.queue toPageIn: 200, Inflight: 8217, pagedInMessages.size
8235, enqueueCount: 6798907, dequeueCount: 6789598 | org.apache.activemq.broker.region.Queue
| Queue:test.queue
2011-07-29 22:08:03,247 | DEBUG | Main:memory: usage change from: 15% of available memory,
to: 14% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,252 | DEBUG | Main:memory: usage change from: 14% of available memory,
to: 13% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
2011-07-29 22:08:03,259 | DEBUG | Main:memory: usage change from: 13% of available memory,
to: 12% of available memory | org.apache.activemq.usage.Usage | ActiveMQ Transport: tcp:///94.14.59.38:55031
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message