public class org.apache.activemq.camel.CamelTopic extends org.apache.activemq.camel.CamelDestination implements javax.jms.Topic
{
public void <init>(java.lang.String)
{
org.apache.activemq.camel.CamelTopic v;
java.lang.String v;
v := @this: org.apache.activemq.camel.CamelTopic;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.activemq.camel.CamelDestination: void <init>(java.lang.String)>(v);
return;
}
public java.lang.String getTopicName() throws javax.jms.JMSException
{
org.apache.activemq.camel.CamelTopic v;
java.lang.String v;
v := @this: org.apache.activemq.camel.CamelTopic;
v = virtualinvoke v.<org.apache.activemq.camel.CamelTopic: java.lang.String getUri()>();
return v;
}
public javax.jms.TopicPublisher createPublisher(org.apache.activemq.ActiveMQSession) throws javax.jms.JMSException
{
org.apache.activemq.camel.CamelTopic v;
org.apache.activemq.camel.CamelTopicPublisher v;
org.apache.camel.Endpoint v;
org.apache.activemq.ActiveMQSession v;
v := @this: org.apache.activemq.camel.CamelTopic;
v := @parameter: org.apache.activemq.ActiveMQSession;
v = new org.apache.activemq.camel.CamelTopicPublisher;
v = virtualinvoke v.<org.apache.activemq.camel.CamelTopic: org.apache.camel.Endpoint resolveEndpoint(org.apache.activemq.ActiveMQSession)>(v);
specialinvoke v.<org.apache.activemq.camel.CamelTopicPublisher: void <init>(org.apache.activemq.camel.CamelTopic,org.apache.camel.Endpoint,org.apache.activemq.ActiveMQSession)>(v, v, v);
return v;
}
public javax.jms.TopicSubscriber createDurableSubscriber(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.CamelTopic;
v := @parameter: org.apache.activemq.ActiveMQSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = new org.apache.activemq.camel.CamelTopicSubscriber;
v = virtualinvoke v.<org.apache.activemq.camel.CamelTopic: org.apache.camel.Endpoint resolveEndpoint(org.apache.activemq.ActiveMQSession)>(v);
specialinvoke v.<org.apache.activemq.camel.CamelTopicSubscriber: void <init>(org.apache.activemq.camel.CamelTopic,org.apache.camel.Endpoint,org.apache.activemq.ActiveMQSession,java.lang.String,java.lang.String,boolean)>(v, v, v, v, v, v);
return v;
}
}