|
@@ -70,7 +70,7 @@ public class UploadChannelService {
|
|
|
int fileType = uploadChannel.getFileType();
|
|
int fileType = uploadChannel.getFileType();
|
|
|
boolean processFile = uploadChannel.getProcessFile();
|
|
boolean processFile = uploadChannel.getProcessFile();
|
|
|
int scope = uploadChannel.getScope();
|
|
int scope = uploadChannel.getScope();
|
|
|
- ObjectChannel channel = new ObjectChannel(channelId, name, channelPrefix, maxSize, fileType, processFile, scope, domain);
|
|
|
|
|
|
|
+ ObjectChannel channel = new ObjectChannel(channelId, name, channelPrefix, maxSize, fileType, processFile, scope, domain, createBy);
|
|
|
|
|
|
|
|
String host = storeNode.getNodeAddr();
|
|
String host = storeNode.getNodeAddr();
|
|
|
int port = storeNode.getRpcPort();
|
|
int port = storeNode.getRpcPort();
|
|
@@ -154,7 +154,8 @@ public class UploadChannelService {
|
|
|
boolean processFile = uploadChannel.getProcessFile();
|
|
boolean processFile = uploadChannel.getProcessFile();
|
|
|
int scope = uploadChannel.getScope();
|
|
int scope = uploadChannel.getScope();
|
|
|
String domain = storeNodeService.getById(uploadChannel.getNodeId()).getDomain();
|
|
String domain = storeNodeService.getById(uploadChannel.getNodeId()).getDomain();
|
|
|
- return new ObjectChannel(channelId, name, channelPrefix, maxSize, fileType, processFile, scope, domain);
|
|
|
|
|
|
|
+ int createBy = uploadChannel.getCreateBy();
|
|
|
|
|
+ return new ObjectChannel(channelId, name, channelPrefix, maxSize, fileType, processFile, scope, domain, createBy);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
public StoreNode getStoreNodeByChannelId(int channelId) throws Exception {
|
|
public StoreNode getStoreNodeByChannelId(int channelId) throws Exception {
|