public class org.apache.activemq.camel.CamelTopicSubscriber extends org.apache.activemq.camel.CamelMessageConsumer implements javax.jms.TopicSubscriber
{
public void <init>(org.apache.activemq.camel.CamelTopic, org.apache.camel.Endpoint, org.apache.activemq.ActiveMQSession, java.lang.String, java.lang.String, boolean)
{
org.apache.activemq.camel.CamelTopic v;
org.apache.activemq.camel.CamelTopicSubscriber v;
java.lang.String v, v;
org.apache.camel.Endpoint v;
org.apache.activemq.ActiveMQSession v;
boolean v;
v := @this: org.apache.activemq.camel.CamelTopicSubscriber;
v := @parameter: org.apache.activemq.camel.CamelTopic;
v := @parameter: org.apache.camel.Endpoint;
v := @parameter: org.apache.activemq.ActiveMQSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
specialinvoke v.<org.apache.activemq.camel.CamelMessageConsumer: void <init>(org.apache.activemq.camel.CamelDestination,org.apache.camel.Endpoint,org.apache.activemq.ActiveMQSession,java.lang.String,boolean)>(v, v, v, v, v);
return;
}
public javax.jms.Topic getTopic() throws javax.jms.JMSException
{
org.apache.activemq.camel.CamelDestination v;
org.apache.activemq.camel.CamelTopicSubscriber v;
v := @this: org.apache.activemq.camel.CamelTopicSubscriber;
virtualinvoke v.<org.apache.activemq.camel.CamelTopicSubscriber: void checkClosed()>();
v = specialinvoke v.<org.apache.activemq.camel.CamelMessageConsumer: org.apache.activemq.camel.CamelDestination getDestination()>();
return v;
}
public boolean getNoLocal() throws javax.jms.JMSException
{
org.apache.activemq.camel.CamelTopicSubscriber v;
boolean v;
v := @this: org.apache.activemq.camel.CamelTopicSubscriber;
virtualinvoke v.<org.apache.activemq.camel.CamelTopicSubscriber: void checkClosed()>();
v = specialinvoke v.<org.apache.activemq.camel.CamelMessageConsumer: boolean isNoLocal()>();
return v;
}
}