I have increased the setting from 20M to 200M and it seems work now. Thaks!!
James.Strachan wrote:
>
> 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 <[EMAIL PROTECTED]> 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:
>> [EMAIL PROTECTED]
>> 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/
>
>
--
View this message in context:
http://www.nabble.com/AMQ-4.1-Stucked-tf2968112.html#a8397298
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
