Pavel Moravec created QPID-6087:
-----------------------------------
Summary: QMF Session name to contain user ID for AMQP 0-10
Key: QPID-6087
URL: https://issues.apache.org/jira/browse/QPID-6087
Project: Qpid
Issue Type: Bug
Components: C++ Broker
Affects Versions: 0.28
Reporter: Pavel Moravec
Assignee: Pavel Moravec
Priority: Minor
Description of problem:
AMQP 0-10 allows sessions of the same name attached in parallel by different
users. Broker allows that, but QMF can't cope with it properly as it stores
session object by its name - that is unique per one user only.
Therefore, QMF does not track all sessions, subscriptions (maybe something
else) in those cases.
It is required to have unique session ID for QMF. Either having user ID as part
of the session ID, or use pointer to the session object like AMQP 1.0
implementation uses.
Version-Release number of selected component (if applicable):
any (0.18-30, 0.22-48)
How reproducible:
100%
Steps to Reproduce:
1) Have usera:usera and userb:userb credentials for qpid broker
2) Compile below program:
#include <cstdlib>
#include <iostream>
#include <sstream>
#include <qpid/messaging/Address.h>
#include <qpid/messaging/Connection.h>
#include <qpid/messaging/Message.h>
#include <qpid/messaging/Sender.h>
#include <qpid/messaging/Receiver.h>
#include <qpid/messaging/Session.h>
using namespace qpid::messaging;
using namespace qpid::types;
using std::stringstream;
using std::string;
int main(int argc, char** argv) {
const char* session_name = argc>1 ? argv[1] : "session_name";
const char* connectionOptions = argc>2 ? argv[2] : "{username:guest,
password:guest}";
const char* address = argc>3 ? argv[3] : "myQueue; {create:always}";
Connection connection("localhost:5672", connectionOptions);
try {
connection.open();
Session session = connection.createSession(session_name);
Receiver receiver = session.createReceiver(address);
receiver.fetch();
connection.close();
return 0;
} catch(const std::exception& error) {
std::cout << error.what() << std::endl;
connection.close();
}
return 1;
}
3) ./session_attach_given_name aaa "{username:usera, password:usera}" &
4) ./session_attach_given_name aaa "{username:userb, password:userb}" &
5) grep errors in qpidd logs
6) check subscriptions (qpid-stat -u) and sessions (qpid-tool -> list session)
that QMF is aware of
Actual results:
5) qpid prints errors:
2014-09-02 16:07:04 [Management] error Detected two management objects with the
same identifier:
0-51-1--17(org.apache.qpid.broker:subscription:org.apache.qpid.broker:session:aaa,org.apache.qpid.broker:queue:myQueue,myQueue)
2014-09-02 16:07:04 [Management] error Detected two management objects with the
same identifier: 0-51-1--14(org.apache.qpid.broker:session:aaa)
6) there is just 1 subscription for "myQueue" queue (while both programs create
one) and just 1 session named "aaa".
Expected results:
no error, 2 subscriptions, 2 sessions
Additional info:
AMQP 1.0 connections/session works well here, as AMQP 1.0 does not have named
sessions and string of pointer is used rather.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
