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.
