qpid-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "question" <46970...@qq.com>
Subject Memory keeping increasing when using Qpid, can any one help?
Date Thu, 19 Oct 2017 10:13:55 GMT
Dear all,


Sorry to disturb you. I am new to Qpid. 
When I tried to write a simple sender and receiver by splitting the HelloWorld example in
Qpid cpp 1.36.  I met memory problem.


HelloWord1 is responsible receiving data as below:


                       Connection connection(broker, connectionOptions);
			connection.open();


			Session session = connection.createSession();
			Receiver receiver = session.createReceiver(address);


			while (true)
			{			


				Message message;
				message.setContentObject("Hello world!");
				message.getContentObject().setEncoding("utf8");
			//	sender.send(message);


				message = receiver.fetch(Duration::FOREVER);
				std::cout << message.getContent() << std::endl;
				session.acknowledge();			


			}
			connection.close();



HelloWorld2 is responsible sending data as below:
                     
			Connection connection(broker, connectionOptions);
			connection.open();
			Session session = connection.createSession();
			Sender sender = session.createSender(address);
			for (int i = 0; i < 500000000; i++)
			{
				Message message;
				message.setContentObject("Hello world!");
				message.getContentObject().setEncoding("utf8");
				sender.send(message);
			


			}
			connection.close();


And I use Java qpid-broker-6.1.1 as broker.


I saw the both processes HelloWord1.exe  and HelloWorld2.exe  memory usage increase quickly.
Am I using the Qpid in a wrong way? Maybe I am too stupid. Can anyone help? :-(


The two cpp files are attached...


Thanks,
Frank.
Mime
View raw message