@@ -869,7 +869,8 @@ public class ConnectorTracker implements Serializable { | |||
} | |||
Map<String, StreamVariable> nameToStreamVar = pidToNameToStreamVariable | |||
.get(connectorId); | |||
nameToStreamVar.remove(variableName); | |||
StreamVariable streamVar = nameToStreamVar.remove(variableName); | |||
streamVariableToSeckey.remove(streamVar); | |||
if (nameToStreamVar.isEmpty()) { | |||
pidToNameToStreamVariable.remove(connectorId); | |||
} |
@@ -1118,6 +1118,8 @@ public class Upload extends AbstractComponent | |||
fireUploadSuccess(event.getFileName(), event.getMimeType(), | |||
event.getContentLength()); | |||
endUpload(); | |||
if(lastStartedEvent != null) | |||
lastStartedEvent.disposeStreamVariable(); | |||
} | |||
@Override | |||
@@ -1136,6 +1138,8 @@ public class Upload extends AbstractComponent | |||
} | |||
} finally { | |||
endUpload(); | |||
if(lastStartedEvent != null) | |||
lastStartedEvent.disposeStreamVariable(); | |||
} | |||
} | |||
}; |