public class org.apache.activemq.ActiveMQTopicSession extends java.lang.Object implements javax.jms.TopicSession
{
private final javax.jms.TopicSession next;
public void <init>(javax.jms.TopicSession)
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.TopicSession;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next> = v;
return;
}
public void close() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void close()>();
return;
}
public void commit() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void commit()>();
return;
}
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue) throws javax.jms.JMSException
{
javax.jms.Queue v;
javax.jms.IllegalStateException v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Queue;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("Operation not supported by a TopicSession");
throw v;
}
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Queue v;
java.lang.String v;
javax.jms.IllegalStateException v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Queue;
v := @parameter: java.lang.String;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("Operation not supported by a TopicSession");
throw v;
}
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.BytesMessage v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.BytesMessage createBytesMessage()>();
return v;
}
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.MessageConsumer v;
javax.jms.Destination v;
javax.jms.InvalidDestinationException v;
javax.jms.TopicSession v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Destination;
v = v instanceof javax.jms.Queue;
if v == 0 goto label;
v = new javax.jms.InvalidDestinationException;
specialinvoke v.<javax.jms.InvalidDestinationException: void <init>(java.lang.String)>("Queues are not supported by a TopicSession");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.MessageConsumer createConsumer(javax.jms.Destination)>(v);
return v;
}
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination, java.lang.String) throws javax.jms.JMSException
{
javax.jms.MessageConsumer v;
javax.jms.Destination v;
javax.jms.InvalidDestinationException v;
javax.jms.TopicSession v;
java.lang.String v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Destination;
v := @parameter: java.lang.String;
v = v instanceof javax.jms.Queue;
if v == 0 goto label;
v = new javax.jms.InvalidDestinationException;
specialinvoke v.<javax.jms.InvalidDestinationException: void <init>(java.lang.String)>("Queues are not supported by a TopicSession");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.MessageConsumer createConsumer(javax.jms.Destination,java.lang.String)>(v, v);
return v;
}
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination, java.lang.String, boolean) throws javax.jms.JMSException
{
javax.jms.MessageConsumer v;
javax.jms.Destination v;
javax.jms.InvalidDestinationException v;
javax.jms.TopicSession v;
java.lang.String v;
boolean v, v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Destination;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v instanceof javax.jms.Queue;
if v == 0 goto label;
v = new javax.jms.InvalidDestinationException;
specialinvoke v.<javax.jms.InvalidDestinationException: void <init>(java.lang.String)>("Queues are not supported by a TopicSession");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.MessageConsumer createConsumer(javax.jms.Destination,java.lang.String,boolean)>(v, v, v);
return v;
}
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Topic v;
javax.jms.TopicSession v;
java.lang.String v;
javax.jms.TopicSubscriber v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic,java.lang.String)>(v, v);
return v;
}
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic, java.lang.String, java.lang.String, boolean) throws javax.jms.JMSException
{
javax.jms.Topic v;
javax.jms.TopicSession v;
java.lang.String v, v;
javax.jms.TopicSubscriber v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic,java.lang.String,java.lang.String,boolean)>(v, v, v, v);
return v;
}
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
{
javax.jms.MapMessage v;
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.MapMessage createMapMessage()>();
return v;
}
public javax.jms.Message createMessage() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.Message v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.Message createMessage()>();
return v;
}
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
{
javax.jms.ObjectMessage v;
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.ObjectMessage createObjectMessage()>();
return v;
}
public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable) throws javax.jms.JMSException
{
javax.jms.ObjectMessage v;
javax.jms.TopicSession v;
java.io.Serializable v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: java.io.Serializable;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.ObjectMessage createObjectMessage(java.io.Serializable)>(v);
return v;
}
public javax.jms.MessageProducer createProducer(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
javax.jms.InvalidDestinationException v;
javax.jms.TopicSession v;
javax.jms.MessageProducer v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Destination;
v = v instanceof javax.jms.Queue;
if v == 0 goto label;
v = new javax.jms.InvalidDestinationException;
specialinvoke v.<javax.jms.InvalidDestinationException: void <init>(java.lang.String)>("Queues are not supported by a TopicSession");
throw v;
label:
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.MessageProducer createProducer(javax.jms.Destination)>(v);
return v;
}
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic) throws javax.jms.JMSException
{
javax.jms.Topic v;
javax.jms.TopicSession v;
javax.jms.TopicPublisher v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Topic;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicPublisher createPublisher(javax.jms.Topic)>(v);
return v;
}
public javax.jms.Queue createQueue(java.lang.String) throws javax.jms.JMSException
{
java.lang.String v;
javax.jms.IllegalStateException v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: java.lang.String;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("Operation not supported by a TopicSession");
throw v;
}
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.StreamMessage v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.StreamMessage createStreamMessage()>();
return v;
}
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic) throws javax.jms.JMSException
{
javax.jms.Topic v;
javax.jms.TopicSession v;
javax.jms.TopicSubscriber v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Topic;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic)>(v);
return v;
}
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic, java.lang.String, boolean) throws javax.jms.JMSException
{
javax.jms.Topic v;
javax.jms.TopicSession v;
java.lang.String v;
javax.jms.TopicSubscriber v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.Topic;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic,java.lang.String,boolean)>(v, v, v);
return v;
}
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
{
javax.jms.IllegalStateException v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = new javax.jms.IllegalStateException;
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>("Operation not supported by a TopicSession");
throw v;
}
public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.TemporaryTopic v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TemporaryTopic createTemporaryTopic()>();
return v;
}
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.TextMessage v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TextMessage createTextMessage()>();
return v;
}
public javax.jms.TextMessage createTextMessage(java.lang.String) throws javax.jms.JMSException
{
javax.jms.TextMessage v;
javax.jms.TopicSession v;
java.lang.String v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.TextMessage createTextMessage(java.lang.String)>(v);
return v;
}
public javax.jms.Topic createTopic(java.lang.String) throws javax.jms.JMSException
{
javax.jms.Topic v;
javax.jms.TopicSession v;
java.lang.String v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.Topic createTopic(java.lang.String)>(v);
return v;
}
public boolean equals(java.lang.Object)
{
java.lang.Object v;
javax.jms.TopicSession v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: java.lang.Object;
if v == v goto label;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
return v;
label:
return 1;
}
public int getAcknowledgeMode() throws javax.jms.JMSException
{
int v;
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: int getAcknowledgeMode()>();
return v;
}
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.MessageListener v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: javax.jms.MessageListener getMessageListener()>();
return v;
}
public boolean getTransacted() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
boolean v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = interfaceinvoke v.<javax.jms.TopicSession: boolean getTransacted()>();
return v;
}
public int hashCode()
{
int v;
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
return v;
}
public void recover() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void recover()>();
return;
}
public void rollback() throws javax.jms.JMSException
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void rollback()>();
return;
}
public void run()
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void run()>();
return;
}
public void setMessageListener(javax.jms.MessageListener) throws javax.jms.JMSException
{
javax.jms.TopicSession v;
javax.jms.MessageListener v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: javax.jms.MessageListener;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void setMessageListener(javax.jms.MessageListener)>(v);
return;
}
public java.lang.String toString()
{
javax.jms.TopicSession v;
java.lang.String v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
return v;
}
public void unsubscribe(java.lang.String) throws javax.jms.JMSException
{
javax.jms.TopicSession v;
java.lang.String v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
interfaceinvoke v.<javax.jms.TopicSession: void unsubscribe(java.lang.String)>(v);
return;
}
public javax.jms.TopicSession getNext()
{
javax.jms.TopicSession v;
org.apache.activemq.ActiveMQTopicSession v;
v := @this: org.apache.activemq.ActiveMQTopicSession;
v = v.<org.apache.activemq.ActiveMQTopicSession: javax.jms.TopicSession next>;
return v;
}
}