public class org.apache.camel.component.jms.JmsTemporaryTopicEndpoint extends org.apache.camel.component.jms.JmsEndpoint implements org.apache.camel.component.jms.DestinationEndpoint
{
private javax.jms.Destination jmsDestination;
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.JmsTemporaryTopicEndpoint v;
java.lang.String v, v;
org.apache.camel.component.jms.JmsComponent v;
v := @this: org.apache.camel.component.jms.JmsTemporaryTopicEndpoint;
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.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, 1, v);
return;
}
public void <init>(java.lang.String, java.lang.String)
{
org.apache.camel.component.jms.JmsTemporaryTopicEndpoint v;
java.lang.String v, v;
v := @this: org.apache.camel.component.jms.JmsTemporaryTopicEndpoint;
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)>(v, v);
virtualinvoke v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: void setDestinationType(java.lang.String)>("temp-topic");
return;
}
public void <init>(javax.jms.TemporaryTopic) throws javax.jms.JMSException
{
javax.jms.TemporaryTopic v;
org.apache.camel.component.jms.JmsTemporaryTopicEndpoint v;
java.lang.String v, v;
v := @this: org.apache.camel.component.jms.JmsTemporaryTopicEndpoint;
v := @parameter: javax.jms.TemporaryTopic;
v = interfaceinvoke v.<javax.jms.TemporaryTopic: java.lang.String getTopicName()>();
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:temp-topic:\u0001");
specialinvoke v.<org.apache.camel.component.jms.JmsEndpoint: void <init>(java.lang.String,java.lang.String)>(v, null);
v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: javax.jms.Destination jmsDestination> = v;
virtualinvoke v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: void setDestinationType(java.lang.String)>("temp-topic");
virtualinvoke v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: void setDestination(javax.jms.Destination)>(v);
return;
}
public boolean isSingleton()
{
org.apache.camel.component.jms.JmsTemporaryTopicEndpoint v;
v := @this: org.apache.camel.component.jms.JmsTemporaryTopicEndpoint;
return 1;
}
public synchronized javax.jms.Destination getJmsDestination(javax.jms.Session) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Destination v, v, v;
org.apache.camel.component.jms.JmsTemporaryTopicEndpoint v;
v := @this: org.apache.camel.component.jms.JmsTemporaryTopicEndpoint;
v := @parameter: javax.jms.Session;
v = v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: javax.jms.Destination jmsDestination>;
if v != null goto label;
v = virtualinvoke v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: javax.jms.Destination createJmsDestination(javax.jms.Session)>(v);
v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: javax.jms.Destination jmsDestination> = v;
label:
v = v.<org.apache.camel.component.jms.JmsTemporaryTopicEndpoint: javax.jms.Destination jmsDestination>;
return v;
}
protected javax.jms.Destination createJmsDestination(javax.jms.Session) throws javax.jms.JMSException
{
javax.jms.Session v;
org.apache.camel.component.jms.JmsTemporaryTopicEndpoint v;
javax.jms.TemporaryTopic v;
v := @this: org.apache.camel.component.jms.JmsTemporaryTopicEndpoint;
v := @parameter: javax.jms.Session;
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TemporaryTopic createTemporaryTopic()>();
return v;
}
}