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: Unable to reconnect after calling System.exit()
Date Thu, 08 Jun 2006 11:37:51 GMT
BTW 4.0M4 is kinda old; you might wanna upgrade to the 4.0 build.

Also it could be you've hit this bug - which is to do with sometimes
recovery does not work if you kill -9 a broker.

http://issues.apache.org/activemq/browse/AMQ-732


On 6/6/06, Hugo V <aerosteak@hotmail.com> wrote:
>
> 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.
>
>


-- 

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

Mime
View raw message