public class org.apache.activemq.broker.region.QueueRegion extends org.apache.activemq.broker.region.AbstractRegion
{
public void <init>(org.apache.activemq.broker.region.RegionBroker, org.apache.activemq.broker.region.DestinationStatistics, org.apache.activemq.usage.SystemUsage, org.apache.activemq.thread.TaskRunnerFactory, org.apache.activemq.broker.region.DestinationFactory)
{
org.apache.activemq.thread.TaskRunnerFactory v;
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.broker.region.DestinationFactory v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.RegionBroker v;
org.apache.activemq.broker.region.QueueRegion v;
v := @this: org.apache.activemq.broker.region.QueueRegion;
v := @parameter: org.apache.activemq.broker.region.RegionBroker;
v := @parameter: org.apache.activemq.broker.region.DestinationStatistics;
v := @parameter: org.apache.activemq.usage.SystemUsage;
v := @parameter: org.apache.activemq.thread.TaskRunnerFactory;
v := @parameter: org.apache.activemq.broker.region.DestinationFactory;
specialinvoke v.<org.apache.activemq.broker.region.AbstractRegion: void <init>(org.apache.activemq.broker.region.RegionBroker,org.apache.activemq.broker.region.DestinationStatistics,org.apache.activemq.usage.SystemUsage,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.broker.region.DestinationFactory)>(v, v, v, v, v);
return;
}
public java.lang.String toString()
{
java.util.Map v, v;
int v, v, v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.usage.SystemUsage v;
java.lang.String v;
org.apache.activemq.broker.region.QueueRegion v;
v := @this: org.apache.activemq.broker.region.QueueRegion;
v = v.<org.apache.activemq.broker.region.QueueRegion: java.util.Map destinations>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = v.<org.apache.activemq.broker.region.QueueRegion: java.util.Map subscriptions>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.usage.SystemUsage usageManager>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: int getPercentUsage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int,int)>(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[])>("QueueRegion: destinations=\u, subscriptions=\u, memory=\u0001%");
return v;
}
protected org.apache.activemq.broker.region.Subscription createSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws javax.jms.JMSException
{
org.apache.activemq.broker.region.policy.PolicyMap v, v;
org.apache.activemq.broker.region.QueueSubscription v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.usage.SystemUsage v, v, v, v;
org.apache.activemq.command.ConsumerInfo v;
boolean v;
org.apache.activemq.broker.region.QueueBrowserSubscription v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.region.policy.PolicyEntry v;
org.apache.activemq.broker.region.RegionBroker v, v, v, v, v, v;
org.apache.activemq.broker.region.QueueRegion v;
v := @this: org.apache.activemq.broker.region.QueueRegion;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ConsumerInfo;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = null;
if v == null goto label;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.broker.region.RegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy()>();
if v == null goto label;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.broker.region.RegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyMap: org.apache.activemq.broker.region.policy.PolicyEntry getEntryFor(org.apache.activemq.command.ActiveMQDestination)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: boolean isBrowser()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.region.QueueBrowserSubscription;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.broker.region.RegionBroker broker>;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.usage.SystemUsage usageManager>;
specialinvoke v.<org.apache.activemq.broker.region.QueueBrowserSubscription: void <init>(org.apache.activemq.broker.Broker,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v, v, v);
if v == null goto label;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.broker.region.RegionBroker broker>;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.usage.SystemUsage usageManager>;
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: void configure(org.apache.activemq.broker.Broker,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.region.QueueBrowserSubscription)>(v, v, v);
label:
return v;
label:
v = new org.apache.activemq.broker.region.QueueSubscription;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.broker.region.RegionBroker broker>;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.usage.SystemUsage usageManager>;
specialinvoke v.<org.apache.activemq.broker.region.QueueSubscription: void <init>(org.apache.activemq.broker.Broker,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v, v, v);
if v == null goto label;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.broker.region.RegionBroker broker>;
v = v.<org.apache.activemq.broker.region.QueueRegion: org.apache.activemq.usage.SystemUsage usageManager>;
virtualinvoke v.<org.apache.activemq.broker.region.policy.PolicyEntry: void configure(org.apache.activemq.broker.Broker,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.region.QueueSubscription)>(v, v, v);
label:
return v;
}
protected java.util.Set getInactiveDestinations()
{
java.util.Iterator v;
java.util.Set v;
java.lang.Object v;
boolean v, v;
org.apache.activemq.broker.region.QueueRegion v;
v := @this: org.apache.activemq.broker.region.QueueRegion;
v = specialinvoke v.<org.apache.activemq.broker.region.AbstractRegion: java.util.Set getInactiveDestinations()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v != 0 goto label;
interfaceinvoke v.<java.util.Iterator: void remove()>();
goto label;
label:
return v;
}
public void processDispatchNotification(org.apache.activemq.command.MessageDispatchNotification) throws java.lang.Exception
{
org.apache.activemq.command.MessageDispatchNotification v;
org.apache.activemq.broker.region.QueueRegion v;
v := @this: org.apache.activemq.broker.region.QueueRegion;
v := @parameter: org.apache.activemq.command.MessageDispatchNotification;
virtualinvoke v.<org.apache.activemq.broker.region.QueueRegion: void processDispatchNotificationViaDestination(org.apache.activemq.command.MessageDispatchNotification)>(v);
return;
}
}