What version of the broker are you using? Regards
Tim > -----Original Message----- > From: amq user [mailto:[EMAIL PROTECTED] > Sent: Friday, December 08, 2006 2:37 PM > To: activemq-dev@geronimo.apache.org > Subject: Re: active-cpp persistent problem > > On 12/8/06, Bish, Tim <[EMAIL PROTECTED]> wrote: > > > > > > AFAIK the activemq-cpp message do properly send the persistant flag. > > > > Can you create a small test app that demonstrates to problem? > > > yes. my test code is just a copy of main.cpp from the example. > > run method looks like: > > virtual void run() { > try { > // Open test message file > FILE *fd; > if ( (fd = fopen(messageFile.c_str(), "r")) == NULL) { > cout<<"Error: Can't open file: "<<messageFile<<endl; > return; > } > > ActiveMQConnectionFactory* connectionFactory = new > ActiveMQConnectionFactory("tcp://10.111.53.230:22222"); > // Create a Connection > connection = connectionFactory->createConnection(); > connection->start(); > // Create a Session > session = connection->createSession( Session::AUTO_ACKNOWLEDGE > ); > > // Create the destination (Topic or Queue) > destination = session->createQueue( "TEST.FOO" ); > > // Create a MessageProducer from the Session to the Topic or > Queue > producer = session->createProducer( destination ); > producer->setDeliveryMode( DeliveryMode::PERSISTANT ); > > // Create the Thread Id String > string threadIdStr = Integer::toString( Thread::getId() ); > > // Create a messages > string texts = (string)"<START_PERFORM_TEST>"; > string texte = (string)"<END_PERFORM_TEST>"; > TextMessage* message_s = session->createTextMessage( > string(texts) ); > > producer->send( message_s ); > delete message_s; > > char * line = NULL; > size_t len = 0; > ssize_t read; > for( int ix=0; ix<numMessages; ++ix ){ > fseek(fd,0L,SEEK_SET); > while((read = getline(&line,&len,fd)) != -1) { > //TextMessage* message = session->createTextMessage( text > ); > TextMessage* message = session->createTextMessage( > string(line) ); > > // Tell the producer to send the message > //printf( "Sent message from thread %s\n", > threadIdStr.c_str() > ); > producer->send( message ); > > delete message; > } > } > > TextMessage* message_e = session->createTextMessage( > string(texte) ); > producer->send( message_e ); > delete message_e; > > if(line) > free(line); > > }catch ( CMSException& e ) { > e.printStackTrace(); > } > } > > > > > What are the steps you are currently following in both cases? Are you > > sending messages with the C++ client and they are not persistant when > > you restart and connect a C++ client back to the broker, or have you > > tried sending a message persistantly with C++ and then connecting back > > with a Java client to see if that gets the messages that should have > > been persisted? > > > I used the cpp code above to send some messages. And they are gone after I > restart the broker. I tried to use cpp consumer to get those messages. > Actually, I don't need to restart the message to see if it is consistent > or > not. If i send enough message to the broker, jconsole says > MemoryPercentageUsed: 100. and I got this: > activemq::io::SocketOutputStream::write - Resource temporarily unavailable > - > tid: 3085880224 > FILE: activemq/network/SocketOutputStream.cpp, LINE: 85 - tid: > 3085880224 > FILE: activemq/connector/stomp/StompCommandWriter.cpp, LINE: 101 - > tid: 3085880224 > FILE: ./activemq/transport/ResponseCorrelator.h, LINE: 163 - tid: > 3085880224 > caught unknown exception - tid: 3085880224 > FILE: activemq/connector/stomp/StompConnector.cpp, LINE: 466 - > tid: > 3085880224 > FILE: activemq/core/ActiveMQSession.cpp, LINE: 495 - tid: > 3085880224 > FILE: activemq/core/ActiveMQProducer.cpp, LINE: 89 - tid: > 3085880224 > FILE: activemq/core/ActiveMQProducer.cpp, LINE: 71 - tid: > 3085880224 > caught unknown exception > FILE: activemq/connector/stomp/StompConnector.cpp, LINE: 466 > FILE: activemq/core/ActiveMQSession.cpp, LINE: 495 > FILE: activemq/core/ActiveMQProducer.cpp, LINE: 89 > FILE: activemq/core/ActiveMQProducer.cpp, LINE: 71 > > Thanks > > > > > > Regards > > > > Tim. > > > > > -----Original Message----- > > > From: amq user [mailto:[EMAIL PROTECTED] > > > Sent: Friday, December 08, 2006 2:10 PM > > > To: activemq-dev > > > Subject: active-cpp persistent problem > > > > > > I'm struggling with persistent option in activemq-cpp client. (my java > > > client does the trick) > > > part of my code looks like: > > > > > > producer->setDeliveryMode( DeliveryMode::PERSISTANT ); > > > > > > The problem is after I send a message, and stop the broker. The > > message is > > > gone. > > > If I send a lot of message exceeding the memory size the broker > > handles, I > > > got resource unavailable exception. > > > > > > It looks to me the message I send over using cpp doesn't instruct the > > > broker > > > to use persistent. > > > I'm using ActiveMQ 4.0.2, and activemq-cpp-1.0. > > > > > > Please help. What else should I check. Did I miss anything? > > > Thanks > >
