public final class org.apache.activemq.advisory.AdvisorySupport extends java.lang.Object
{
public static final java.lang.String ADVISORY_TOPIC_PREFIX;
public static final org.apache.activemq.command.ActiveMQTopic CONNECTION_ADVISORY_TOPIC;
public static final org.apache.activemq.command.ActiveMQTopic QUEUE_ADVISORY_TOPIC;
public static final org.apache.activemq.command.ActiveMQTopic TOPIC_ADVISORY_TOPIC;
public static final org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC;
public static final org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC;
public static final java.lang.String PRODUCER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String QUEUE_PRODUCER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String TOPIC_PRODUCER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String ANONYMOUS_PRODUCER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String CONSUMER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String QUEUE_CONSUMER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String TOPIC_CONSUMER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String QUEUE_VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String TOPIC_VIRTUAL_DESTINATION_CONSUMER_ADVISORY_TOPIC_PREFIX;
public static final java.lang.String EXPIRED_TOPIC_MESSAGES_TOPIC_PREFIX;
public static final java.lang.String EXPIRED_QUEUE_MESSAGES_TOPIC_PREFIX;
public static final java.lang.String NO_TOPIC_CONSUMERS_TOPIC_PREFIX;
public static final java.lang.String NO_QUEUE_CONSUMERS_TOPIC_PREFIX;
public static final java.lang.String SLOW_CONSUMER_TOPIC_PREFIX;
public static final java.lang.String FAST_PRODUCER_TOPIC_PREFIX;
public static final java.lang.String MESSAGE_DISCAREDED_TOPIC_PREFIX;
public static final java.lang.String FULL_TOPIC_PREFIX;
public static final java.lang.String MESSAGE_DELIVERED_TOPIC_PREFIX;
public static final java.lang.String MESSAGE_CONSUMED_TOPIC_PREFIX;
public static final java.lang.String MESSAGE_DLQ_TOPIC_PREFIX;
public static final java.lang.String MASTER_BROKER_TOPIC_PREFIX;
public static final java.lang.String NETWORK_BRIDGE_TOPIC_PREFIX;
public static final java.lang.String NETWORK_BRIDGE_FORWARD_FAILURE_TOPIC_PREFIX;
public static final java.lang.String AGENT_TOPIC;
public static final java.lang.String ADIVSORY_MESSAGE_TYPE;
public static final java.lang.String MSG_PROPERTY_ORIGIN_BROKER_ID;
public static final java.lang.String MSG_PROPERTY_ORIGIN_BROKER_NAME;
public static final java.lang.String MSG_PROPERTY_ORIGIN_BROKER_URL;
public static final java.lang.String MSG_PROPERTY_USAGE_NAME;
public static final java.lang.String MSG_PROPERTY_USAGE_COUNT;
public static final java.lang.String MSG_PROPERTY_CONSUMER_ID;
public static final java.lang.String MSG_PROPERTY_PRODUCER_ID;
public static final java.lang.String MSG_PROPERTY_MESSAGE_ID;
public static final java.lang.String MSG_PROPERTY_DESTINATION;
public static final java.lang.String MSG_PROPERTY_CONSUMER_COUNT;
public static final java.lang.String MSG_PROPERTY_DISCARDED_COUNT;
public static final org.apache.activemq.command.ActiveMQTopic ALL_DESTINATIONS_COMPOSITE_ADVISORY_TOPIC;
public static final org.apache.activemq.command.ActiveMQTopic TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC;
private static final org.apache.activemq.command.ActiveMQTopic AGENT_TOPIC_DESTINATION;
private void <init>()
{
org.apache.activemq.advisory.AdvisorySupport v;
v := @this: org.apache.activemq.advisory.AdvisorySupport;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.activemq.command.ActiveMQTopic getConnectionAdvisoryTopic()
{
org.apache.activemq.command.ActiveMQTopic v;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic CONNECTION_ADVISORY_TOPIC>;
return v;
}
public static org.apache.activemq.command.ActiveMQTopic[] getAllDestinationAdvisoryTopics(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.command.ActiveMQTopic[] v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic[] getAllDestinationAdvisoryTopics(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic[] getAllDestinationAdvisoryTopics(org.apache.activemq.command.ActiveMQDestination) throws javax.jms.JMSException
{
java.lang.Object[] v;
org.apache.activemq.command.ActiveMQTopic[] v;
java.util.ArrayList v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.command.ActiveMQTopic v, v, v, v, v, v, v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getExpiredMessageTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getNoConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getSlowConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getFastProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageDiscardedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageDeliveredAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageConsumedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageDLQdAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getFullAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = newarray (org.apache.activemq.command.ActiveMQTopic)[0];
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getConsumerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = "ActiveMQ.Advisory.Consumer.Queue.";
goto label;
label:
v = "ActiveMQ.Advisory.Consumer.Topic.";
label:
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination,java.lang.String,boolean)>(v, v, 1);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getVirtualDestinationConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = "ActiveMQ.Advisory.VirtualDestination.Consumer.Queue.";
goto label;
label:
v = "ActiveMQ.Advisory.VirtualDestination.Consumer.Topic.";
label:
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination,java.lang.String,boolean)>(v, v, 1);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getProducerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
if v != null goto label;
v = "ActiveMQ.Advisory.Producer.Anonymous";
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = "ActiveMQ.Advisory.Producer.Queue.";
goto label;
label:
v = "ActiveMQ.Advisory.Producer.Topic.";
label:
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination,java.lang.String,boolean)>(v, v, 0);
return v;
}
private static org.apache.activemq.command.ActiveMQTopic getAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination, java.lang.String, boolean)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v, v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: java.lang.String;
v := @parameter: boolean;
if v == null goto label;
v = new org.apache.activemq.command.ActiveMQTopic;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: java.lang.String replaceAll(java.lang.String,java.lang.String)>(",", "&sbquo;");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("\u0001\u0001");
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
goto label;
label:
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
label:
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getExpiredMessageTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getExpiredMessageTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getExpiredMessageTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v, v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
label:
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getExpiredTopicMessageAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getExpiredTopicMessageAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
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[])>("ActiveMQ.Advisory.Expired.Topic.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getExpiredQueueMessageAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
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[])>("ActiveMQ.Advisory.Expired.Queue.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNoConsumersAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getExpiredMessageTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNoConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v, v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getNoQueueConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
label:
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getNoTopicConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNoTopicConsumersAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getNoTopicConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNoTopicConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
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[])>("ActiveMQ.Advisory.NoConsumer.Topic.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNoQueueConsumersAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getNoQueueConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNoQueueConsumersAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
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[])>("ActiveMQ.Advisory.NoConsumer.Queue.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getSlowConsumerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getSlowConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getSlowConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.SlowConsumer.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getFastProducerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getFastProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getFastProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.FastProducer.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageDiscardedAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageDiscardedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageDiscardedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.MessageDiscarded.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageDeliveredAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageDeliveredAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageDeliveredAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.MessageDelivered.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageConsumedAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getMessageConsumedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageConsumedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.MessageConsumed.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMessageDLQdAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.MessageDLQd.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getMasterBrokerAdvisoryTopic()
{
org.apache.activemq.command.ActiveMQTopic v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.MasterBroker");
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNetworkBridgeAdvisoryTopic()
{
org.apache.activemq.command.ActiveMQTopic v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.NetworkBridge");
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getFullAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getFullAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getFullAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQTopic v;
java.lang.String v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getDestinationTypeAsString()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("ActiveMQ.Advisory.FULL.\u.\u0001");
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getDestinationAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
org.apache.activemq.command.ActiveMQTopic v;
javax.jms.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic getDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
java.lang.RuntimeException v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.command.ActiveMQTopic v, v, v, v;
byte v, v;
java.lang.String v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: byte getDestinationType()>();
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
default: goto label;
};
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic QUEUE_ADVISORY_TOPIC>;
return v;
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TOPIC_ADVISORY_TOPIC>;
return v;
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC>;
return v;
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC>;
return v;
label:
v = new java.lang.RuntimeException;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: byte getDestinationType()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (byte)>(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[])>("Unknown destination type: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
}
public static boolean isDestinationAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isTempDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
org.apache.activemq.command.ActiveMQTopic v, v;
int v, v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isTempDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != 0 goto label;
return 0;
label:
v = v + 1;
goto label;
label:
return 1;
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
int v, v;
boolean v, v, v, v, v, v, v;
org.apache.activemq.command.ActiveMQDestination v, v;
org.apache.activemq.command.ActiveMQTopic v, v, v, v;
org.apache.activemq.command.ActiveMQDestination[] v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isDestinationAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic QUEUE_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TOPIC_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
return 0;
}
public static boolean isConnectionAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isConnectionAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isConnectionAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
org.apache.activemq.command.ActiveMQTopic v;
int v, v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isConnectionAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic CONNECTION_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
return v;
}
public static boolean isProducerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.Producer.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isConsumerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.Consumer.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isVirtualDestinationConsumerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isVirtualDestinationConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isVirtualDestinationConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isVirtualDestinationConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.VirtualDestination.Consumer.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isSlowConsumerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isSlowConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isSlowConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isSlowConsumerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.SlowConsumer.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isFastProducerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isFastProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isFastProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isFastProducerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.FastProducer.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isMessageConsumedAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMessageConsumedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isMessageConsumedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMessageConsumedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.MessageConsumed.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isMasterBrokerAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMasterBrokerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isMasterBrokerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMasterBrokerAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.MasterBroker");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isMessageDeliveredAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMessageDeliveredAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isMessageDeliveredAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMessageDeliveredAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.MessageDelivered.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isMessageDiscardedAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMessageDiscardedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isMessageDiscardedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isMessageDiscardedAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.MessageDiscarded.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isFullAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isFullAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isFullAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isFullAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.FULL.");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static boolean isNetworkBridgeAdvisoryTopic(javax.jms.Destination) throws javax.jms.JMSException
{
javax.jms.Destination v;
boolean v;
org.apache.activemq.command.ActiveMQDestination v;
v := @parameter: javax.jms.Destination;
v = staticinvoke <org.apache.activemq.ActiveMQMessageTransformation: org.apache.activemq.command.ActiveMQDestination transformDestination(javax.jms.Destination)>(v);
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isNetworkBridgeAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
return v;
}
public static boolean isNetworkBridgeAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.ActiveMQDestination v, v;
int v, v;
java.lang.String v;
org.apache.activemq.command.ActiveMQDestination[] v;
boolean v, v, v, v, v;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isComposite()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: org.apache.activemq.command.ActiveMQDestination[] getCompositeDestinations()>();
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.advisory.AdvisorySupport: boolean isNetworkBridgeAdvisoryTopic(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
return 1;
label:
v = v + 1;
goto label;
label:
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isTopic()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.lang.String getPhysicalName()>();
v = virtualinvoke v.<java.lang.String: boolean startsWith(java.lang.String)>("ActiveMQ.Advisory.NetworkBridge");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static javax.jms.Destination getAgentDestination()
{
org.apache.activemq.command.ActiveMQTopic v;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic AGENT_TOPIC_DESTINATION>;
return v;
}
public static org.apache.activemq.command.ActiveMQTopic getNetworkBridgeForwardFailureAdvisoryTopic()
{
org.apache.activemq.command.ActiveMQTopic v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.NetworkBridge.ForwardFailure");
return v;
}
static void <clinit>()
{
java.lang.String v, v, v, v, v, v, v, v;
org.apache.activemq.command.ActiveMQTopic v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.Connection");
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic CONNECTION_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.Queue");
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic QUEUE_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.Topic");
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TOPIC_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.TempQueue");
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Advisory.TempTopic");
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TOPIC_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getPhysicalName()>();
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic QUEUE_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getPhysicalName()>();
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getPhysicalName()>();
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, 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[])>("\u,\u,\u,\u0001");
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic ALL_DESTINATIONS_COMPOSITE_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_QUEUE_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getPhysicalName()>();
v = <org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_TOPIC_ADVISORY_TOPIC>;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTopic: java.lang.String getPhysicalName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("\u,\u0001");
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>(v);
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC> = v;
v = new org.apache.activemq.command.ActiveMQTopic;
specialinvoke v.<org.apache.activemq.command.ActiveMQTopic: void <init>(java.lang.String)>("ActiveMQ.Agent");
<org.apache.activemq.advisory.AdvisorySupport: org.apache.activemq.command.ActiveMQTopic AGENT_TOPIC_DESTINATION> = v;
return;
}
}