public abstract class org.apache.camel.component.dataset.DataSetSupport extends java.lang.Object implements org.apache.camel.component.dataset.DataSet
{
private java.util.Map defaultHeaders;
private org.apache.camel.Processor outputTransformer;
private long size;
private long reportCount;
public void <init>()
{
org.apache.camel.component.dataset.DataSetSupport v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.component.dataset.DataSetSupport: long size> = 10L;
v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount> = -1L;
return;
}
public void <init>(int)
{
int v;
org.apache.camel.component.dataset.DataSetSupport v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.component.dataset.DataSetSupport: long size> = 10L;
v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount> = -1L;
virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: void setSize(long)>(v);
return;
}
public void populateMessage(org.apache.camel.Exchange, long) throws java.lang.Exception
{
org.apache.camel.Message v;
org.apache.camel.component.dataset.DataSetSupport v;
long v;
org.apache.camel.Exchange v;
org.apache.camel.Processor v, v;
java.util.Map v;
java.lang.Object v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: long;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: java.lang.Object createMessageBody(long)>(v);
interfaceinvoke v.<org.apache.camel.Message: void setBody(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: java.util.Map getDefaultHeaders()>();
interfaceinvoke v.<org.apache.camel.Message: void setHeaders(java.util.Map)>(v);
virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: void applyHeaders(org.apache.camel.Exchange,long)>(v, v);
v = v.<org.apache.camel.component.dataset.DataSetSupport: org.apache.camel.Processor outputTransformer>;
if v == null goto label;
v = v.<org.apache.camel.component.dataset.DataSetSupport: org.apache.camel.Processor outputTransformer>;
interfaceinvoke v.<org.apache.camel.Processor: void process(org.apache.camel.Exchange)>(v);
label:
return;
}
public void assertMessageExpected(org.apache.camel.component.dataset.DataSetEndpoint, org.apache.camel.Exchange, org.apache.camel.Exchange, long) throws java.lang.Exception
{
org.apache.camel.Message v, v, v;
org.apache.camel.component.dataset.DataSetSupport v;
long v;
org.apache.camel.Exchange v, v;
org.apache.camel.component.dataset.DataSetEndpoint v;
java.lang.Class v;
java.lang.Object v, v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: org.apache.camel.component.dataset.DataSetEndpoint;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: long;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.Object getBody()>();
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.Object getBody()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.camel.Exchange: org.apache.camel.Message getIn()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = interfaceinvoke v.<org.apache.camel.Message: java.lang.Object getMandatoryBody(java.lang.Class)>(v);
label:
staticinvoke <org.apache.camel.component.dataset.DataSetEndpoint: void assertEquals(java.lang.String,java.lang.Object,java.lang.Object,org.apache.camel.Exchange)>("message body", v, v, v);
return;
}
public long getSize()
{
org.apache.camel.component.dataset.DataSetSupport v;
long v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v = v.<org.apache.camel.component.dataset.DataSetSupport: long size>;
return v;
}
public void setSize(long)
{
org.apache.camel.component.dataset.DataSetSupport v;
long v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: long;
v.<org.apache.camel.component.dataset.DataSetSupport: long size> = v;
return;
}
public long getReportCount()
{
org.apache.camel.component.dataset.DataSetSupport v;
long v, v, v, v, v, v;
byte v, v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v = v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount>;
v = v cmp 0L;
if v > 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: long getSize()>();
v = v / 5L;
v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount> = v;
label:
v = v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount>;
v = v cmp 0L;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: long getSize()>();
v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount> = v;
label:
v = v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount>;
return v;
}
public void setReportCount(long)
{
org.apache.camel.component.dataset.DataSetSupport v;
long v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: long;
v.<org.apache.camel.component.dataset.DataSetSupport: long reportCount> = v;
return;
}
public java.util.Map getDefaultHeaders()
{
java.util.Map v, v, v;
org.apache.camel.component.dataset.DataSetSupport v;
java.util.HashMap v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v = v.<org.apache.camel.component.dataset.DataSetSupport: java.util.Map defaultHeaders>;
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.camel.component.dataset.DataSetSupport: java.util.Map defaultHeaders> = v;
v = v.<org.apache.camel.component.dataset.DataSetSupport: java.util.Map defaultHeaders>;
virtualinvoke v.<org.apache.camel.component.dataset.DataSetSupport: void populateDefaultHeaders(java.util.Map)>(v);
label:
v = v.<org.apache.camel.component.dataset.DataSetSupport: java.util.Map defaultHeaders>;
return v;
}
public void setDefaultHeaders(java.util.Map)
{
org.apache.camel.component.dataset.DataSetSupport v;
java.util.Map v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: java.util.Map;
v.<org.apache.camel.component.dataset.DataSetSupport: java.util.Map defaultHeaders> = v;
return;
}
public org.apache.camel.Processor getOutputTransformer()
{
org.apache.camel.component.dataset.DataSetSupport v;
org.apache.camel.Processor v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v = v.<org.apache.camel.component.dataset.DataSetSupport: org.apache.camel.Processor outputTransformer>;
return v;
}
public void setOutputTransformer(org.apache.camel.Processor)
{
org.apache.camel.component.dataset.DataSetSupport v;
org.apache.camel.Processor v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: org.apache.camel.Processor;
v.<org.apache.camel.component.dataset.DataSetSupport: org.apache.camel.Processor outputTransformer> = v;
return;
}
protected abstract java.lang.Object createMessageBody(long);
protected void applyHeaders(org.apache.camel.Exchange, long)
{
org.apache.camel.component.dataset.DataSetSupport v;
long v;
org.apache.camel.Exchange v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: long;
return;
}
protected void populateDefaultHeaders(java.util.Map)
{
org.apache.camel.component.dataset.DataSetSupport v;
java.util.Map v;
v := @this: org.apache.camel.component.dataset.DataSetSupport;
v := @parameter: java.util.Map;
return;
}
}