Re: [Qpid Java Broker] Get SessionPrincipal

2017-06-02 Thread Oleksandr Rudyy
Vavricka, I made a change which should fix the issue. Alex On 2 June 2017 at 14:35, Vavricka wrote: > Thanks for quick answer and raising JIRA. > > Regards, > Vavricka > > > > -- > View this message in context: http://qpid.2158936.n2.nabble. > com/Qpid-Java-Broker-Get-SessionPrincipal-tp7663741

Re: [Qpid Java Broker] Get SessionPrincipal

2017-06-02 Thread Vavricka
Thanks for quick answer and raising JIRA. Regards, Vavricka -- View this message in context: http://qpid.2158936.n2.nabble.com/Qpid-Java-Broker-Get-SessionPrincipal-tp7663741p7663746.html Sent from the Apache Qpid users mailing list archive at Nabble.com. -

Re: [Qpid Java Broker] Get SessionPrincipal

2017-06-02 Thread Oleksandr Rudyy
Vavricka, Thanks for reporting the issue and providing instruction how to reproduce it. I raised JIRA QPID-7808 [1] for it. I am going to fix the defect. Kind Regards, Alex [1] https://issues.apache.org/jira/browse/QPID-7808 On 2 June 2017 at 13:13, Vavricka wrote: > Complete stacktrace in at

Re: [Qpid Java Broker] Get SessionPrincipal

2017-06-02 Thread Vavricka
Complete stacktrace in attached file threads_report.txt Stacktrace within checkOverfull method: "IO-/127.0.0.1:57308@5531" prio=5 tid=0x21 nid=NA runnable java.lang.Thread.State: RUNNABLE at org.apache.qpid.serve

Re: [Qpid Java Broker] Get SessionPrincipal

2017-06-02 Thread Keith W
Hi Vavricka, The absence of the SessionPrincipal would suggest the calling thread is somehow running without the Session's _accessControllerContext which would suggest a bug. The AMQP connection implementations organise for connection work to be done with the AbstractAMQPConnection#_accessControl

[Qpid Java Broker] Get SessionPrincipal

2017-06-02 Thread Vavricka
Hi, I would like to get current session in Java Broker source code. In class ProducerFlowControlOverflowPolicyHandler in checkOverfull() method there is current session get by Set sessionPrincipals = subject.getPrincipals(SessionPrincipal.class); When I use this for AMQP 1.0 connection, ever