public class org.apache.activemq.advisory.AdvisoryBroker extends org.apache.activemq.broker.BrokerFilter { private static final org.slf4j.Logger LOG; private static final org.apache.activemq.util.IdGenerator ID_GENERATOR; protected final java.util.concurrent.ConcurrentMap connections; private final java.util.concurrent.locks.ReentrantReadWriteLock consumersLock; protected final java.util.Map consumers; protected final java.util.Set virtualDestinations; protected final java.util.concurrent.ConcurrentMap virtualDestinationConsumers; protected final java.util.concurrent.ConcurrentMap brokerConsumerDests; protected final java.util.concurrent.ConcurrentMap producers; protected final java.util.concurrent.ConcurrentMap destinations; protected final java.util.concurrent.ConcurrentMap networkBridges; protected final org.apache.activemq.command.ProducerId advisoryProducerId; private final org.apache.activemq.util.LongSequenceGenerator messageIdGenerator; private org.apache.activemq.advisory.VirtualDestinationMatcher virtualDestinationMatcher; private final org.apache.activemq.util.IdGenerator connectionIdGenerator; private final org.apache.activemq.util.LongSequenceGenerator sessionIdGenerator; private final org.apache.activemq.util.LongSequenceGenerator consumerIdGenerator; public void (org.apache.activemq.broker.Broker) { java.util.concurrent.locks.ReentrantReadWriteLock v; org.apache.activemq.advisory.AdvisoryBroker v; java.util.LinkedHashMap v; org.apache.activemq.broker.Broker v; java.lang.String v; java.util.concurrent.ConcurrentHashMap v, v, v, v, v, v, v; java.util.Set v; org.apache.activemq.command.ProducerId v, v; org.apache.activemq.util.LongSequenceGenerator v, v, v; org.apache.activemq.util.IdGenerator v, v; org.apache.activemq.advisory.DestinationFilterVirtualDestinationMatcher v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.Broker; specialinvoke v.(org.apache.activemq.broker.Broker)>(v); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new java.util.LinkedHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.command.ProducerId; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.advisory.DestinationFilterVirtualDestinationMatcher; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.IdGenerator; specialinvoke v.(java.lang.String)>("advisory"); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v = v.; v = ; v = virtualinvoke v.(); virtualinvoke v.(v); return; } public void addConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo) throws java.lang.Exception { org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConnectionInfo v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.advisory.AdvisoryBroker v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConnectionInfo; specialinvoke v.(v, v); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(""); virtualinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); return; } public org.apache.activemq.broker.region.Subscription addConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.command.ConsumerId v, v, v, v, v, v, v; org.apache.activemq.broker.ConnectionContext v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; java.util.Map v, v; org.apache.activemq.broker.BrokerService v; java.util.Set v, v, v; java.lang.Throwable v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Collection v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ActiveMQTopic v, v, v, v, v, v, v, v; org.apache.activemq.broker.region.Subscription v; java.util.concurrent.ConcurrentMap v, v, v, v, v, v, v; java.util.Iterator v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; org.apache.activemq.advisory.VirtualDestinationMatcher v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = specialinvoke v.(v, v); v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(); specialinvoke v.(v, v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v, v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (); v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(v, v, v, null, v); goto label; label: return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void addProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { org.apache.activemq.broker.BrokerService v; org.apache.activemq.advisory.AdvisoryBroker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.command.ProducerId v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ProducerInfo v; boolean v, v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ProducerInfo; specialinvoke v.(v, v); v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: return; } public org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, boolean) throws java.lang.Exception { org.apache.activemq.advisory.AdvisoryBroker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.DestinationInfo v; boolean v, v, v, v, v, v; org.apache.activemq.broker.BrokerService v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; java.util.Set v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; java.lang.Object v, v; org.apache.activemq.advisory.VirtualDestinationMatcher v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: boolean; v = specialinvoke v.(v, v, v); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); if v == 0 goto label; specialinvoke v.(v, null, v, v); goto label; label: v = new org.apache.activemq.command.DestinationInfo; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.ConnectionId,byte,org.apache.activemq.command.ActiveMQDestination)>(v, 0, v); v = v.; v = interfaceinvoke v.(v, v); if v != null goto label; v = staticinvoke (v); virtualinvoke v.(v, v, v); label: return v; } public void addDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo) throws java.lang.Exception { org.apache.activemq.advisory.AdvisoryBroker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; java.lang.Object v; org.apache.activemq.command.DestinationInfo v; boolean v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.DestinationInfo; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v, v); v = staticinvoke (v); if v != 0 goto label; v = v.; v = interfaceinvoke v.(v, v); if v != null goto label; v = staticinvoke (v); virtualinvoke v.(v, v, v); label: return; } public void removeDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, long) throws java.lang.Exception { org.apache.activemq.advisory.AdvisoryBroker$VirtualConsumerPair v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.DestinationInfo v; boolean v, v, v, v; org.apache.activemq.broker.BrokerService v; java.util.Set v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v, v; org.apache.activemq.command.ActiveMQTopic[] v; long v; java.util.concurrent.ConcurrentMap v, v, v, v, v; org.apache.activemq.broker.Broker v; int v, v; org.slf4j.Logger v; java.util.Iterator v; java.lang.Object v, v, v, v, v; org.apache.activemq.advisory.VirtualDestinationMatcher v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: long; specialinvoke v.(v, v, v); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v, v); if v == 0 goto label; v = new org.apache.activemq.advisory.AdvisoryBroker$VirtualConsumerPair; specialinvoke v.(org.apache.activemq.advisory.AdvisoryBroker,org.apache.activemq.broker.region.virtual.VirtualDestination,org.apache.activemq.command.ActiveMQDestination)>(v, v, v); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = ; interfaceinvoke v.("Virtual consumer pair removed: {} for consumer: {} ", v, v); specialinvoke v.(v, v); label: v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(1); v = staticinvoke (v); virtualinvoke v.(v, v, v); v = staticinvoke (v); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: v = v.; interfaceinvoke v.(v, v, -1L); label: goto label; label: v := @caughtexception; label: v = v + 1; goto label; label: return; catch java.lang.Exception from label to label with label; } public void removeDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo) throws java.lang.Exception { org.apache.activemq.command.ActiveMQTopic[] v; org.apache.activemq.advisory.AdvisoryBroker v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.broker.Broker v; org.apache.activemq.broker.ConnectionContext v; int v, v; org.apache.activemq.command.DestinationInfo v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; org.apache.activemq.command.ActiveMQTopic v, v; java.lang.Object v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.DestinationInfo; specialinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(1); v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = staticinvoke (v); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: v = v.; interfaceinvoke v.(v, v, -1L); label: goto label; label: v := @caughtexception; label: v = v + 1; goto label; label: return; catch java.lang.Exception from label to label with label; } public void removeConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo, java.lang.Throwable) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.command.RemoveInfo v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ConnectionInfo v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConnectionInfo; v := @parameter: java.lang.Throwable; specialinvoke v.(v, v, v); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); return; } public void removeConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.RemoveInfo v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.broker.ConnectionContext v; java.util.Map v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ConsumerInfo; specialinvoke v.(v, v); v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); label: return; catch java.lang.Throwable from label to label with label; } public void removeSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.RemoveSubscriptionInfo) throws java.lang.Exception { java.lang.IllegalStateException v; org.apache.activemq.util.SubscriptionKey v; org.apache.activemq.broker.region.DurableTopicSubscription v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.broker.Broker v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.broker.region.Region v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.RemoveSubscriptionInfo v; org.slf4j.Logger v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.RemoveSubscriptionInfo; v = new org.apache.activemq.util.SubscriptionKey; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = v.; v = v instanceof org.apache.activemq.broker.region.RegionBroker; if v == 0 goto label; v = v.; goto label; label: v = v.; v = interfaceinvoke v.(); virtualinvoke v.(); label: if v != null goto label; v = ; interfaceinvoke v.("Cannot locate a RegionBroker instance to pass along the removeSubscription call"); v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("No RegionBroker found."); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(v, v); if v != null goto label; v = ; interfaceinvoke v.("We cannot send an advisory message for a durable sub removal when we don\'t know about the durable sub"); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v); virtualinvoke v.(v, v, v, v); label: return; } public void removeProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception { org.apache.activemq.broker.BrokerService v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.command.RemoveInfo v; java.util.concurrent.ConcurrentMap v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.command.ProducerId v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.ProducerInfo v; boolean v, v, v, v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.command.ProducerInfo; specialinvoke v.(v, v); v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); label: return; } public void messageExpired(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReference, org.apache.activemq.broker.region.Subscription) { org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v, v; java.lang.String v; boolean v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageId v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReference; v := @parameter: org.apache.activemq.broker.region.Subscription; specialinvoke v.(v, v, v); label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); label: v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalMessageId", v); virtualinvoke v.(v, v, v, null, v); label: goto label; label: v := @caughtexception; specialinvoke v.("expired", v); label: return; catch java.lang.Exception from label to label with label; } public void messageConsumed(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReference) { org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v, v; java.lang.String v, v; boolean v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageId v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReference; specialinvoke v.(v, v); label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); label: v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalMessageId", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalDestination", v); virtualinvoke v.(v, v, v, null, v); label: goto label; label: v := @caughtexception; specialinvoke v.("consumed", v); label: return; catch java.lang.Exception from label to label with label; } public void messageDelivered(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.MessageReference) { org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v, v; java.lang.String v, v; boolean v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageId v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.MessageReference; specialinvoke v.(v, v); label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); label: v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalMessageId", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalDestination", v); virtualinvoke v.(v, v, v, null, v); label: goto label; label: v := @caughtexception; specialinvoke v.("delivered", v); label: return; catch java.lang.Exception from label to label with label; } public void messageDiscarded(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.MessageReference) { org.apache.activemq.command.Message$MessageDestination v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v, v, v; int v; java.lang.String v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v; org.apache.activemq.broker.region.MessageReference v; org.apache.activemq.command.MessageId v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.broker.region.MessageReference; specialinvoke v.(v, v, v); label: v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(); label: v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.()>(); v = v instanceof org.apache.activemq.broker.region.TopicSubscription; if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.("discardedCount", v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalMessageId", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("consumerId", v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.("orignalDestination", v); virtualinvoke v.(v, v, v, null, v); label: goto label; label: v := @caughtexception; specialinvoke v.("discarded", v); label: return; catch java.lang.Exception from label to label with label; } public void slowConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.broker.region.Destination, org.apache.activemq.broker.region.Subscription) { org.apache.activemq.broker.region.Subscription v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.advisory.AdvisoryBroker v; org.apache.activemq.command.ConsumerId v; java.lang.Exception v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.command.ActiveMQTopic v; org.apache.activemq.broker.ConnectionContext v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v, v; boolean v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.advisory.AdvisoryBroker; v := @parameter: org.apache.activemq.broker.ConnectionContext; v := @parameter: org.apache.activemq.broker.region.Destination; v := @parameter: org.apache.activemq.broker.region.Subscription; specialinvoke v.(v, v, v); label: v = interfaceinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v); v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.