[ 
https://issues.apache.org/jira/browse/BEAM-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ted Yu updated BEAM-1962:
-------------------------
    Description: 
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.

  was:
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.


> 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: sdk-java-extensions
>            Reporter: Ted Yu
>            Assignee: Jean-Baptiste Onofré
>            Priority: Minor
>
> 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
(v6.4.14#64029)

Reply via email to