public class org.apache.activemq.broker.region.TempTopic extends org.apache.activemq.broker.region.Topic implements org.apache.activemq.thread.Task
{
private final org.apache.activemq.command.ActiveMQTempDestination tempDest;
public void <init>(org.apache.activemq.broker.BrokerService, org.apache.activemq.command.ActiveMQDestination, org.apache.activemq.store.TopicMessageStore, org.apache.activemq.broker.region.DestinationStatistics, org.apache.activemq.thread.TaskRunnerFactory) throws java.lang.Exception
{
org.apache.activemq.broker.region.TempTopic v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.TopicMessageStore v;
org.apache.activemq.thread.TaskRunnerFactory v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.region.TempTopic;
v := @parameter: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: org.apache.activemq.store.TopicMessageStore;
v := @parameter: org.apache.activemq.broker.region.DestinationStatistics;
v := @parameter: org.apache.activemq.thread.TaskRunnerFactory;
specialinvoke v.<org.apache.activemq.broker.region.Topic: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.command.ActiveMQDestination,org.apache.activemq.store.TopicMessageStore,org.apache.activemq.broker.region.DestinationStatistics,org.apache.activemq.thread.TaskRunnerFactory)>(v, v, v, v, v);
v.<org.apache.activemq.broker.region.TempTopic: org.apache.activemq.command.ActiveMQTempDestination tempDest> = v;
return;
}
public void addSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription) throws java.lang.Exception
{
org.apache.activemq.broker.region.TempTopic v;
org.apache.activemq.broker.region.Subscription v;
org.apache.activemq.command.ActiveMQTempDestination v, v, v;
org.apache.activemq.command.ConsumerId v, v;
org.apache.activemq.broker.ConnectionContext v;
java.lang.String v, v, v, v, v;
org.apache.activemq.command.ConsumerInfo v, v;
boolean v, v, v, v;
org.slf4j.Logger v, v;
v := @this: org.apache.activemq.broker.region.TempTopic;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.broker.region.Subscription;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: boolean isFaultTolerant()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: boolean isNetworkConnection()>();
if v != 0 goto label;
v = v.<org.apache.activemq.broker.region.TempTopic: org.apache.activemq.command.ActiveMQTempDestination tempDest>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTempDestination: java.lang.String getConnectionId()>();
v = interfaceinvoke v.<org.apache.activemq.broker.region.Subscription: org.apache.activemq.command.ConsumerInfo getConsumerInfo()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: java.lang.String getConnectionId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.activemq.broker.region.TempTopic: org.apache.activemq.command.ActiveMQTempDestination tempDest>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Subscription: org.apache.activemq.command.ConsumerInfo getConsumerInfo()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: java.lang.String getConnectionId()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQTempDestination: void setConnectionId(java.lang.String)>(v);
v = <org.apache.activemq.broker.region.TempTopic: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.activemq.broker.region.TempTopic: org.slf4j.Logger LOG>;
v = v.<org.apache.activemq.broker.region.TempTopic: org.apache.activemq.command.ActiveMQTempDestination tempDest>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTempDestination: java.lang.String getConnectionId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.broker.region.TempTopic,java.lang.String)>(v, 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[])>(" changed ownership of \u to \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
specialinvoke v.<org.apache.activemq.broker.region.Topic: void addSubscription(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.broker.region.Subscription)>(v, v);
return;
}
public void initialize()
{
org.apache.activemq.broker.region.TempTopic v;
v := @this: org.apache.activemq.broker.region.TempTopic;
return;
}
}