[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] [Commented] (AMQ-3547) Calling Connection.close() on
From:       "Philippe Mouawad (Commented) (JIRA)" <jira () apache ! org>
Date:       2011-10-30 8:01:34
Message-ID: 1412996475.38048.1319961694642.JavaMail.tomcat () hel ! zones ! apache ! org
[Download RAW message or body]


    [ https://issues.apache.org/jira/browse/AMQ-3547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13139562#comment-13139562 \
] 

Philippe Mouawad commented on AMQ-3547:
---------------------------------------

Hello,
I tested last nightly build that integrates this fix, issue is not fixed for me.

Regards
Philippe
                
> Calling Connection.close() on interrupted thread generates InterruptedIOException \
>                 and leaks Connection
> ------------------------------------------------------------------------------------------------------
>  
> Key: AMQ-3547
> URL: https://issues.apache.org/jira/browse/AMQ-3547
> Project: ActiveMQ
> Issue Type: Bug
> Components: JMS client
> Affects Versions: 5.5.0
> Reporter: Martin Beránek
> Assignee: Timothy Bish
> Priority: Critical
> Fix For: 5.6.0
> 
> Attachments: AMQ3529Test.java, AMQ3529Test.java
> 
> 
> Similar to https://issues.apache.org/jira/browse/AMQ-3529
> call close() method on connection raise JMSException with InterruptedIOException as \
> cause Sample program:
> public static void main(String[] args) throws Exception {
> 	ConnectionFactory connectionFactory = new \
> ActiveMQConnectionFactory("tcp://localhost:61616");  Connection connection = \
> connectionFactory.createConnection();  Session session = \
> connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  final Thread mainThread \
> = Thread.currentThread();  new Thread() {
> 		public void run() {
> 			// this thread interrupt main thread after 1s
> 			try {
> 				Thread.sleep(1000);
> 			} catch (InterruptedException e) {
> 			}
> 			mainThread.interrupt();
> 		};
> 	}.start();
> 	try {
> 		//wait for interrupt
> 		Thread.sleep(10000);
> 	} catch (InterruptedException e) {
> 		Thread.currentThread().interrupt();
> 	}
> 	try {
> 		// this generate exception - bug???
> 		connection.close();
> 	} catch (JMSException e) {
> 		e.printStackTrace();
> 	}
> 	// non-daemon thread responsible for connection still running, program
> 	// will not terminate
> }
> when I remove line with Session obtain, everything works OK

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: \
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more \
information on JIRA, see: http://www.atlassian.com/software/jira

       


[prev in list] [next in list] [prev in thread] [next in thread]