Spring/spring-integration-extensions
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-160: Optimize UnZipResultSplitter

Browse Source 
Fixes spring-projects/spring-integration-extensions#160

* Upgrade to `zt-zip-1.11`
* Polish README a bit
This commit is contained in:
Artem Bilan
2017-06-21 16:46:22 -04:00
parent 6f1b2babf6
commit deeeccc40b
3 changed files with 24 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-integration-zip/README.md
View File

@@ -1,20 +1,15 @@
Spring Integration Zip Support
==============================
| | Build Status |
| ------------- | :-------------: |
| Linux | [![Build Status](http://build.spring.io/plugins/servlet/buildStatusImage/INTEXT-ZIP)](https://build.spring.io/browse/INTEXT-ZIP) |
| Windows | [![Build Status](http://build.spring.io/plugins/servlet/buildStatusImage/INTEXT-ZIPWIN)](https://build.spring.io/browse/INTEXT-ZIPWIN) |
Build Status : [![Build Status](http://build.spring.io/plugins/servlet/buildStatusImage/INTEXT-ZIP)](https://build.spring.io/browse/INTEXT-ZIP)
## Introduction
This *Spring Integration Extension* provides [Zip][] (un-) compression support. The following components are provided:
* Zip transformer
* Unzip transformer
* UnZipResultSplitter
**Important!** This module is currently under active development and not all functionality is provided or stable, yet.
* Zip Transformer
* UnZip Transformer
* UnZip Result Splitter
## ZIP Compression Support

2
spring-integration-zip/build.gradle
View File

@@ -63,7 +63,7 @@ ext {
slf4jVersion = "1.7.21"
springIntegrationVersion = '4.3.10.RELEASE'
ztZipVersion = '1.9'
ztZipVersion = '1.11'
idPrefix = 'zip'
}

31
spring-integration-zip/src/main/java/org/springframework/integration/zip/splitter/UnZipResultSplitter.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2015-2016 the original author or authors.
* Copyright 2015-2017 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -23,37 +23,44 @@ import java.util.Map;
import org.apache.commons.io.FilenameUtils;
import org.springframework.integration.file.FileHeaders;
import org.springframework.integration.splitter.AbstractMessageSplitter;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.integration.zip.ZipHeaders;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.util.Assert;
/**
*
* @author Gunnar Hillert
* @author Andriy Kryvtsun
* @author Artem Bilan
*
* @since 1.0
*/
public class UnZipResultSplitter {
public class UnZipResultSplitter extends AbstractMessageSplitter {
public List<Message<Object>> splitUnzippedMap(Message<Map<String, Object>> message) {
@Override
@SuppressWarnings("unchecked")
protected Object splitMessage(Message<?> message) {
Assert.state(message.getPayload() instanceof Map,
"The UnZipResultSplitter supports only Map<String, Object> payload");
Map<String, Object> unzippedEntries = (Map<String, Object>) message.getPayload();
MessageHeaders headers = message.getHeaders();
Map<String, Object> unzippedEntries = message.getPayload();
List<Message<Object>> messages = new ArrayList<Message<Object>>(unzippedEntries.size());
List<MessageBuilder<Object>> messageBuilders = new ArrayList<MessageBuilder<Object>>(unzippedEntries.size());
for (Map.Entry<String, Object> entry : unzippedEntries.entrySet()) {
final String path = FilenameUtils.getPath(entry.getKey());
final String filename = FilenameUtils.getName(entry.getKey());
final Message<Object> splitMessage = MessageBuilder.withPayload(entry.getValue())
String path = FilenameUtils.getPath(entry.getKey());
String filename = FilenameUtils.getName(entry.getKey());
MessageBuilder<Object> messageBuilder = MessageBuilder.withPayload(entry.getValue())
.setHeader(FileHeaders.FILENAME, filename)
.setHeader(ZipHeaders.ZIP_ENTRY_PATH, path)
.copyHeadersIfAbsent(headers)
.build();
messages.add(splitMessage);
.copyHeadersIfAbsent(headers);
messageBuilders.add(messageBuilder);
}
return messages;
return messageBuilders;
}
}