activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "arpit shah (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQ-1478) Can't produce messages after consumer goes down.
Date Fri, 26 Oct 2007 14:52:23 GMT
Can't produce messages after consumer goes down.
------------------------------------------------

                 Key: AMQ-1478
                 URL: https://issues.apache.org/activemq/browse/AMQ-1478
             Project: ActiveMQ
          Issue Type: Bug
    Affects Versions: 4.1.1
         Environment: Producer box( Windows - running a broker - Producer configuration: persistent
messages)
Consumer box(Linux - with durable topics for persistence)

            Reporter: arpit shah
         Attachments: activemq.xml


Configuration is attached below.

Behavior:

Set the persistent to be true in the broker configuration and created a durable topic to consume
messages. 

Everything was fine until the consumer went down. During that time producer keeps producing
messages. Restart consumer to catch all the missed messages but didn't catch them. After that
the whole application hangs. can't produce any more messages, hence can't consume them. The
heap usage size keeps increasing on the producer side.

Increased memory size, which didn't work either. The received log is shown below on the broker
side when it comes up and the message that shows up on the produce client window.

Here is the message from the producer window:

response from futureResponse was invalid
        FILE: ..\src\main\activemq\transport\filters\ResponseCorrelator.cpp, LIN
E: 146
        FILE: ..\src\main\activemq\transport\filters\ResponseCorrelator.cpp, LIN
E: 153
        FILE: ..\src\main\activemq\connector\openwire\OpenWireFormatNegotiator.c
pp, LINE: 105
        FILE: ..\src\main\activemq\connector\openwire\OpenWireConnector.cpp, LIN
E: 1454
        FILE: ..\src\main\activemq\connector\openwire\OpenWireConnector.cpp, LIN
E: 924
        FILE: ..\src\main\activemq\core\ActiveMQSession.cpp, LINE: 675
        FILE: ..\src\main\activemq\core\ActiveMQProducer.cpp, LINE: 194
        FILE: ..\src\main\activemq\core\ActiveMQProducer.cpp, LINE: 149
        FILE: ..\src\main\activemq\core\ActiveMQProducer.cpp, LINE: 108


Here is broker log:

2007-10-25 15:56:32,576 [main           ] INFO  BrokerService                  - ActiveMQ
4.1.1 JMS Message Broker (localhost) is starting
2007-10-25 15:56:32,576 [main           ] INFO  BrokerService                  - For help
or more information please see: http://incubator.apache.org/activemq/
2007-10-25 15:56:32,654 [JMX connector  ] INFO  ManagementContext              - JMX consoles
can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
2007-10-25 15:56:33,154 [main           ] INFO  JDBCPersistenceAdapter         - Database
driver recognized: [apache_derby_embedded_jdbc_driver]
2007-10-25 15:56:33,904 [main           ] INFO  DefaultDatabaseLocker          - Attempting
to acquire the exclusive lock to become the Master broker
2007-10-25 15:56:33,904 [main           ] INFO  DefaultDatabaseLocker          - Becoming
the master on dataSource: org.apache.derby.jdbc.EmbeddedDataSource@8a2023
2007-10-25 15:56:34,748 [main           ] INFO  JournalPersistenceAdapter      - Journal Recovery
Started from: Active Journal: using 5 x 20.0 Megs at: C:\ActiveMQ\apache-activemq-4.1.1\apache-activemq-4.1.1\activemq-data\journal
2007-10-25 15:56:34,764 [main           ] INFO  JournalPersistenceAdapter      - Journal Recovered:
0 message(s) in transactions recovered.
2007-10-25 15:56:34,967 [main           ] INFO  TransportServerThreadSupport   - Listening
for connections at: tcp://PCSHAH:61616
2007-10-25 15:56:34,967 [main           ] INFO  TransportConnector             - Connector
openwire Started
2007-10-25 15:56:35,280 [main           ] INFO  TransportServerThreadSupport   - Listening
for connections at: ssl://PCSHAH:61617
2007-10-25 15:56:35,280 [main           ] INFO  TransportConnector             - Connector
ssl Started
2007-10-25 15:56:35,280 [main           ] INFO  TransportServerThreadSupport   - Listening
for connections at: stomp://PCSHAH:61613
2007-10-25 15:56:35,280 [main           ] INFO  TransportConnector             - Connector
stomp Started
2007-10-25 15:56:35,358 [main           ] INFO  NetworkConnector               - Network Connector
default-nc Started
2007-10-25 15:56:35,358 [main           ] INFO  BrokerService                  - ActiveMQ
JMS Message Broker (localhost, ID:PCSHAH-2327-1193342192311-1:0) started
2007-10-25 15:56:51,421 [85.37.184:44137] INFO  KahaStore                      - Kaha Store
deleted data directory activemq-data\localhost\tmp_storage


-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message