public class org.apache.activemq.broker.region.QueueDispatchSelector extends org.apache.activemq.broker.region.policy.SimpleDispatchSelector
{
private static final org.slf4j.Logger LOG;
private org.apache.activemq.broker.region.Subscription exclusiveConsumer;
private boolean paused;
public void <init>(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.broker.region.QueueDispatchSelector v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
specialinvoke v.<org.apache.activemq.broker.region.policy.SimpleDispatchSelector: void <init>(org.apache.activemq.command.ActiveMQDestination)>(v);
return;
}
public org.apache.activemq.broker.region.Subscription getExclusiveConsumer()
{
org.apache.activemq.broker.region.QueueDispatchSelector v;
org.apache.activemq.broker.region.Subscription v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v = v.<org.apache.activemq.broker.region.QueueDispatchSelector: org.apache.activemq.broker.region.Subscription exclusiveConsumer>;
return v;
}
public void setExclusiveConsumer(org.apache.activemq.broker.region.Subscription)
{
org.apache.activemq.broker.region.QueueDispatchSelector v;
org.apache.activemq.broker.region.Subscription v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v := @parameter: org.apache.activemq.broker.region.Subscription;
v.<org.apache.activemq.broker.region.QueueDispatchSelector: org.apache.activemq.broker.region.Subscription exclusiveConsumer> = v;
return;
}
public boolean isExclusiveConsumer(org.apache.activemq.broker.region.Subscription)
{
org.apache.activemq.broker.region.Subscription v, v;
org.apache.activemq.broker.region.QueueDispatchSelector v;
boolean v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v := @parameter: org.apache.activemq.broker.region.Subscription;
v = v.<org.apache.activemq.broker.region.QueueDispatchSelector: org.apache.activemq.broker.region.Subscription exclusiveConsumer>;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean canSelect(org.apache.activemq.broker.region.Subscription, org.apache.activemq.broker.region.MessageReference) throws java.lang.Exception
{
org.apache.activemq.broker.region.MessageReference v;
org.apache.activemq.broker.region.Subscription v, v, v;
org.apache.activemq.broker.region.QueueDispatchSelector v;
boolean v, v, v, v, v, v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v := @parameter: org.apache.activemq.broker.region.Subscription;
v := @parameter: org.apache.activemq.broker.region.MessageReference;
v = v.<org.apache.activemq.broker.region.QueueDispatchSelector: boolean paused>;
if v != 0 goto label;
v = specialinvoke v.<org.apache.activemq.broker.region.policy.SimpleDispatchSelector: boolean canDispatch(org.apache.activemq.broker.region.Subscription,org.apache.activemq.broker.region.MessageReference)>(v, v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Subscription: boolean isBrowser()>();
if v != 0 goto label;
v = v.<org.apache.activemq.broker.region.QueueDispatchSelector: org.apache.activemq.broker.region.Subscription exclusiveConsumer>;
if v == null goto label;
v = v.<org.apache.activemq.broker.region.QueueDispatchSelector: org.apache.activemq.broker.region.Subscription exclusiveConsumer>;
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
v = v;
label:
return v;
}
public void pause()
{
org.apache.activemq.broker.region.QueueDispatchSelector v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v.<org.apache.activemq.broker.region.QueueDispatchSelector: boolean paused> = 1;
return;
}
public void resume()
{
org.apache.activemq.broker.region.QueueDispatchSelector v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v.<org.apache.activemq.broker.region.QueueDispatchSelector: boolean paused> = 0;
return;
}
public boolean isPaused()
{
org.apache.activemq.broker.region.QueueDispatchSelector v;
boolean v;
v := @this: org.apache.activemq.broker.region.QueueDispatchSelector;
v = v.<org.apache.activemq.broker.region.QueueDispatchSelector: boolean paused>;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/broker/region/QueueDispatchSelector;");
<org.apache.activemq.broker.region.QueueDispatchSelector: org.slf4j.Logger LOG> = v;
return;
}
}