public class org.apache.activemq.command.ActiveMQBlobMessage extends org.apache.activemq.command.ActiveMQMessage implements org.apache.activemq.BlobMessage
{
public static final byte DATA_STRUCTURE_TYPE;
public static final java.lang.String BINARY_MIME_TYPE;
private java.lang.String remoteBlobUrl;
private java.lang.String mimeType;
private java.lang.String name;
private boolean deletedByBroker;
private transient org.apache.activemq.blob.BlobUploader blobUploader;
private transient org.apache.activemq.blob.BlobDownloader blobDownloader;
private transient java.net.URL url;
public void <init>()
{
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage: void <init>()>();
return;
}
public org.apache.activemq.command.Message copy()
{
org.apache.activemq.command.ActiveMQBlobMessage v, v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = new org.apache.activemq.command.ActiveMQBlobMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void <init>()>();
specialinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void copy(org.apache.activemq.command.ActiveMQBlobMessage)>(v);
return v;
}
private void copy(org.apache.activemq.command.ActiveMQBlobMessage)
{
org.apache.activemq.blob.BlobUploader v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQBlobMessage v, v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: org.apache.activemq.command.ActiveMQBlobMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage: void copy(org.apache.activemq.command.ActiveMQMessage)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String getRemoteBlobUrl()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setRemoteBlobUrl(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String getMimeType()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setMimeType(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: boolean isDeletedByBroker()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setDeletedByBroker(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobUploader getBlobUploader()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setBlobUploader(org.apache.activemq.blob.BlobUploader)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String getName()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setName(java.lang.String)>(v);
return;
}
public byte getDataStructureType()
{
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
return 29;
}
public java.lang.String getRemoteBlobUrl()
{
java.lang.String v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String remoteBlobUrl>;
return v;
}
public void setRemoteBlobUrl(java.lang.String)
{
java.lang.String v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String remoteBlobUrl> = v;
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.net.URL url> = null;
return;
}
public java.lang.String getMimeType()
{
java.lang.String v, v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String mimeType>;
if v != null goto label;
return "application/octet-stream";
label:
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String mimeType>;
return v;
}
public void setMimeType(java.lang.String)
{
java.lang.String v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String mimeType> = v;
return;
}
public java.lang.String getName()
{
java.lang.String v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String name>;
return v;
}
public void setName(java.lang.String)
{
java.lang.String v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String name> = v;
return;
}
public boolean isDeletedByBroker()
{
org.apache.activemq.command.ActiveMQBlobMessage v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: boolean deletedByBroker>;
return v;
}
public void setDeletedByBroker(boolean)
{
org.apache.activemq.command.ActiveMQBlobMessage v;
boolean v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: boolean;
v.<org.apache.activemq.command.ActiveMQBlobMessage: boolean deletedByBroker> = v;
return;
}
public java.lang.String getJMSXMimeType()
{
java.lang.String v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String getMimeType()>();
return v;
}
public java.io.InputStream getInputStream() throws java.io.IOException, javax.jms.JMSException
{
org.apache.activemq.blob.BlobDownloader v, v;
org.apache.activemq.command.ActiveMQBlobMessage v;
java.io.InputStream v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobDownloader blobDownloader>;
if v != null goto label;
return null;
label:
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobDownloader blobDownloader>;
v = virtualinvoke v.<org.apache.activemq.blob.BlobDownloader: java.io.InputStream getInputStream(org.apache.activemq.command.ActiveMQBlobMessage)>(v);
return v;
}
public java.net.URL getURL() throws javax.jms.JMSException
{
java.net.MalformedURLException v;
java.net.URL v, v, v;
javax.jms.JMSException v;
org.apache.activemq.command.ActiveMQBlobMessage v;
java.lang.String v, v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.net.URL url>;
if v != null goto label;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String remoteBlobUrl>;
if v == null goto label;
label:
v = new java.net.URL;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String remoteBlobUrl>;
specialinvoke v.<java.net.URL: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.net.URL url> = v;
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
label:
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: java.net.URL url>;
return v;
catch java.net.MalformedURLException from label to label with label;
}
public void setURL(java.net.URL)
{
java.lang.String v;
java.net.URL v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: java.net.URL;
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.net.URL url> = v;
if v == null goto label;
v = virtualinvoke v.<java.net.URL: java.lang.String toExternalForm()>();
goto label;
label:
v = null;
label:
v.<org.apache.activemq.command.ActiveMQBlobMessage: java.lang.String remoteBlobUrl> = v;
return;
}
public org.apache.activemq.blob.BlobUploader getBlobUploader()
{
org.apache.activemq.blob.BlobUploader v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobUploader blobUploader>;
return v;
}
public void setBlobUploader(org.apache.activemq.blob.BlobUploader)
{
org.apache.activemq.blob.BlobUploader v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: org.apache.activemq.blob.BlobUploader;
v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobUploader blobUploader> = v;
return;
}
public org.apache.activemq.blob.BlobDownloader getBlobDownloader()
{
org.apache.activemq.blob.BlobDownloader v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobDownloader blobDownloader>;
return v;
}
public void setBlobDownloader(org.apache.activemq.blob.BlobDownloader)
{
org.apache.activemq.blob.BlobDownloader v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v := @parameter: org.apache.activemq.blob.BlobDownloader;
v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobDownloader blobDownloader> = v;
return;
}
public void onSend() throws javax.jms.JMSException
{
java.net.URL v;
org.apache.activemq.blob.BlobUploader v, v;
java.io.IOException v;
javax.jms.JMSException v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
specialinvoke v.<org.apache.activemq.command.ActiveMQMessage: void onSend()>();
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobUploader blobUploader>;
if v == null goto label;
label:
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobUploader blobUploader>;
v = virtualinvoke v.<org.apache.activemq.blob.BlobUploader: java.net.URL upload(org.apache.activemq.command.ActiveMQBlobMessage)>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQBlobMessage: void setURL(java.net.URL)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.JMSExceptionSupport: javax.jms.JMSException create(java.lang.Exception)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public void deleteFile() throws java.io.IOException, javax.jms.JMSException
{
org.apache.activemq.blob.BlobDownloader v;
org.apache.activemq.command.ActiveMQBlobMessage v;
v := @this: org.apache.activemq.command.ActiveMQBlobMessage;
v = v.<org.apache.activemq.command.ActiveMQBlobMessage: org.apache.activemq.blob.BlobDownloader blobDownloader>;
virtualinvoke v.<org.apache.activemq.blob.BlobDownloader: void deleteFile(org.apache.activemq.command.ActiveMQBlobMessage)>(v);
return;
}
}