activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hugo V <aerost...@hotmail.com>
Subject Unable to reconnect after calling System.exit()
Date Tue, 06 Jun 2006 16:00:36 GMT

Hello,

I am doing a simple test to see the robustness of ActiveMQ. I produce 500
Messages and then I call System.exit().

After the test , I try to reconnect on the queue but the call to
Session.createConsumer hangs. I can connect on the broker and browse other
queue but not the queue where I did the test.  I can reproduce the test. To
be able to reconnect on the queue I need to shutdown/restart activeMQ. 

Some context information : 
ActiveMQ 4.0 M4

Connection Setup :  	
URL tcp://myserver:7670?jms.useAsyncSend=true
Acknowledge mode = Auto
Transacted = false;
Durable = true
No selector

In the Log file in Debug Mode : 

INFO  BrokerService                  - ActiveMQ 4.0 JMS Message Broker
(AMQ-MASTER-fbdev005) is starting
INFO  BrokerService                  - For help or more information please
see: http://incubator.apache.org/activemq/
INFO  ManagementContext              - JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO  JDBCPersistenceAdapter         - Database driver recognized:
[apache_derby_embedded_jdbc_driver]
DEBUG DefaultJDBCAdapter             - Executing SQL: CREATE TABLE
ACTIVEMQ_MSGS(ID INTEGER NOT NULL, CONTAINER VARCHAR(250),
DEBUG DefaultJDBCAdapter             - Could not create JDBC tables; The
message table already existed. Failure was: CREATE Tts i
DEBUG DefaultJDBCAdapter             - Executing SQL: CREATE INDEX
ACTIVEMQ_MSGS_MIDX ON ACTIVEMQ_MSGS (MSGID_PROD,MSGID_SEQ)
DEBUG DefaultJDBCAdapter             - Executing SQL: CREATE INDEX
ACTIVEMQ_MSGS_CIDX ON ACTIVEMQ_MSGS (CONTAINER)
DEBUG DefaultJDBCAdapter             - Executing SQL: CREATE INDEX
ACTIVEMQ_MSGS_EIDX ON ACTIVEMQ_MSGS (EXPIRATION)
DEBUG DefaultJDBCAdapter             - Executing SQL: CREATE TABLE
ACTIVEMQ_ACKS(CONTAINER VARCHAR(250) NOT NULL, CLIENT_ID V
DEBUG DefaultJDBCAdapter             - Could not create JDBC tables; The
message table already existed. Failure was: CREATE TE)) 
DEBUG JDBCPersistenceAdapter         - Cleaning up old messages.
DEBUG DefaultJDBCAdapter             - Executing SQL: DELETE FROM
ACTIVEMQ_MSGS WHERE ( EXPIRATION<>0 AND EXPIRATION<?) OR ID
DEBUG DefaultJDBCAdapter             - Deleted 0 old message(s).
DEBUG JDBCPersistenceAdapter         - Cleanup done.
INFO  JournalPersistenceAdapter      - Journal Recovery Started from: Active
Journal: using 5 x 20.0 Megs at: /app/var/active
DEBUG JournalPersistenceAdapter      - TRACE Entry: RECOVERED
INFO  JournalPersistenceAdapter      - Journal Recovered: 750 message(s) in
transactions recovered.
INFO  TransportServerThreadSupport   - Listening for connections at:
tcp://fbdev005:7670
INFO  TransportConnector             - Connector default Started
INFO  TransportServerThreadSupport   - Listening for connections at:
tcp://fbdev005:7671?wireFormat=stomp
INFO  TransportConnector             - Connector stomp Started
INFO  BrokerService                  - ActiveMQ JMS Message Broker
(AMQ-MASTER-fbdev005, ID:fbdev005-50959-1149608672549-1:0)
DEBUG TcpTransport                   - TCP consumer thread starting
DEBUG WireFormatNegotiator           - Sending: WireFormatInfo { version=1,
properties={TightEncodingEnabled=true, TcpNoDelay
DEBUG WireFormatNegotiator           - Received WireFormat: WireFormatInfo {
version=1, properties={StackTraceEnabled=true, T
DEBUG WireFormatNegotiator           - tcp:///142.225.35.145:2303 before
negotiation: OpenWireFormat{version=1, cacheEnabled=
DEBUG WireFormatNegotiator           - tcp:///142.225.35.145:2303 after
negotiation: OpenWireFormat{version=1, cacheEnabled=t
DEBUG PropertiesLoginModule          - setting based dir=/opt/activemq/conf
DEBUG PropertiesLoginModule          - Initialized debug=true
usersFile=users.properties groupsFile=groups.properties basedir
DEBUG PropertiesLoginModule          - login user=[sawanai]
password=[ab1234]
DEBUG PropertiesLoginModule          - login user=[sawanai]
password=[ab1234]
DEBUG PropertiesLoginModule          - Added principals for user sawanai
DEBUG AbstractRegion                 - Adding destination:
topic://ActiveMQ.Advisory.Connection
DEBUG AbstractRegion                 - Adding destination:
topic://ActiveMQ.Advisory.Topic
DEBUG AbstractRegion                 - Adding destination: queue://FP.DLQ
DEBUG JournalPersistenceAdapter      - Waking for checkpoint to complete.
DEBUG JournalPersistenceAdapter      - Checkpoint started.
DEBUG JournalPersistenceAdapter      - Checkpoint done.
DEBUG AbstractRegion                 - Adding destination:
topic://ActiveMQ.Advisory.Queue
DEBUG AbstractRegion                 - Adding destination:
topic://ActiveMQ.Advisory.Consumer.Queue.FP.DLQ
DEBUG AbstractRegion                 - Adding destination:
topic://ActiveMQ.Advisory.Producer.Queue.FP.DLQ
DEBUG JournalMessageStore            - Journalled message add for:
ID:FB05706-2302-1149608298304-1:0:1:1:1, at: 6272:4145254
DEBUG JournalMessageStore            - Journalled message add for:
ID:FB05706-2302-1149608298304-1:0:1:1:2, at: 6272:4147528

[... 500 messages ]

[The client disconnection... ]

DEBUG Transport                      - Transport failed:
java.net.SocketException: Connection reset
java.net.SocketException: Connection reset
	at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:96)
	at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
 [...]

[Then, my connection hangs ...]

DEBUG WireFormatNegotiator           - Sending: WireFormatInfo { version=1,
properties={TightEncodingEnabled=true, TcpNoDelay
DEBUG TcpTransport                   - TCP consumer thread starting
DEBUG WireFormatNegotiator           - Received WireFormat: WireFormatInfo {
version=1, properties={StackTraceEnabled=true, T
DEBUG WireFormatNegotiator           - tcp:///142.225.35.145:2309 before
negotiation: OpenWireFormat{version=1, cacheEnabled=
DEBUG WireFormatNegotiator           - tcp:///142.225.35.145:2309 after
negotiation: OpenWireFormat{version=1, cacheEnabled=t
DEBUG PropertiesLoginModule          - setting based dir=/opt/activemq/conf
DEBUG PropertiesLoginModule          - Initialized debug=true
usersFile=users.properties groupsFile=groups.properties basedir
DEBUG PropertiesLoginModule          - login user=[sawanai]
password=[ab1234]
DEBUG PropertiesLoginModule          - login user=[sawanai]
password=[ab1234]
DEBUG PropertiesLoginModule          - Added principals for user sawanai
DEBUG InactivityMonitor              - Message sent since last write check,
resetting flag
DEBUG InactivityMonitor              - No message sent since last write
check, sending a KeepAliveInfo
DEBUG InactivityMonitor              - A receive is in progress
DEBUG InactivityMonitor              - No message sent since last write
check, sending a KeepAliveInfo
DEBUG InactivityMonitor              - No message sent since last write
check, sending a KeepAliveInfo
DEBUG InactivityMonitor              - A receive is in progress

--
View this message in context: http://www.nabble.com/Unable-to-reconnect-after-calling-System.exit%28%29-t1742740.html#a4736118
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message