public class org.apache.camel.component.file.FileEndpoint extends org.apache.camel.component.file.GenericFileEndpoint
{
private static final java.lang.Integer CHMOD_WRITE_MASK;
private static final java.lang.Integer CHMOD_READ_MASK;
private static final java.lang.Integer CHMOD_EXECUTE_MASK;
private final org.apache.camel.component.file.FileOperations operations;
private java.io.File file;
private boolean copyAndDeleteOnRenameFail;
private boolean renameUsingCopy;
private boolean forceWrites;
private boolean probeContentType;
private java.lang.String extendedAttributes;
private java.lang.String chmod;
private java.lang.String chmodDirectory;
public void <init>()
{
org.apache.camel.component.file.FileOperations v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
specialinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: void <init>()>();
v = new org.apache.camel.component.file.FileOperations;
specialinvoke v.<org.apache.camel.component.file.FileOperations: void <init>(org.apache.camel.component.file.FileEndpoint)>(v);
v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations> = v;
v.<org.apache.camel.component.file.FileEndpoint: boolean copyAndDeleteOnRenameFail> = 1;
v.<org.apache.camel.component.file.FileEndpoint: boolean forceWrites> = 1;
return;
}
public void <init>(java.lang.String, org.apache.camel.Component)
{
org.apache.camel.component.file.FileEndpoint v;
org.apache.camel.component.file.FileOperations v;
org.apache.camel.Component v;
java.lang.String v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.Component;
specialinvoke v.<org.apache.camel.component.file.GenericFileEndpoint: void <init>(java.lang.String,org.apache.camel.Component)>(v, v);
v = new org.apache.camel.component.file.FileOperations;
specialinvoke v.<org.apache.camel.component.file.FileOperations: void <init>(org.apache.camel.component.file.FileEndpoint)>(v);
v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations> = v;
v.<org.apache.camel.component.file.FileEndpoint: boolean copyAndDeleteOnRenameFail> = 1;
v.<org.apache.camel.component.file.FileEndpoint: boolean forceWrites> = 1;
return;
}
public org.apache.camel.component.file.FileConsumer createConsumer(org.apache.camel.Processor) throws java.lang.Exception
{
java.lang.Integer v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.function.Predicate v;
java.io.FileNotFoundException v;
java.util.stream.Stream v;
org.apache.camel.component.file.FileEndpoint v;
java.lang.String[] v;
org.apache.camel.spi.IdempotentRepository v, v;
org.apache.camel.Expression v;
org.apache.camel.Processor v;
int v;
java.lang.Boolean v, v;
java.lang.String v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v;
org.apache.camel.component.file.FileOperations v, v, v;
java.lang.IllegalArgumentException v, v, v;
java.io.File v, v, v, v, v, v, v, v;
org.apache.camel.component.file.FileConsumer v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: org.apache.camel.Processor;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "operations");
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "file");
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isAutoCreate()>();
if v == 0 goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.slf4j.Logger log>;
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Creating non existing starting directory: {}", v);
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
v = staticinvoke <org.apache.camel.util.FileUtil: boolean isAbsolute(java.io.File)>(v);
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations>;
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
v = virtualinvoke v.<java.io.File: java.lang.String getPath()>();
v = virtualinvoke v.<org.apache.camel.component.file.FileOperations: boolean buildDirectory(java.lang.String,boolean)>(v, v);
if v != 0 goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.slf4j.Logger log>;
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Cannot auto create starting directory: {}", v);
goto label;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isStartingDirectoryMustExist()>();
if v == 0 goto label;
v = new java.io.FileNotFoundException;
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Starting directory does not exist: \u0001");
specialinvoke v.<java.io.FileNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations>;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileConsumer newFileConsumer(org.apache.camel.Processor,org.apache.camel.component.file.GenericFileOperations)>(v, v);
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isDelete()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.Expression getMove()>();
if v == null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("You cannot set both delete=true and move options");
throw v;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isNoop()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isIdempotentSet()>();
if v != 0 goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Endpoint is configured with noop=true so forcing endpoint to be idempotent as well");
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: void setIdempotent(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isIdempotentSet()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: java.lang.Boolean isIdempotent()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.spi.IdempotentRepository idempotentRepository>;
if v != null goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.slf4j.Logger log>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1000);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Using default memory based idempotent repository with cache max size: {}", v);
v = staticinvoke <org.apache.camel.processor.idempotent.MemoryIdempotentRepository: org.apache.camel.spi.IdempotentRepository memoryIdempotentRepository(int)>(1000);
v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.spi.IdempotentRepository idempotentRepository> = v;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: java.lang.String getReadLock()>();
v = staticinvoke <org.apache.camel.util.ObjectHelper: boolean isNotEmpty(java.lang.Object)>(v);
if v == 0 goto label;
v = "none,markerFile,fileLock,rename,changed,idempotent,idempotent-changed,idempotent-rename";
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <org.apache.camel.component.file.FileEndpoint$lambda_createConsumer_0__148: java.util.function.Predicate bootstrap$(org.apache.camel.component.file.FileEndpoint)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: boolean anyMatch(java.util.function.Predicate)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: java.lang.String getReadLock()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, "none,markerFile,fileLock,rename,changed,idempotent,idempotent-changed,idempotent-rename") <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("ReadLock invalid: \u, must be one of: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = "fileLock";
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String readLock>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.camel.util.FileUtil: boolean isWindows()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The readLock=fileLock option is not supported on Windows");
throw v;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: int getMaxMessagesPerPoll()>();
virtualinvoke v.<org.apache.camel.component.file.FileConsumer: void setMaxMessagesPerPoll(int)>(v);
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isEagerMaxMessagesPerPoll()>();
virtualinvoke v.<org.apache.camel.component.file.FileConsumer: void setEagerLimitMaxMessagesPerPoll(boolean)>(v);
virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: void configureConsumer(org.apache.camel.Consumer)>(v);
return v;
}
public org.apache.camel.PollingConsumer createPollingConsumer() throws java.lang.Exception
{
java.lang.Object[] v;
long v, v;
java.lang.Integer v;
java.lang.Long v;
int v;
java.lang.Boolean v;
boolean v, v, v;
org.apache.camel.component.file.GenericFilePollingConsumer v;
org.slf4j.Logger v, v;
org.apache.camel.component.file.FileOperations v;
java.io.File v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "operations");
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "file");
v = v.<org.apache.camel.component.file.FileEndpoint: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: int getPollingConsumerQueueSize()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isPollingConsumerBlockWhenFull()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: long getPollingConsumerBlockTimeout()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Creating GenericFilePollingConsumer with queueSize: {} blockWhenFull: {} blockTimeout: {}", v);
label:
v = new org.apache.camel.component.file.GenericFilePollingConsumer;
specialinvoke v.<org.apache.camel.component.file.GenericFilePollingConsumer: void <init>(org.apache.camel.component.file.GenericFileEndpoint)>(v);
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean isPollingConsumerBlockWhenFull()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFilePollingConsumer: void setBlockWhenFull(boolean)>(v);
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: long getPollingConsumerBlockTimeout()>();
virtualinvoke v.<org.apache.camel.component.file.GenericFilePollingConsumer: void setBlockTimeout(long)>(v);
return v;
}
public org.apache.camel.component.file.GenericFileProducer createProducer() throws java.lang.Exception
{
org.apache.camel.Expression v, v, v;
org.apache.camel.component.file.GenericFileExist v, v, v, v, v, v;
org.apache.camel.component.file.strategy.FileMoveExistingStrategy v, v;
java.lang.String v;
org.apache.camel.component.file.FileOperations v, v;
java.lang.IllegalArgumentException v, v, v;
org.apache.camel.component.file.FileEndpoint v;
org.apache.camel.component.file.GenericFileProducer v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations>;
staticinvoke <org.apache.camel.util.ObjectHelper: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "operations");
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileExist getFileExist()>();
v = <org.apache.camel.component.file.GenericFileExist: org.apache.camel.component.file.GenericFileExist Append>;
if v != v goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: java.lang.String getTempPrefix()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.Expression getTempFileName()>();
if v == null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("You cannot set both fileExist=Append and tempPrefix/tempFileName options");
throw v;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileExist getFileExist()>();
v = <org.apache.camel.component.file.GenericFileExist: org.apache.camel.component.file.GenericFileExist Move>;
if v != v goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.Expression getMoveExisting()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("You must configure moveExisting option when fileExist=Move");
throw v;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.Expression getMoveExisting()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileExist getFileExist()>();
v = <org.apache.camel.component.file.GenericFileExist: org.apache.camel.component.file.GenericFileExist Move>;
if v == v goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("You must configure fileExist=Move when moveExisting has been set");
throw v;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.strategy.FileMoveExistingStrategy getMoveExistingFileStrategy()>();
if v != null goto label;
v = specialinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.strategy.FileMoveExistingStrategy createDefaultMoveExistingFileStrategy()>();
virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: void setMoveExistingFileStrategy(org.apache.camel.component.file.strategy.FileMoveExistingStrategy)>(v);
label:
v = new org.apache.camel.component.file.GenericFileProducer;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.FileOperations operations>;
specialinvoke v.<org.apache.camel.component.file.GenericFileProducer: void <init>(org.apache.camel.component.file.GenericFileEndpoint,org.apache.camel.component.file.GenericFileOperations)>(v, v);
return v;
}
public org.apache.camel.Exchange createExchange(org.apache.camel.component.file.GenericFile)
{
org.apache.camel.component.file.FileEndpoint v;
org.apache.camel.component.file.GenericFile v;
org.apache.camel.Exchange v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: org.apache.camel.component.file.GenericFile;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.Exchange createExchange()>();
if v == null goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: boolean probeContentType>;
virtualinvoke v.<org.apache.camel.component.file.GenericFile: void bindToExchange(org.apache.camel.Exchange,boolean)>(v, v);
label:
return v;
}
protected org.apache.camel.component.file.FileConsumer newFileConsumer(org.apache.camel.Processor, org.apache.camel.component.file.GenericFileOperations)
{
org.apache.camel.Processor v;
org.apache.camel.component.file.FileEndpoint v;
org.apache.camel.component.file.FileConsumer v;
org.apache.camel.component.file.GenericFileProcessStrategy v, v;
org.apache.camel.component.file.GenericFileOperations v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: org.apache.camel.Processor;
v := @parameter: org.apache.camel.component.file.GenericFileOperations;
v = new org.apache.camel.component.file.FileConsumer;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileProcessStrategy processStrategy>;
if v == null goto label;
v = v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileProcessStrategy processStrategy>;
goto label;
label:
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileProcessStrategy createGenericFileStrategy()>();
label:
specialinvoke v.<org.apache.camel.component.file.FileConsumer: void <init>(org.apache.camel.component.file.FileEndpoint,org.apache.camel.Processor,org.apache.camel.component.file.GenericFileOperations,org.apache.camel.component.file.GenericFileProcessStrategy)>(v, v, v, v);
return v;
}
private org.apache.camel.component.file.strategy.FileMoveExistingStrategy createDefaultMoveExistingFileStrategy()
{
org.apache.camel.component.file.FileEndpoint v;
org.apache.camel.component.file.GenericFileDefaultMoveExistingFileStrategy v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = new org.apache.camel.component.file.GenericFileDefaultMoveExistingFileStrategy;
specialinvoke v.<org.apache.camel.component.file.GenericFileDefaultMoveExistingFileStrategy: void <init>()>();
return v;
}
public java.io.File getFile()
{
org.apache.camel.component.file.FileEndpoint v;
java.io.File v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: java.io.File file>;
return v;
}
public void setFile(java.io.File)
{
org.apache.camel.component.file.FileEndpoint v;
org.apache.camel.component.file.GenericFileConfiguration v;
java.lang.String v;
java.io.File v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.io.File;
v.<org.apache.camel.component.file.FileEndpoint: java.io.File file> = v;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: org.apache.camel.component.file.GenericFileConfiguration getConfiguration()>();
v = staticinvoke <org.apache.camel.util.FileUtil: boolean isAbsolute(java.io.File)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
goto label;
label:
v = virtualinvoke v.<java.io.File: java.lang.String getPath()>();
label:
virtualinvoke v.<org.apache.camel.component.file.GenericFileConfiguration: void setDirectory(java.lang.String)>(v);
return;
}
public java.lang.String getScheme()
{
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
return "file";
}
protected java.lang.String createEndpointUri()
{
org.apache.camel.component.file.FileEndpoint v;
java.lang.String v;
java.net.URI v;
java.io.File v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: java.io.File getFile()>();
v = virtualinvoke v.<java.io.File: java.net.URI toURI()>();
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
return v;
}
public char getFileSeparator()
{
char v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = <java.io.File: char separatorChar>;
return v;
}
public boolean isAbsolute(java.lang.String)
{
org.apache.camel.component.file.FileEndpoint v;
java.lang.String v;
java.io.File v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.lang.String;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = staticinvoke <org.apache.camel.util.FileUtil: boolean isAbsolute(java.io.File)>(v);
return v;
}
public boolean isCopyAndDeleteOnRenameFail()
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: boolean copyAndDeleteOnRenameFail>;
return v;
}
public void setCopyAndDeleteOnRenameFail(boolean)
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.component.file.FileEndpoint: boolean copyAndDeleteOnRenameFail> = v;
return;
}
public boolean isRenameUsingCopy()
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: boolean renameUsingCopy>;
return v;
}
public void setRenameUsingCopy(boolean)
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.component.file.FileEndpoint: boolean renameUsingCopy> = v;
return;
}
public boolean isForceWrites()
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: boolean forceWrites>;
return v;
}
public void setForceWrites(boolean)
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.component.file.FileEndpoint: boolean forceWrites> = v;
return;
}
public boolean isProbeContentType()
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: boolean probeContentType>;
return v;
}
public void setProbeContentType(boolean)
{
org.apache.camel.component.file.FileEndpoint v;
boolean v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: boolean;
v.<org.apache.camel.component.file.FileEndpoint: boolean probeContentType> = v;
return;
}
public java.lang.String getExtendedAttributes()
{
java.lang.String v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String extendedAttributes>;
return v;
}
public void setExtendedAttributes(java.lang.String)
{
java.lang.String v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.lang.String;
v.<org.apache.camel.component.file.FileEndpoint: java.lang.String extendedAttributes> = v;
return;
}
public boolean chmodPermissionsAreValid(java.lang.String)
{
java.lang.Character v;
int v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
boolean v;
char v, v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.lang.String;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v < 3 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
if v <= 4 goto label;
label:
return 0;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 3;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = 0;
label:
v = virtualinvoke v.<java.lang.String: int length()>();
if v >= v goto label;
v = virtualinvoke v.<java.lang.String: char charAt(int)>(v);
v = staticinvoke <java.lang.Character: java.lang.Character valueOf(char)>(v);
v = virtualinvoke v.<java.lang.Character: char charValue()>();
v = staticinvoke <java.lang.Character: boolean isDigit(char)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Character: java.lang.String toString()>();
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
if v <= 7 goto label;
label:
return 0;
label:
v = v + 1;
goto label;
label:
return 1;
}
public java.util.Set getPermissions()
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v;
boolean v;
java.nio.file.attribute.PosixFilePermission v, v, v, v, v, v, v, v, v;
org.apache.camel.component.file.FileEndpoint v;
java.util.HashSet v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmod>;
v = staticinvoke <org.apache.camel.util.ObjectHelper: boolean isEmpty(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmod>;
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmod>;
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 3;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, 1);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(1, 2);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(2, 3);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OWNER_WRITE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OWNER_READ>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OWNER_EXECUTE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission GROUP_WRITE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission GROUP_READ>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission GROUP_EXECUTE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OTHERS_WRITE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OTHERS_READ>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OTHERS_EXECUTE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
return v;
}
public java.lang.String getChmod()
{
java.lang.String v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmod>;
return v;
}
public void setChmod(java.lang.String) throws java.lang.Exception
{
org.apache.camel.component.file.FileEndpoint v;
java.lang.String v, v, v;
java.lang.IllegalArgumentException v;
boolean v, v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.camel.util.ObjectHelper: boolean isNotEmpty(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean chmodPermissionsAreValid(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmod> = v;
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("chmod option [\u] is not valid");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public java.util.Set getDirectoryPermissions()
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v;
boolean v;
java.nio.file.attribute.PosixFilePermission v, v, v, v, v, v, v, v, v;
org.apache.camel.component.file.FileEndpoint v;
java.util.HashSet v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmodDirectory>;
v = staticinvoke <org.apache.camel.util.ObjectHelper: boolean isEmpty(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmodDirectory>;
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmodDirectory>;
v = virtualinvoke v.<java.lang.String: int length()>();
v = v - 3;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, 1);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(1, 2);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(2, 3);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OWNER_WRITE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OWNER_READ>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OWNER_EXECUTE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission GROUP_WRITE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission GROUP_READ>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission GROUP_EXECUTE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OTHERS_WRITE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OTHERS_READ>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = <org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v & v;
if v <= 0 goto label;
v = <java.nio.file.attribute.PosixFilePermission: java.nio.file.attribute.PosixFilePermission OTHERS_EXECUTE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
return v;
}
public java.lang.String getChmodDirectory()
{
java.lang.String v;
org.apache.camel.component.file.FileEndpoint v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v = v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmodDirectory>;
return v;
}
public void setChmodDirectory(java.lang.String) throws java.lang.Exception
{
org.apache.camel.component.file.FileEndpoint v;
java.lang.String v, v, v;
java.lang.IllegalArgumentException v;
boolean v, v;
v := @this: org.apache.camel.component.file.FileEndpoint;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.camel.util.ObjectHelper: boolean isNotEmpty(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.file.FileEndpoint: boolean chmodPermissionsAreValid(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v.<org.apache.camel.component.file.FileEndpoint: java.lang.String chmodDirectory> = v;
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("chmodDirectory option [\u] is not valid");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
static void <clinit>()
{
java.lang.Integer v, v, v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
<org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_WRITE_MASK> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
<org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_READ_MASK> = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
<org.apache.camel.component.file.FileEndpoint: java.lang.Integer CHMOD_EXECUTE_MASK> = v;
return;
}
}