[
https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismaël Mejía resolved BEAM-1962.
--------------------------------
Resolution: Fixed
Assignee: (was: Jean-Baptiste Onofré)
Fix Version/s: Not applicable
This seems like a false positive since the lifecycle methods should close the
connections.
> Connection should be closed in case start() throws exception
> ------------------------------------------------------------
>
> Key: BEAM-1962
> URL: https://issues.apache.org/jira/browse/BEAM-1962
> Project: Beam
> Issue Type: Bug
> Components: io-java-jms
> Reporter: Ted Yu
> Priority: Minor
> Fix For: Not applicable
>
>
> In JmsIO#start() :
> {code}
> try {
> Connection connection;
> if (spec.getUsername() != null) {
> connection =
> connectionFactory.createConnection(spec.getUsername(),
> spec.getPassword());
> } else {
> connection = connectionFactory.createConnection();
> }
> connection.start();
> this.connection = connection;
> } catch (Exception e) {
> throw new IOException("Error connecting to JMS", e);
> }
> {code}
> If start() throws exception, connection should be closed.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
