[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] Assigned: (AMQCPP-137) Exception in
From:       "Timothy Bish (JIRA)" <jira () apache ! org>
Date:       2007-08-28 19:58:22
Message-ID: 2409404.1188331102310.JavaMail.jira () brutus
[Download RAW message or body]


     [ https://issues.apache.org/activemq/browse/AMQCPP-137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel \
]

Timothy Bish reassigned AMQCPP-137:
-----------------------------------

    Assignee: Timothy Bish  (was: Nathan Mittler)

> Exception in ResponseCorrelator::onCommand() 
> ---------------------------------------------
> 
> Key: AMQCPP-137
> URL: https://issues.apache.org/activemq/browse/AMQCPP-137
> Project: ActiveMQ C++ Client
> Issue Type: Bug
> Components: CMS Impl
> Affects Versions: 2.0.1
> Environment: Win XP
> Reporter: Greg Griffin
> Assignee: Timothy Bish
> Priority: Minor
> 
> EXCEPTION:
> ResponseCorrelator::onCommand() - received unknown response for request: 179414
> Exception: writing msg
> response from futureResponse was invalid
> response from futureResponse was invalid
> FILE: ..\src\main\activemq\transport\ResponseCorrelator.cpp, LINE: 145
> FILE: ..\src\main\activemq\transport\ResponseCorrelator.cpp, LINE: 152
> FILE: ..\src\main\activemq\connector\openwire\OpenWireFormatNegotiator.cpp, LINE: \
>                 105
> FILE: ..\src\main\activemq\connector\openwire\OpenWireConnector.cpp, LINE: 1468
> FILE: ..\src\main\activemq\connector\openwire\OpenWireConnector.cpp, LINE: 928
> FILE: ..\src\main\activemq\core\ActiveMQSession.cpp, LINE: 703
> FILE: ..\src\main\activemq\core\ActiveMQProducer.cpp, LINE: 194
> FILE: ..\src\main\activemq\core\ActiveMQProducer.cpp, LINE: 149
> CODE SNIPPET:
> 	try {
> 		msgBytes = session->createBytesMessage();
> 		msgBytes->writeInt(time);
> 		msgBytes->writeByte(type);
> 		msgBytes->writeDouble(price);
> 		msgBytes->writeLong(size);
> 		key.insert(0,topicBase);
> 		tmpTopic = getTopic( key );
> 		publisher->send(tmpTopic, msgBytes);
> 		delete msgBytes;
> 	} 
> 	catch (CMSException& e) {
> std::cerr << "Exception: writing msg" << endl;
> messenger->onException(e);
> 		exit(-1);
> return;
> }
> Exception happened in code that has been processing hundreds of msgs per second for \
> 5 hours a day, no problem. But occurred during time when had a runaway java process \
> taking all of one CPU and lot's of memory. No msgs in broker (4.1.1) logs

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


[prev in list] [next in list] [prev in thread] [next in thread] 

Configure | About | News | Add a list | Sponsored by KoreLogic