You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by manua <ag...@gmail.com> on 2010/07/01 15:47:48 UTC
Caught unknown exception in activeMQConsumer.cpp
Hi All,
I am getting the following error, when processing the received message,
caught unknown exception
FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 987
FILE: activemq/core/ActiveMQSessionExecutor.cpp, LINE: 133
My application is divided into three parts,
1. On receiving the message, its extracting the test message and passing
that to json_spirit function.
2. The json spirit function converts the text message to a json and extract
the various vector/map parameters. It then pass the extracted parameter to
the Db Function.
3. The Db function takes the string as a input and accordingly fetch the
data from the db.
Its working fine till Step 2. In step 3, Db connection is made but the
moment it hits the query part, I got the above error.
Am I doing something wrong, or is there a better way to do it.
Please let me know your inputs.
Thanks,
Manu
--
View this message in context: http://old.nabble.com/Caught-unknown-exception-in-activeMQConsumer.cpp-tp29045831p29045831.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Caught unknown exception in activeMQConsumer.cpp
Posted by Timothy Bish <ta...@gmail.com>.
On Wed, 2010-07-14 at 08:07 -0700, manua wrote:
> Hi Tim,
>
> The issue is resolved, It was mysql quey block which was throwing the
> exception, but it was being catched in wrong catch block.
>
> Thanks,
> Manu
Great, glad its now working for you.
Regards
>
>
> Timothy Bish wrote:
> >
> > On Thu, 2010-07-01 at 07:18 -0700, manua wrote:
> >> Hi Tim,
> >>
> >> Please find below my code snippet,
> >>
> >> int get_ref_data(string s){
> >> mysqlpp::Connection conn;
> >> if (conn.connect("Database", "localhost", "proddbuser", "proddblander"))
> >> {
> >> cout << "DB Connected" << endl;
> >> mysqlpp::Query query = conn.query();
> >> query << "SELECT * from table where symbol=" << s << " and
> >> date='20100628'";
> >> if (mysqlpp::StoreQueryResult res = query.store()) {
> >> cout << "Query Data:" << endl;
> >> for (size_t i = 0; i < res.num_rows(); ++i) {
> >> cout << '\t' << res[i][0] << " , "<< res[i][1] << " , "<< res[i][2]
> >> << "
> >> , "<< res[i][3] << " , "<< res[i][4] << endl;
> >> }
> >> }else{
> >> cout << "Couldn't execute the query";
> >> }
> >> }
> >> cout <<endl;
> >> return 1;
> >> }
> >>
> >> void onRequest( void *msg ){
> >> const TextMessage* txtMessage = dynamic_cast< const TextMessage* >(
> >> (Message *)msg );
> >> string s1 = txtMessage->getText();
> >> istringstream is1(s1);
> >> Stream_reader<istringstream, mValue> reader(is1);
> >>
> >> mValue value;
> >> reader.read_next(value);
> >> mObject& O = value.get_obj();
> >>
> >> for(mObject::iterator it=O.begin();it != O.end();++it){
> >> cout <<endl<< (it)->first;
> >> if(!(it)->first.compare("Portfolio")){
> >> mArray& a = O["Portfolio"].get_array();
> >> for(int i=0;i<a.size();i++){
> >> mArray& tmp = a[i].get_array();
> >> cout << endl << " ";
> >> string t = tmp[0].get_value<string>();
> >> get_ref_data(t);
> >> for(int j=0;j<tmp.size();j++){
> >> cout <<" " << tmp[j].get_value<string>();
> >> }
> >> }
> >> }
> >> }
> >>
> >> txtMessage->acknowledge();
> >>
> >> // testing the slave response part. The same Object is being sent as
> >> received.
> >> ofstream os( "json_cpp.txt" );
> >> write_stream( mValue( O ), os, true );
> >>
> >> mObject OR;
> >> OR["response"] = "done";
> >> OR["input"] = O;
> >> string s2 = write_string(mValue( OR ),true);
> >>
> >> destURI = "Data.Response.Q";
> >> respProducer = new clAMQ(brokerURI, destURI);
> >> respProducer->connect();
> >> respProducer->createProducer();
> >>
> >> void *rmsg = respProducer->createTextMessage();
> >> clAMQ::addPayLoadToTextMessage(rmsg,s2);
> >> respProducer->sendMsg(rmsg);
> >> }
> >>
> >>
> >> In the above function, when get_data() is called, I got the error
> >> message.
> >>
> >
> > I don't really see much error handling in these methods so it likely
> > something in there is throwing an exception, I'd recommend maybe
> > stepping through the code with the debugger to see if that's true and if
> > so then you can see where its coming from.
> >
> > Regards
> > Tim.
> >
> >> Please let me your inputs.
> >>
> >> Thanks,
> >> Manu
> >>
> >>
> >> Timothy Bish wrote:
> >> >
> >> > On Thu, 2010-07-01 at 06:47 -0700, manua wrote:
> >> >> Hi All,
> >> >>
> >> >> I am getting the following error, when processing the received
> >> message,
> >> >>
> >> >> caught unknown exception
> >> >> FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 987
> >> >> FILE: activemq/core/ActiveMQSessionExecutor.cpp, LINE: 133
> >> >>
> >> >> My application is divided into three parts,
> >> >>
> >> >> 1. On receiving the message, its extracting the test message and
> >> passing
> >> >> that to json_spirit function.
> >> >> 2. The json spirit function converts the text message to a json and
> >> >> extract
> >> >> the various vector/map parameters. It then pass the extracted
> >> parameter
> >> >> to
> >> >> the Db Function.
> >> >> 3. The Db function takes the string as a input and accordingly fetch
> >> the
> >> >> data from the db.
> >> >>
> >> >> Its working fine till Step 2. In step 3, Db connection is made but the
> >> >> moment it hits the query part, I got the above error.
> >> >>
> >> >> Am I doing something wrong, or is there a better way to do it.
> >> >> Please let me know your inputs.
> >> >>
> >> >> Thanks,
> >> >> Manu
> >> >
> >> > Without seeing the code my first guess would be that your onMessage
> >> > method is throwing an exception somewhere in your step three which
> >> > propagates back through the ActiveMQConsumer to the
> >> > ActiveMQSessionExecutor. I'd add some more exception handing in you
> >> > onMessage handler to see what your code is throwing.
> >> >
> >> > Regards
> >> >
> >> > --
> >> > Tim Bish
> >> >
> >> > Open Source Integration: http://fusesource.com
> >> > ActiveMQ in Action: http://www.manning.com/snyder/
> >> >
> >> > Follow me on Twitter: http://twitter.com/tabish121
> >> > My Blog: http://timbish.blogspot.com/
> >> >
> >> >
> >> >
> >>
> >
> > --
> > Tim Bish
> >
> > Open Source Integration: http://fusesource.com
> > ActiveMQ in Action: http://www.manning.com/snyder/
> >
> > Follow me on Twitter: http://twitter.com/tabish121
> > My Blog: http://timbish.blogspot.com/
> >
> >
> >
>
--
Tim Bish
Open Source Integration: http://fusesource.com
ActiveMQ in Action: http://www.manning.com/snyder/
Follow me on Twitter: http://twitter.com/tabish121
My Blog: http://timbish.blogspot.com/
Re: Caught unknown exception in activeMQConsumer.cpp
Posted by manua <ag...@gmail.com>.
Hi Tim,
The issue is resolved, It was mysql quey block which was throwing the
exception, but it was being catched in wrong catch block.
Thanks,
Manu
Timothy Bish wrote:
>
> On Thu, 2010-07-01 at 07:18 -0700, manua wrote:
>> Hi Tim,
>>
>> Please find below my code snippet,
>>
>> int get_ref_data(string s){
>> mysqlpp::Connection conn;
>> if (conn.connect("Database", "localhost", "proddbuser", "proddblander"))
>> {
>> cout << "DB Connected" << endl;
>> mysqlpp::Query query = conn.query();
>> query << "SELECT * from table where symbol=" << s << " and
>> date='20100628'";
>> if (mysqlpp::StoreQueryResult res = query.store()) {
>> cout << "Query Data:" << endl;
>> for (size_t i = 0; i < res.num_rows(); ++i) {
>> cout << '\t' << res[i][0] << " , "<< res[i][1] << " , "<< res[i][2]
>> << "
>> , "<< res[i][3] << " , "<< res[i][4] << endl;
>> }
>> }else{
>> cout << "Couldn't execute the query";
>> }
>> }
>> cout <<endl;
>> return 1;
>> }
>>
>> void onRequest( void *msg ){
>> const TextMessage* txtMessage = dynamic_cast< const TextMessage* >(
>> (Message *)msg );
>> string s1 = txtMessage->getText();
>> istringstream is1(s1);
>> Stream_reader<istringstream, mValue> reader(is1);
>>
>> mValue value;
>> reader.read_next(value);
>> mObject& O = value.get_obj();
>>
>> for(mObject::iterator it=O.begin();it != O.end();++it){
>> cout <<endl<< (it)->first;
>> if(!(it)->first.compare("Portfolio")){
>> mArray& a = O["Portfolio"].get_array();
>> for(int i=0;i<a.size();i++){
>> mArray& tmp = a[i].get_array();
>> cout << endl << " ";
>> string t = tmp[0].get_value<string>();
>> get_ref_data(t);
>> for(int j=0;j<tmp.size();j++){
>> cout <<" " << tmp[j].get_value<string>();
>> }
>> }
>> }
>> }
>>
>> txtMessage->acknowledge();
>>
>> // testing the slave response part. The same Object is being sent as
>> received.
>> ofstream os( "json_cpp.txt" );
>> write_stream( mValue( O ), os, true );
>>
>> mObject OR;
>> OR["response"] = "done";
>> OR["input"] = O;
>> string s2 = write_string(mValue( OR ),true);
>>
>> destURI = "Data.Response.Q";
>> respProducer = new clAMQ(brokerURI, destURI);
>> respProducer->connect();
>> respProducer->createProducer();
>>
>> void *rmsg = respProducer->createTextMessage();
>> clAMQ::addPayLoadToTextMessage(rmsg,s2);
>> respProducer->sendMsg(rmsg);
>> }
>>
>>
>> In the above function, when get_data() is called, I got the error
>> message.
>>
>
> I don't really see much error handling in these methods so it likely
> something in there is throwing an exception, I'd recommend maybe
> stepping through the code with the debugger to see if that's true and if
> so then you can see where its coming from.
>
> Regards
> Tim.
>
>> Please let me your inputs.
>>
>> Thanks,
>> Manu
>>
>>
>> Timothy Bish wrote:
>> >
>> > On Thu, 2010-07-01 at 06:47 -0700, manua wrote:
>> >> Hi All,
>> >>
>> >> I am getting the following error, when processing the received
>> message,
>> >>
>> >> caught unknown exception
>> >> FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 987
>> >> FILE: activemq/core/ActiveMQSessionExecutor.cpp, LINE: 133
>> >>
>> >> My application is divided into three parts,
>> >>
>> >> 1. On receiving the message, its extracting the test message and
>> passing
>> >> that to json_spirit function.
>> >> 2. The json spirit function converts the text message to a json and
>> >> extract
>> >> the various vector/map parameters. It then pass the extracted
>> parameter
>> >> to
>> >> the Db Function.
>> >> 3. The Db function takes the string as a input and accordingly fetch
>> the
>> >> data from the db.
>> >>
>> >> Its working fine till Step 2. In step 3, Db connection is made but the
>> >> moment it hits the query part, I got the above error.
>> >>
>> >> Am I doing something wrong, or is there a better way to do it.
>> >> Please let me know your inputs.
>> >>
>> >> Thanks,
>> >> Manu
>> >
>> > Without seeing the code my first guess would be that your onMessage
>> > method is throwing an exception somewhere in your step three which
>> > propagates back through the ActiveMQConsumer to the
>> > ActiveMQSessionExecutor. I'd add some more exception handing in you
>> > onMessage handler to see what your code is throwing.
>> >
>> > Regards
>> >
>> > --
>> > Tim Bish
>> >
>> > Open Source Integration: http://fusesource.com
>> > ActiveMQ in Action: http://www.manning.com/snyder/
>> >
>> > Follow me on Twitter: http://twitter.com/tabish121
>> > My Blog: http://timbish.blogspot.com/
>> >
>> >
>> >
>>
>
> --
> Tim Bish
>
> Open Source Integration: http://fusesource.com
> ActiveMQ in Action: http://www.manning.com/snyder/
>
> Follow me on Twitter: http://twitter.com/tabish121
> My Blog: http://timbish.blogspot.com/
>
>
>
--
View this message in context: http://old.nabble.com/Caught-unknown-exception-in-activeMQConsumer.cpp-tp29045831p29163079.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Caught unknown exception in activeMQConsumer.cpp
Posted by Timothy Bish <ta...@gmail.com>.
On Thu, 2010-07-01 at 07:18 -0700, manua wrote:
> Hi Tim,
>
> Please find below my code snippet,
>
> int get_ref_data(string s){
> mysqlpp::Connection conn;
> if (conn.connect("Database", "localhost", "proddbuser", "proddblander")) {
> cout << "DB Connected" << endl;
> mysqlpp::Query query = conn.query();
> query << "SELECT * from table where symbol=" << s << " and
> date='20100628'";
> if (mysqlpp::StoreQueryResult res = query.store()) {
> cout << "Query Data:" << endl;
> for (size_t i = 0; i < res.num_rows(); ++i) {
> cout << '\t' << res[i][0] << " , "<< res[i][1] << " , "<< res[i][2] << "
> , "<< res[i][3] << " , "<< res[i][4] << endl;
> }
> }else{
> cout << "Couldn't execute the query";
> }
> }
> cout <<endl;
> return 1;
> }
>
> void onRequest( void *msg ){
> const TextMessage* txtMessage = dynamic_cast< const TextMessage* >(
> (Message *)msg );
> string s1 = txtMessage->getText();
> istringstream is1(s1);
> Stream_reader<istringstream, mValue> reader(is1);
>
> mValue value;
> reader.read_next(value);
> mObject& O = value.get_obj();
>
> for(mObject::iterator it=O.begin();it != O.end();++it){
> cout <<endl<< (it)->first;
> if(!(it)->first.compare("Portfolio")){
> mArray& a = O["Portfolio"].get_array();
> for(int i=0;i<a.size();i++){
> mArray& tmp = a[i].get_array();
> cout << endl << " ";
> string t = tmp[0].get_value<string>();
> get_ref_data(t);
> for(int j=0;j<tmp.size();j++){
> cout <<" " << tmp[j].get_value<string>();
> }
> }
> }
> }
>
> txtMessage->acknowledge();
>
> // testing the slave response part. The same Object is being sent as
> received.
> ofstream os( "json_cpp.txt" );
> write_stream( mValue( O ), os, true );
>
> mObject OR;
> OR["response"] = "done";
> OR["input"] = O;
> string s2 = write_string(mValue( OR ),true);
>
> destURI = "Data.Response.Q";
> respProducer = new clAMQ(brokerURI, destURI);
> respProducer->connect();
> respProducer->createProducer();
>
> void *rmsg = respProducer->createTextMessage();
> clAMQ::addPayLoadToTextMessage(rmsg,s2);
> respProducer->sendMsg(rmsg);
> }
>
>
> In the above function, when get_data() is called, I got the error message.
>
I don't really see much error handling in these methods so it likely
something in there is throwing an exception, I'd recommend maybe
stepping through the code with the debugger to see if that's true and if
so then you can see where its coming from.
Regards
Tim.
> Please let me your inputs.
>
> Thanks,
> Manu
>
>
> Timothy Bish wrote:
> >
> > On Thu, 2010-07-01 at 06:47 -0700, manua wrote:
> >> Hi All,
> >>
> >> I am getting the following error, when processing the received message,
> >>
> >> caught unknown exception
> >> FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 987
> >> FILE: activemq/core/ActiveMQSessionExecutor.cpp, LINE: 133
> >>
> >> My application is divided into three parts,
> >>
> >> 1. On receiving the message, its extracting the test message and passing
> >> that to json_spirit function.
> >> 2. The json spirit function converts the text message to a json and
> >> extract
> >> the various vector/map parameters. It then pass the extracted parameter
> >> to
> >> the Db Function.
> >> 3. The Db function takes the string as a input and accordingly fetch the
> >> data from the db.
> >>
> >> Its working fine till Step 2. In step 3, Db connection is made but the
> >> moment it hits the query part, I got the above error.
> >>
> >> Am I doing something wrong, or is there a better way to do it.
> >> Please let me know your inputs.
> >>
> >> Thanks,
> >> Manu
> >
> > Without seeing the code my first guess would be that your onMessage
> > method is throwing an exception somewhere in your step three which
> > propagates back through the ActiveMQConsumer to the
> > ActiveMQSessionExecutor. I'd add some more exception handing in you
> > onMessage handler to see what your code is throwing.
> >
> > Regards
> >
> > --
> > Tim Bish
> >
> > Open Source Integration: http://fusesource.com
> > ActiveMQ in Action: http://www.manning.com/snyder/
> >
> > Follow me on Twitter: http://twitter.com/tabish121
> > My Blog: http://timbish.blogspot.com/
> >
> >
> >
>
--
Tim Bish
Open Source Integration: http://fusesource.com
ActiveMQ in Action: http://www.manning.com/snyder/
Follow me on Twitter: http://twitter.com/tabish121
My Blog: http://timbish.blogspot.com/
Re: Caught unknown exception in activeMQConsumer.cpp
Posted by manua <ag...@gmail.com>.
Hi Tim,
Please find below my code snippet,
int get_ref_data(string s){
mysqlpp::Connection conn;
if (conn.connect("Database", "localhost", "proddbuser", "proddblander")) {
cout << "DB Connected" << endl;
mysqlpp::Query query = conn.query();
query << "SELECT * from table where symbol=" << s << " and
date='20100628'";
if (mysqlpp::StoreQueryResult res = query.store()) {
cout << "Query Data:" << endl;
for (size_t i = 0; i < res.num_rows(); ++i) {
cout << '\t' << res[i][0] << " , "<< res[i][1] << " , "<< res[i][2] << "
, "<< res[i][3] << " , "<< res[i][4] << endl;
}
}else{
cout << "Couldn't execute the query";
}
}
cout <<endl;
return 1;
}
void onRequest( void *msg ){
const TextMessage* txtMessage = dynamic_cast< const TextMessage* >(
(Message *)msg );
string s1 = txtMessage->getText();
istringstream is1(s1);
Stream_reader<istringstream, mValue> reader(is1);
mValue value;
reader.read_next(value);
mObject& O = value.get_obj();
for(mObject::iterator it=O.begin();it != O.end();++it){
cout <<endl<< (it)->first;
if(!(it)->first.compare("Portfolio")){
mArray& a = O["Portfolio"].get_array();
for(int i=0;i<a.size();i++){
mArray& tmp = a[i].get_array();
cout << endl << " ";
string t = tmp[0].get_value<string>();
get_ref_data(t);
for(int j=0;j<tmp.size();j++){
cout <<" " << tmp[j].get_value<string>();
}
}
}
}
txtMessage->acknowledge();
// testing the slave response part. The same Object is being sent as
received.
ofstream os( "json_cpp.txt" );
write_stream( mValue( O ), os, true );
mObject OR;
OR["response"] = "done";
OR["input"] = O;
string s2 = write_string(mValue( OR ),true);
destURI = "Data.Response.Q";
respProducer = new clAMQ(brokerURI, destURI);
respProducer->connect();
respProducer->createProducer();
void *rmsg = respProducer->createTextMessage();
clAMQ::addPayLoadToTextMessage(rmsg,s2);
respProducer->sendMsg(rmsg);
}
In the above function, when get_data() is called, I got the error message.
Please let me your inputs.
Thanks,
Manu
Timothy Bish wrote:
>
> On Thu, 2010-07-01 at 06:47 -0700, manua wrote:
>> Hi All,
>>
>> I am getting the following error, when processing the received message,
>>
>> caught unknown exception
>> FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 987
>> FILE: activemq/core/ActiveMQSessionExecutor.cpp, LINE: 133
>>
>> My application is divided into three parts,
>>
>> 1. On receiving the message, its extracting the test message and passing
>> that to json_spirit function.
>> 2. The json spirit function converts the text message to a json and
>> extract
>> the various vector/map parameters. It then pass the extracted parameter
>> to
>> the Db Function.
>> 3. The Db function takes the string as a input and accordingly fetch the
>> data from the db.
>>
>> Its working fine till Step 2. In step 3, Db connection is made but the
>> moment it hits the query part, I got the above error.
>>
>> Am I doing something wrong, or is there a better way to do it.
>> Please let me know your inputs.
>>
>> Thanks,
>> Manu
>
> Without seeing the code my first guess would be that your onMessage
> method is throwing an exception somewhere in your step three which
> propagates back through the ActiveMQConsumer to the
> ActiveMQSessionExecutor. I'd add some more exception handing in you
> onMessage handler to see what your code is throwing.
>
> Regards
>
> --
> Tim Bish
>
> Open Source Integration: http://fusesource.com
> ActiveMQ in Action: http://www.manning.com/snyder/
>
> Follow me on Twitter: http://twitter.com/tabish121
> My Blog: http://timbish.blogspot.com/
>
>
>
--
View this message in context: http://old.nabble.com/Caught-unknown-exception-in-activeMQConsumer.cpp-tp29045831p29046224.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
Re: Caught unknown exception in activeMQConsumer.cpp
Posted by Timothy Bish <ta...@gmail.com>.
On Thu, 2010-07-01 at 06:47 -0700, manua wrote:
> Hi All,
>
> I am getting the following error, when processing the received message,
>
> caught unknown exception
> FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 987
> FILE: activemq/core/ActiveMQSessionExecutor.cpp, LINE: 133
>
> My application is divided into three parts,
>
> 1. On receiving the message, its extracting the test message and passing
> that to json_spirit function.
> 2. The json spirit function converts the text message to a json and extract
> the various vector/map parameters. It then pass the extracted parameter to
> the Db Function.
> 3. The Db function takes the string as a input and accordingly fetch the
> data from the db.
>
> Its working fine till Step 2. In step 3, Db connection is made but the
> moment it hits the query part, I got the above error.
>
> Am I doing something wrong, or is there a better way to do it.
> Please let me know your inputs.
>
> Thanks,
> Manu
Without seeing the code my first guess would be that your onMessage
method is throwing an exception somewhere in your step three which
propagates back through the ActiveMQConsumer to the
ActiveMQSessionExecutor. I'd add some more exception handing in you
onMessage handler to see what your code is throwing.
Regards
--
Tim Bish
Open Source Integration: http://fusesource.com
ActiveMQ in Action: http://www.manning.com/snyder/
Follow me on Twitter: http://twitter.com/tabish121
My Blog: http://timbish.blogspot.com/