activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: AMQ 4.1 Stucked
Date Mon, 15 Jan 2007 10:03:15 GMT
Sounds like you are using up your message buffer. Try increasing the
usageManager setting in your activemq.xml to something much larger
(add a few zeros)

On 1/12/07, IceyCake <achan@shopzilla.com> wrote:
>
> Let me explain what I'm trying to do here:
>
> Message Producer --- Durable Topic 1 ---> Message Consumer 1 --- Durable
> Topic 2 ---> Message Consumer 2
>
> I'm using Persistant msg with auto ack and no transaction within the
> session.
>
> What's going on is
>
> 1. Startup Active MQ 4.1
> 2. Start Message Producer and it produces thousands of msgs to the Durable
> Topic 1
> 3. Start Message Consumer 1 and it seems able to receive 2 msgs from the
> Topic 1
> 4. Message Consumer 1 tries to send a message to Topic 2
> 5. Lockup at the send() method
> 6. Message Producer lockup at the send() method as well
> 7. Kill ActiveMQ
> 8. Return to 1
>
> It happens pretty consistently.
>
> BTW, ActiveMQ is running on CentOS 4.2 and the Message Producer/Consumers
> are running on a MacBook Pro.
>
> Any hints/help would be appreciated.  Thanks!!!
>
>
> The debug log for activemq looks like the following:
>
> . (couple thousand lines skipped)
> .
> .
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7458, at: 15:7264261
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7459, at: 15:7264673
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7460, at: 15:7265085
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7461, at: 15:7265497
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7462, at: 15:7265909
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7463, at: 15:7266321
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7464, at: 15:7266733
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7465, at: 15:7267145
> DEBUG WireFormatNegotiator           - Sending: WireFormatInfo { version=2,
> properties={CacheSize=1024, CacheEnabled=true, SizePrefixDisabled=false,
> TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
> TightEncodingEnabled=true, StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> DEBUG WireFormatNegotiator           - Received WireFormat: WireFormatInfo {
> version=2, properties={CacheSize=1024, CacheEnabled=true,
> SizePrefixDisabled=false, TcpNoDelayEnabled=true,
> MaxInactivityDuration=30000, TightEncodingEnabled=true,
> StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> DEBUG WireFormatNegotiator           - tcp:///172.16.20.39:55793 before
> negotiation: OpenWireFormat{version=2, cacheEnabled=false,
> stackTraceEnabled=false, tightEncodingEnabled=false,
> sizePrefixDisabled=false}
> DEBUG WireFormatNegotiator           - tcp:///172.16.20.39:55793 after
> negotiation: OpenWireFormat{version=2, cacheEnabled=true,
> stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
> DEBUG TransportConnection            - Setting up new connection:
> org.apache.activemq.broker.jmx.ManagedTransportConnection@126c06b
> DEBUG AbstractRegion                 - Adding consumer:
> ID:szachan.ad.ewsad.net-55792-1168632555737-1:0:-1:1
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7466, at: 15:7267557
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7467, at: 15:7267969
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalMessageStore            - Journalled message add for:
> ID:szachan.ad.ewsad.net-55707-1168631764856-1:0:1:1:7468, at: 15:7268381
> DEBUG UsageManager                   - Memory usage change.  from: 84, to:
> 83
> DEBUG UsageManager                   - Memory usage change.  from: 83, to:
> 82
> DEBUG UsageManager                   - Memory usage change.  from: 82, to:
> 81
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JDBCPersistenceAdapter         - Cleaning up old messages.
> DEBUG DefaultJDBCAdapter             - Executing SQL: DELETE FROM
> ACTIVEMQ_MSGS WHERE ( EXPIRATION<>0 AND EXPIRATION<?) OR ID <= ( SELECT
> min(ACTIVEMQ_ACKS.LAST_ACKED_ID) FROM ACTIVEMQ_ACKS WHERE
> ACTIVEMQ_ACKS.CONTAINER=ACTIVEMQ_MSGS.CONTAINER)
> DEBUG DefaultJDBCAdapter             - Deleted 0 old message(s).
> DEBUG JDBCPersistenceAdapter         - Cleanup done.
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 81, to:
> 82
> DEBUG UsageManager                   - Memory usage change.  from: 82, to:
> 83
> DEBUG UsageManager                   - Memory usage change.  from: 83, to:
> 84
> DEBUG UsageManager                   - Memory usage change.  from: 84, to:
> 85
> DEBUG UsageManager                   - Memory usage change.  from: 85, to:
> 86
> DEBUG UsageManager                   - Memory usage change.  from: 86, to:
> 87
> DEBUG UsageManager                   - Memory usage change.  from: 87, to:
> 88
> DEBUG UsageManager                   - Memory usage change.  from: 88, to:
> 89
> DEBUG UsageManager                   - Memory usage change.  from: 89, to:
> 90
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 90, to:
> 91
> DEBUG UsageManager                   - Memory usage change.  from: 91, to:
> 92
> DEBUG UsageManager                   - Memory usage change.  from: 92, to:
> 93
> DEBUG UsageManager                   - Memory usage change.  from: 93, to:
> 94
> DEBUG UsageManager                   - Memory usage change.  from: 94, to:
> 95
> DEBUG UsageManager                   - Memory usage change.  from: 95, to:
> 96
> DEBUG UsageManager                   - Memory usage change.  from: 96, to:
> 97
> DEBUG UsageManager                   - Memory usage change.  from: 97, to:
> 98
> DEBUG UsageManager                   - Memory usage change.  from: 98, to:
> 99
> DEBUG UsageManager                   - Memory usage change.  from: 99, to:
> 100
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 100, to:
> 101
> DEBUG UsageManager                   - Memory usage change.  from: 101, to:
> 102
> DEBUG UsageManager                   - Memory usage change.  from: 102, to:
> 103
> DEBUG UsageManager                   - Memory usage change.  from: 103, to:
> 104
> DEBUG UsageManager                   - Memory usage change.  from: 104, to:
> 105
> DEBUG UsageManager                   - Memory usage change.  from: 105, to:
> 106
> DEBUG UsageManager                   - Memory usage change.  from: 106, to:
> 107
> DEBUG UsageManager                   - Memory usage change.  from: 107, to:
> 108
> DEBUG UsageManager                   - Memory usage change.  from: 108, to:
> 109
> DEBUG UsageManager                   - Memory usage change.  from: 109, to:
> 110
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 110, to:
> 111
> DEBUG UsageManager                   - Memory usage change.  from: 111, to:
> 112
> DEBUG UsageManager                   - Memory usage change.  from: 112, to:
> 113
> DEBUG UsageManager                   - Memory usage change.  from: 113, to:
> 114
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 114, to:
> 115
> DEBUG UsageManager                   - Memory usage change.  from: 115, to:
> 116
> DEBUG UsageManager                   - Memory usage change.  from: 116, to:
> 117
> DEBUG UsageManager                   - Memory usage change.  from: 117, to:
> 118
> DEBUG UsageManager                   - Memory usage change.  from: 118, to:
> 119
> DEBUG UsageManager                   - Memory usage change.  from: 119, to:
> 120
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 120, to:
> 121
> DEBUG UsageManager                   - Memory usage change.  from: 121, to:
> 122
> DEBUG UsageManager                   - Memory usage change.  from: 122, to:
> 123
> DEBUG UsageManager                   - Memory usage change.  from: 123, to:
> 124
> DEBUG UsageManager                   - Memory usage change.  from: 124, to:
> 125
> DEBUG UsageManager                   - Memory usage change.  from: 125, to:
> 126
> DEBUG UsageManager                   - Memory usage change.  from: 126, to:
> 127
> DEBUG UsageManager                   - Memory usage change.  from: 127, to:
> 128
> DEBUG UsageManager                   - Memory usage change.  from: 128, to:
> 129
> DEBUG UsageManager                   - Memory usage change.  from: 129, to:
> 130
> DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
> DEBUG UsageManager                   - Memory usage change.  from: 130, to:
> 131
> DEBUG UsageManager                   - Memory usage change.  from: 131, to:
> 132
> DEBUG UsageManager                   - Memory usage change.  from: 132, to:
> 133
> DEBUG UsageManager                   - Memory usage change.  from: 133, to:
> 134
> DEBUG JournalPersistenceAdapter      - Checkpoint started.
> DEBUG JournalPersistenceAdapter      - Marking journal at: 15:7268381
> DEBUG JDBCPersistenceAdapter         - Cleaning up old messages.
> DEBUG DefaultJDBCAdapter             - Executing SQL: DELETE FROM
> ACTIVEMQ_MSGS WHERE ( EXPIRATION<>0 AND EXPIRATION<?) OR ID <= ( SELECT
> min(ACTIVEMQ_ACKS.LAST_ACKED_ID) FROM ACTIVEMQ_ACKS WHERE
> ACTIVEMQ_ACKS.CONTAINER=ACTIVEMQ_MSGS.CONTAINER)
> DEBUG DefaultJDBCAdapter             - Deleted 0 old message(s).
> DEBUG JDBCPersistenceAdapter         - Cleanup done.
> DEBUG JournalPersistenceAdapter      - Checkpoint done.
>
>
> --
> View this message in context: http://www.nabble.com/AMQ-4.1-Stucked-tf2968112.html#a8305575
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message