public class org.apache.camel.component.jms.JmsQueueEndpoint extends org.apache.camel.component.jms.JmsEndpoint implements org.apache.camel.spi.BrowsableEndpoint
{
private int maximumBrowseSize;
private final org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy;
public void <init>(javax.jms.Queue) throws javax.jms.JMSException
{
javax.jms.Queue v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
java.lang.String v, v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v := @parameter: javax.jms.Queue;
v = interfaceinvoke v.<javax.jms.Queue: java.lang.String getQueueName()>();
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[])>("jms:queue:\u0001");
specialinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void <init>(java.lang.String,java.lang.String)>(v, null);
virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void setDestinationType(java.lang.String)>("queue");
virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void setDestination(javax.jms.Destination)>(v);
return;
}
public void <init>(java.lang.String, org.apache.camel.component.jms.JmsComponent, java.lang.String, org.apache.camel.component.jms.JmsConfiguration)
{
org.apache.camel.component.jms.JmsConfiguration v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
java.lang.String v, v;
org.apache.camel.component.jms.JmsComponent v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.jms.JmsComponent;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.jms.JmsConfiguration;
specialinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void <init>(java.lang.String,org.apache.camel.component.jms.JmsComponent,java.lang.String,org.apache.camel.component.jms.JmsConfiguration,org.apache.camel.component.jms.QueueBrowseStrategy)>(v, v, v, v, null);
virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void setDestinationType(java.lang.String)>("queue");
return;
}
public void <init>(java.lang.String, org.apache.camel.component.jms.JmsComponent, java.lang.String, org.apache.camel.component.jms.JmsConfiguration, org.apache.camel.component.jms.QueueBrowseStrategy)
{
org.apache.camel.component.jms.JmsConfiguration v;
org.apache.camel.component.jms.QueueBrowseStrategy v, v;
org.apache.camel.component.jms.JmsComponent v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
int v;
java.lang.String v, v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.jms.JmsComponent;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.jms.JmsConfiguration;
v := @parameter: org.apache.camel.component.jms.QueueBrowseStrategy;
specialinvoke v.<org.apache.camel.component.jms.JmsEndpoint: void <init>(java.lang.String,org.apache.camel.component.jms.JmsComponent,java.lang.String,boolean,org.apache.camel.component.jms.JmsConfiguration)>(v, v, v, 0, v);
v = (int) -1;
v.<org.apache.camel.component.jms.JmsQueueEndpoint: int maximumBrowseSize> = v;
virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void setDestinationType(java.lang.String)>("queue");
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy createQueueBrowseStrategy()>();
v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy> = v;
goto label;
label:
v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy> = v;
label:
return;
}
public void <init>(java.lang.String, java.lang.String, org.apache.camel.component.jms.QueueBrowseStrategy)
{
org.apache.camel.component.jms.JmsQueueEndpoint v;
int v;
org.apache.camel.component.jms.QueueBrowseStrategy v, v;
java.lang.String v, v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.camel.component.jms.QueueBrowseStrategy;
specialinvoke v.<org.apache.camel.component.jms.JmsEndpoint: void <init>(java.lang.String,java.lang.String,boolean)>(v, v, 0);
v = (int) -1;
v.<org.apache.camel.component.jms.JmsQueueEndpoint: int maximumBrowseSize> = v;
virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void setDestinationType(java.lang.String)>("queue");
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy createQueueBrowseStrategy()>();
v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy> = v;
goto label;
label:
v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy> = v;
label:
return;
}
public void <init>(java.lang.String, java.lang.String)
{
org.apache.camel.component.jms.JmsQueueEndpoint v;
int v;
org.apache.camel.component.jms.QueueBrowseStrategy v;
java.lang.String v, v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.camel.component.jms.JmsEndpoint: void <init>(java.lang.String,java.lang.String,boolean)>(v, v, 0);
v = (int) -1;
v.<org.apache.camel.component.jms.JmsQueueEndpoint: int maximumBrowseSize> = v;
virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: void setDestinationType(java.lang.String)>("queue");
v = virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy createQueueBrowseStrategy()>();
v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy> = v;
return;
}
public int getMaximumBrowseSize()
{
int v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v = v.<org.apache.camel.component.jms.JmsQueueEndpoint: int maximumBrowseSize>;
return v;
}
public void setMaximumBrowseSize(int)
{
int v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v := @parameter: int;
v.<org.apache.camel.component.jms.JmsQueueEndpoint: int maximumBrowseSize> = v;
return;
}
public java.util.List getExchanges()
{
org.springframework.jms.core.JmsOperations v;
org.apache.camel.component.jms.JmsConfiguration v;
org.apache.camel.component.jms.QueueBrowseStrategy v, v;
java.util.List v, v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
java.lang.String v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v = v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy>;
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
label:
v = virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: java.lang.String getDestinationName()>();
v = virtualinvoke v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.JmsConfiguration getConfiguration()>();
v = virtualinvoke v.<org.apache.camel.component.jms.JmsConfiguration: org.springframework.jms.core.JmsOperations createInOnlyTemplate(org.apache.camel.component.jms.JmsEndpoint,boolean,java.lang.String)>(v, 0, v);
v = v.<org.apache.camel.component.jms.JmsQueueEndpoint: org.apache.camel.component.jms.QueueBrowseStrategy queueBrowseStrategy>;
v = interfaceinvoke v.<org.apache.camel.component.jms.QueueBrowseStrategy: java.util.List browse(org.springframework.jms.core.JmsOperations,java.lang.String,org.apache.camel.component.jms.JmsQueueEndpoint)>(v, v, v);
return v;
}
protected org.apache.camel.component.jms.QueueBrowseStrategy createQueueBrowseStrategy()
{
org.apache.camel.component.jms.DefaultQueueBrowseStrategy v;
org.apache.camel.component.jms.JmsQueueEndpoint v;
v := @this: org.apache.camel.component.jms.JmsQueueEndpoint;
v = new org.apache.camel.component.jms.DefaultQueueBrowseStrategy;
specialinvoke v.<org.apache.camel.component.jms.DefaultQueueBrowseStrategy: void <init>()>();
return v;
}
}