public class org.apache.activemq.blob.BlobTransferPolicy extends java.lang.Object
{
private java.lang.String defaultUploadUrl;
private java.lang.String brokerUploadUrl;
private java.lang.String uploadUrl;
private int bufferSize;
private org.apache.activemq.blob.BlobUploadStrategy uploadStrategy;
private org.apache.activemq.blob.BlobDownloadStrategy downloadStrategy;
public void <init>()
{
org.apache.activemq.blob.BlobTransferPolicy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String defaultUploadUrl> = "http://localhost:8080/uploads/";
v.<org.apache.activemq.blob.BlobTransferPolicy: int bufferSize> = 131072;
return;
}
public org.apache.activemq.blob.BlobTransferPolicy copy()
{
org.apache.activemq.blob.BlobDownloadStrategy v;
int v;
org.apache.activemq.blob.BlobTransferPolicy v, v;
java.lang.String v, v, v;
org.apache.activemq.blob.BlobUploadStrategy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = new org.apache.activemq.blob.BlobTransferPolicy;
specialinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: void <init>()>();
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String defaultUploadUrl>;
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String defaultUploadUrl> = v;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String brokerUploadUrl>;
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String brokerUploadUrl> = v;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl>;
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl> = v;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: int bufferSize>;
v.<org.apache.activemq.blob.BlobTransferPolicy: int bufferSize> = v;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy uploadStrategy>;
v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy uploadStrategy> = v;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobDownloadStrategy downloadStrategy>;
v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobDownloadStrategy downloadStrategy> = v;
return v;
}
public java.lang.String getUploadUrl()
{
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String getBrokerUploadUrl()>();
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl> = v;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String getDefaultUploadUrl()>();
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl> = v;
label:
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl>;
return v;
}
public void setUploadUrl(java.lang.String)
{
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v := @parameter: java.lang.String;
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String uploadUrl> = v;
return;
}
public java.lang.String getBrokerUploadUrl()
{
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String brokerUploadUrl>;
return v;
}
public void setBrokerUploadUrl(java.lang.String)
{
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v := @parameter: java.lang.String;
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String brokerUploadUrl> = v;
return;
}
public java.lang.String getDefaultUploadUrl()
{
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String defaultUploadUrl>;
return v;
}
public void setDefaultUploadUrl(java.lang.String)
{
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v := @parameter: java.lang.String;
v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String defaultUploadUrl> = v;
return;
}
public org.apache.activemq.blob.BlobUploadStrategy getUploadStrategy()
{
org.apache.activemq.blob.BlobTransferPolicy v;
org.apache.activemq.blob.BlobUploadStrategy v, v, v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy uploadStrategy>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy createUploadStrategy()>();
v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy uploadStrategy> = v;
label:
v = v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy uploadStrategy>;
return v;
}
public org.apache.activemq.blob.BlobDownloadStrategy getDownloadStrategy()
{
org.apache.activemq.blob.BlobDownloadStrategy v, v, v;
org.apache.activemq.blob.BlobTransferPolicy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobDownloadStrategy downloadStrategy>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobDownloadStrategy createDownloadStrategy()>();
v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobDownloadStrategy downloadStrategy> = v;
label:
v = v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobDownloadStrategy downloadStrategy>;
return v;
}
public void setUploadStrategy(org.apache.activemq.blob.BlobUploadStrategy)
{
org.apache.activemq.blob.BlobTransferPolicy v;
org.apache.activemq.blob.BlobUploadStrategy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v := @parameter: org.apache.activemq.blob.BlobUploadStrategy;
v.<org.apache.activemq.blob.BlobTransferPolicy: org.apache.activemq.blob.BlobUploadStrategy uploadStrategy> = v;
return;
}
public int getBufferSize()
{
int v;
org.apache.activemq.blob.BlobTransferPolicy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v = v.<org.apache.activemq.blob.BlobTransferPolicy: int bufferSize>;
return v;
}
public void setBufferSize(int)
{
int v;
org.apache.activemq.blob.BlobTransferPolicy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
v := @parameter: int;
v.<org.apache.activemq.blob.BlobTransferPolicy: int bufferSize> = v;
return;
}
protected org.apache.activemq.blob.BlobUploadStrategy createUploadStrategy()
{
java.net.MalformedURLException v;
java.net.URL v;
java.net.URISyntaxException v;
org.apache.activemq.blob.FileSystemBlobStrategy v;
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v, v, v;
org.apache.activemq.blob.FTPBlobUploadStrategy v;
org.apache.activemq.blob.DefaultBlobUploadStrategy v, v, v;
boolean v, v;
org.apache.activemq.blob.BlobUploadStrategy v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
label:
v = new java.net.URL;
v = virtualinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String getUploadUrl()>();
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("FTP");
if v == 0 goto label;
v = new org.apache.activemq.blob.FTPBlobUploadStrategy;
specialinvoke v.<org.apache.activemq.blob.FTPBlobUploadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
goto label;
label:
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("FILE");
if v == 0 goto label;
v = new org.apache.activemq.blob.FileSystemBlobStrategy;
specialinvoke v.<org.apache.activemq.blob.FileSystemBlobStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
goto label;
label:
v = new org.apache.activemq.blob.DefaultBlobUploadStrategy;
specialinvoke v.<org.apache.activemq.blob.DefaultBlobUploadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.activemq.blob.DefaultBlobUploadStrategy;
specialinvoke v.<org.apache.activemq.blob.DefaultBlobUploadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
goto label;
label:
v := @caughtexception;
v = new org.apache.activemq.blob.DefaultBlobUploadStrategy;
specialinvoke v.<org.apache.activemq.blob.DefaultBlobUploadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
label:
return v;
catch java.net.MalformedURLException from label to label with label;
catch java.net.URISyntaxException from label to label with label;
}
protected org.apache.activemq.blob.BlobDownloadStrategy createDownloadStrategy()
{
java.net.MalformedURLException v;
java.net.URL v;
org.apache.activemq.blob.BlobDownloadStrategy v;
java.net.URISyntaxException v;
org.apache.activemq.blob.DefaultBlobDownloadStrategy v, v, v;
org.apache.activemq.blob.FileSystemBlobStrategy v;
org.apache.activemq.blob.FTPBlobDownloadStrategy v;
org.apache.activemq.blob.BlobTransferPolicy v;
java.lang.String v, v, v;
boolean v, v;
v := @this: org.apache.activemq.blob.BlobTransferPolicy;
label:
v = new java.net.URL;
v = virtualinvoke v.<org.apache.activemq.blob.BlobTransferPolicy: java.lang.String getUploadUrl()>();
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("FTP");
if v == 0 goto label;
v = new org.apache.activemq.blob.FTPBlobDownloadStrategy;
specialinvoke v.<org.apache.activemq.blob.FTPBlobDownloadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
goto label;
label:
v = virtualinvoke v.<java.net.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("FILE");
if v == 0 goto label;
v = new org.apache.activemq.blob.FileSystemBlobStrategy;
specialinvoke v.<org.apache.activemq.blob.FileSystemBlobStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
goto label;
label:
v = new org.apache.activemq.blob.DefaultBlobDownloadStrategy;
specialinvoke v.<org.apache.activemq.blob.DefaultBlobDownloadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.activemq.blob.DefaultBlobDownloadStrategy;
specialinvoke v.<org.apache.activemq.blob.DefaultBlobDownloadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
goto label;
label:
v := @caughtexception;
v = new org.apache.activemq.blob.DefaultBlobDownloadStrategy;
specialinvoke v.<org.apache.activemq.blob.DefaultBlobDownloadStrategy: void <init>(org.apache.activemq.blob.BlobTransferPolicy)>(v);
v = v;
label:
return v;
catch java.net.MalformedURLException from label to label with label;
catch java.net.URISyntaxException from label to label with label;
}
}