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

["Tushar Gosavi (JIRA)" <ji...@apache.org>]

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

Tushar Gosavi closed APEXCORE-678.
----------------------------------

Closing after 3.6.0 release

> 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
>             Fix For: 3.6.0
>
>
> 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)