[jira] [Updated] (APEXCORE-678) Shutdown of application should start from input nodes

["Bhupesh Chawda (JIRA)" <ji...@apache.org>]

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

Bhupesh Chawda updated APEXCORE-678:
------------------------------------
    Description: 
Streaming container calls shutdown() for all nodes instead of just input nodes.

{code}
  private void stopInputNodes()
  {
    for (Entry<Integer, Node<?>> e : nodes.entrySet()) {
      Node<?> node = e.getValue();
      if (node instanceof InputNode) {
        final Thread thread = e.getValue().context.getThread();
        if (thread == null || !thread.isAlive()) {
          continue;
        }
      }
      node.shutdown(true);
    }
  }
{code}

  was:
Streaming container calls shutdown() for all nodes instead of just input nodes.

```
  private void stopInputNodes()
  {
    for (Entry<Integer, Node<?>> e : nodes.entrySet()) {
      Node<?> node = e.getValue();
      if (node instanceof InputNode) {
        final Thread thread = e.getValue().context.getThread();
        if (thread == null || !thread.isAlive()) {
          continue;
        }
      }
      node.shutdown(true);
    }
  }
```


> Shutdown of application should start from input nodes
> -----------------------------------------------------
>
>                 Key: APEXCORE-678
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-678
>             Project: Apache Apex Core
>          Issue Type: Bug
>            Reporter: Bhupesh Chawda
>            Assignee: Bhupesh Chawda
>
> Streaming container calls shutdown() for all nodes instead of just input nodes.
> {code}
>   private void stopInputNodes()
>   {
>     for (Entry<Integer, Node<?>> e : nodes.entrySet()) {
>       Node<?> node = e.getValue();
>       if (node instanceof InputNode) {
>         final Thread thread = e.getValue().context.getThread();
>         if (thread == null || !thread.isAlive()) {
>           continue;
>         }
>       }
>       node.shutdown(true);
>     }
>   }
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)