Skip to content
Snippets Groups Projects
Commit d6cac360 authored by Manuela Kuhn's avatar Manuela Kuhn
Browse files

Moves the sending part inside of getFromHttp

parent 14975778
No related branches found
No related tags found
No related merge requests found
......@@ -127,17 +127,10 @@ def sendData (log, targets, sourceFile, targetFile, metadata, openConnections,
except:
log.error("Unable to pack multipart-message for file " + str(sourceFile), exc_info=True)
if prop["storeFlag"]:
fileDescriptor.write(data)
#send message
try:
__sendToTargets(log, targets, sourceFile, targetFile, openConnections, metadataExtended, payload, context)
log.debug("Passing multipart-message for file " + str(sourceFile) + "...done.")
except:
log.error("Unable to send multipart-message for file " + str(sourceFile), exc_info=True)
chunkNumber += 1
if prop["storeFlag"]:
try:
......@@ -147,6 +140,15 @@ def sendData (log, targets, sourceFile, targetFile, metadata, openConnections,
log.error("Unable to close target file '" + str(targetFile) + "'.", exc_info=True)
raise
#send message
try:
__sendToTargets(log, targets, sourceFile, targetFile, openConnections, metadataExtended, payload, context)
log.debug("Passing multipart-message for file " + str(sourceFile) + "...done.")
except:
log.error("Unable to send multipart-message for file " + str(sourceFile), exc_info=True)
def finishDataHandling (log, sourceFile, targetFile, prop):
if prop["removeFlag"]:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment