public class org.apache.activemq.broker.jmx.DestinationView extends java.lang.Object implements org.apache.activemq.broker.jmx.DestinationViewMBean
{
private static final org.slf4j.Logger LOG;
protected final org.apache.activemq.broker.region.Destination destination;
protected final org.apache.activemq.broker.jmx.ManagedRegionBroker broker;
public void <init>(org.apache.activemq.broker.jmx.ManagedRegionBroker, org.apache.activemq.broker.region.Destination)
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: org.apache.activemq.broker.jmx.ManagedRegionBroker;
v := @parameter: org.apache.activemq.broker.region.Destination;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker> = v;
v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination> = v;
return;
}
public void gc()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void gc()>();
return;
}
public java.lang.String getName()
{
org.apache.activemq.broker.jmx.DestinationView v;
java.lang.String v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: java.lang.String getName()>();
return v;
}
public void resetStatistics()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: void reset()>();
return;
}
public long getEnqueueCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getEnqueues()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getDequeueCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getDequeues()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getForwardCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getForwards()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getDispatchCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getDispatched()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getDuplicateFromStoreCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getDuplicateFromStore()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getInFlightCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getInflight()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getExpiredCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getExpired()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getConsumerCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getConsumers()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getQueueSize()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getMessages()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public long getStoreMessageSize()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.store.MessageStore v;
org.apache.activemq.store.MessageStoreStatistics v;
long v;
org.apache.activemq.management.SizeStatisticImpl v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.store.MessageStore getMessageStore()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.activemq.store.MessageStore: org.apache.activemq.store.MessageStoreStatistics getMessageStoreStatistics()>();
v = virtualinvoke v.<org.apache.activemq.store.MessageStoreStatistics: org.apache.activemq.management.SizeStatisticImpl getMessageSize()>();
v = virtualinvoke v.<org.apache.activemq.management.SizeStatisticImpl: long getTotalSize()>();
goto label;
label:
v = 0L;
label:
return v;
}
public long getMessagesCached()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.management.PollCountStatisticImpl v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.PollCountStatisticImpl getMessagesCached()>();
v = virtualinvoke v.<org.apache.activemq.management.PollCountStatisticImpl: long getCount()>();
return v;
}
public int getMemoryPercentUsage()
{
org.apache.activemq.broker.jmx.DestinationView v;
int v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: int getPercentUsage()>();
return v;
}
public long getMemoryUsageByteCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: long getUsage()>();
return v;
}
public long getMemoryLimit()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: long getLimit()>();
return v;
}
public void setMemoryLimit(long)
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: long;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setLimit(long)>(v);
return;
}
public double getAverageEnqueueTime()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
double v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.TimeStatisticImpl getProcessTime()>();
v = virtualinvoke v.<org.apache.activemq.management.TimeStatisticImpl: double getAverageTime()>();
return v;
}
public int getTempUsagePercentUsage()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.usage.TempUsage v;
int v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.TempUsage getTempUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.TempUsage: int getPercentUsage()>();
return v;
}
public long getTempUsageLimit()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.usage.TempUsage v;
long v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.TempUsage getTempUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.TempUsage: long getLimit()>();
return v;
}
public void setTempUsageLimit(long)
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.usage.TempUsage v;
long v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: long;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.TempUsage getTempUsage()>();
virtualinvoke v.<org.apache.activemq.usage.TempUsage: void setLimit(long)>(v);
return;
}
public long getMaxEnqueueTime()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.TimeStatisticImpl getProcessTime()>();
v = virtualinvoke v.<org.apache.activemq.management.TimeStatisticImpl: long getMaxTime()>();
return v;
}
public long getMinEnqueueTime()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.TimeStatisticImpl getProcessTime()>();
v = virtualinvoke v.<org.apache.activemq.management.TimeStatisticImpl: long getMinTime()>();
return v;
}
public long getAverageMessageSize()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.SizeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
double v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.SizeStatisticImpl getMessageSize()>();
v = virtualinvoke v.<org.apache.activemq.management.SizeStatisticImpl: double getAverageSize()>();
return v;
}
public long getMaxMessageSize()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.management.SizeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.SizeStatisticImpl getMessageSize()>();
v = virtualinvoke v.<org.apache.activemq.management.SizeStatisticImpl: long getMaxSize()>();
return v;
}
public long getMinMessageSize()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.management.SizeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.SizeStatisticImpl getMessageSize()>();
v = virtualinvoke v.<org.apache.activemq.management.SizeStatisticImpl: long getMinSize()>();
return v;
}
public boolean isPrioritizedMessages()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: boolean isPrioritizedMessages()>();
return v;
}
public javax.management.openmbean.CompositeData[] browse() throws javax.management.openmbean.OpenDataException
{
java.lang.Throwable v;
org.apache.activemq.broker.jmx.DestinationView v;
java.lang.RuntimeException v;
javax.management.openmbean.CompositeData[] v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
label:
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: javax.management.openmbean.CompositeData[] browse(java.lang.String)>(null);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch javax.jms.InvalidSelectorException from label to label with label;
}
public javax.management.openmbean.CompositeData[] browse(java.lang.String) throws javax.management.openmbean.OpenDataException, javax.jms.InvalidSelectorException
{
java.lang.Throwable v;
org.apache.activemq.filter.NonCachedMessageEvaluationContext v;
java.util.ArrayList v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.command.Message v, v, v;
int v, v, v;
java.lang.String v;
javax.management.openmbean.CompositeData[] v;
boolean v;
org.slf4j.Logger v;
org.apache.activemq.command.Message[] v;
javax.management.openmbean.CompositeData v, v;
org.apache.activemq.filter.BooleanExpression v, v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.region.Destination v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.Message[] browse()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext;
specialinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void <init>()>();
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
virtualinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <org.apache.activemq.selector.SelectorParser: org.apache.activemq.filter.BooleanExpression parse(java.lang.String)>(v);
label:
v = v;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
label:
if v != null goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.broker.jmx.OpenTypeSupport: javax.management.openmbean.CompositeData convert(java.lang.Object)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v[v];
virtualinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void setMessageReference(org.apache.activemq.broker.region.MessageReference)>(v);
v = interfaceinvoke v.<org.apache.activemq.filter.BooleanExpression: boolean matches(org.apache.activemq.filter.MessageEvaluationContext)>(v);
if v == 0 goto label;
v = v[v];
v = staticinvoke <org.apache.activemq.broker.jmx.OpenTypeSupport: javax.management.openmbean.CompositeData convert(java.lang.Object)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.jmx.DestinationView: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("exception browsing destination", v);
label:
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (javax.management.openmbean.CompositeData)[v];
virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
catch java.lang.Throwable from label to label with label;
}
public java.util.List browseMessages() throws javax.jms.InvalidSelectorException
{
org.apache.activemq.broker.jmx.DestinationView v;
java.util.List v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.util.List browseMessages(java.lang.String)>(null);
return v;
}
public java.util.List browseMessages(java.lang.String) throws javax.jms.InvalidSelectorException
{
java.lang.Throwable v;
org.apache.activemq.filter.NonCachedMessageEvaluationContext v;
java.util.ArrayList v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.command.Message v;
int v, v;
java.lang.String v;
boolean v;
org.slf4j.Logger v;
org.apache.activemq.command.Message[] v;
org.apache.activemq.filter.BooleanExpression v, v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.region.Destination v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.Message[] browse()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext;
specialinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void <init>()>();
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
virtualinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <org.apache.activemq.selector.SelectorParser: org.apache.activemq.filter.BooleanExpression parse(java.lang.String)>(v);
label:
v = v;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
label:
v = v[v];
virtualinvoke v.<org.apache.activemq.command.Message: void setReadOnlyBody(boolean)>(1);
if v != null goto label;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void setMessageReference(org.apache.activemq.broker.region.MessageReference)>(v);
v = interfaceinvoke v.<org.apache.activemq.filter.BooleanExpression: boolean matches(org.apache.activemq.filter.MessageEvaluationContext)>(v);
if v == 0 goto label;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.jmx.DestinationView: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("exception browsing destination", v);
label:
v = v + 1;
goto label;
label:
return v;
catch java.lang.Throwable from label to label with label;
}
public javax.management.openmbean.TabularData browseAsTable() throws javax.management.openmbean.OpenDataException
{
java.lang.Throwable v;
org.apache.activemq.broker.jmx.DestinationView v;
java.lang.RuntimeException v;
javax.management.openmbean.TabularData v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
label:
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: javax.management.openmbean.TabularData browseAsTable(java.lang.String)>(null);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch javax.jms.InvalidSelectorException from label to label with label;
}
public javax.management.openmbean.TabularData browseAsTable(java.lang.String) throws javax.management.openmbean.OpenDataException, javax.jms.InvalidSelectorException
{
java.lang.Throwable v;
org.apache.activemq.broker.jmx.OpenTypeSupport$OpenTypeFactory v;
org.apache.activemq.filter.NonCachedMessageEvaluationContext v;
java.lang.String[] v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.command.Message v, v, v;
java.util.Map v, v;
int v, v;
java.lang.String v;
javax.management.openmbean.CompositeDataSupport v, v;
boolean v;
javax.management.openmbean.CompositeType v;
org.slf4j.Logger v;
org.apache.activemq.command.Message[] v;
org.apache.activemq.filter.BooleanExpression v, v;
org.apache.activemq.command.ActiveMQDestination v;
javax.management.openmbean.TabularType v;
javax.management.openmbean.TabularDataSupport v;
org.apache.activemq.broker.region.Destination v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.activemq.broker.jmx.OpenTypeSupport: org.apache.activemq.broker.jmx.OpenTypeSupport$OpenTypeFactory getFactory(java.lang.Class)>(class "Lorg/apache/activemq/command/ActiveMQMessage;");
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.Message[] browse()>();
v = interfaceinvoke v.<org.apache.activemq.broker.jmx.OpenTypeSupport$OpenTypeFactory: javax.management.openmbean.CompositeType getCompositeType()>();
v = new javax.management.openmbean.TabularType;
v = newarray (java.lang.String)[1];
v[0] = "JMSMessageID";
specialinvoke v.<javax.management.openmbean.TabularType: void <init>(java.lang.String,java.lang.String,javax.management.openmbean.CompositeType,java.lang.String[])>("MessageList", "MessageList", v, v);
v = new javax.management.openmbean.TabularDataSupport;
specialinvoke v.<javax.management.openmbean.TabularDataSupport: void <init>(javax.management.openmbean.TabularType)>(v);
v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext;
specialinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void <init>()>();
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
virtualinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void setDestination(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <org.apache.activemq.selector.SelectorParser: org.apache.activemq.filter.BooleanExpression parse(java.lang.String)>(v);
label:
v = v;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
label:
if v != null goto label;
v = new javax.management.openmbean.CompositeDataSupport;
v = v[v];
v = interfaceinvoke v.<org.apache.activemq.broker.jmx.OpenTypeSupport$OpenTypeFactory: java.util.Map getFields(java.lang.Object)>(v);
specialinvoke v.<javax.management.openmbean.CompositeDataSupport: void <init>(javax.management.openmbean.CompositeType,java.util.Map)>(v, v);
virtualinvoke v.<javax.management.openmbean.TabularDataSupport: void put(javax.management.openmbean.CompositeData)>(v);
goto label;
label:
v = v[v];
virtualinvoke v.<org.apache.activemq.filter.NonCachedMessageEvaluationContext: void setMessageReference(org.apache.activemq.broker.region.MessageReference)>(v);
v = interfaceinvoke v.<org.apache.activemq.filter.BooleanExpression: boolean matches(org.apache.activemq.filter.MessageEvaluationContext)>(v);
if v == 0 goto label;
v = new javax.management.openmbean.CompositeDataSupport;
v = v[v];
v = interfaceinvoke v.<org.apache.activemq.broker.jmx.OpenTypeSupport$OpenTypeFactory: java.util.Map getFields(java.lang.Object)>(v);
specialinvoke v.<javax.management.openmbean.CompositeDataSupport: void <init>(javax.management.openmbean.CompositeType,java.util.Map)>(v, v);
virtualinvoke v.<javax.management.openmbean.TabularDataSupport: void put(javax.management.openmbean.CompositeData)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.jmx.DestinationView: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("exception browsing destination", v);
label:
v = v + 1;
goto label;
label:
return v;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String sendTextMessageWithProperties(java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.DestinationView v;
java.util.Map v;
java.lang.Object v, v, v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.util.Map parseProps(java.lang.String,java.lang.String)>(v, ",");
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("body");
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("username");
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("password");
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.lang.String sendTextMessage(java.util.Map,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
}
public java.lang.String sendTextMessageWithProperties(java.lang.String, java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.DestinationView v;
java.util.Map v;
java.lang.Object v, v, v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.lang.String sendTextMessageWithProperties(java.lang.String)>(v);
return v;
label:
v = specialinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.util.Map parseProps(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("body");
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("username");
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("password");
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.lang.String sendTextMessage(java.util.Map,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
}
private java.util.Map parseProps(java.lang.String, java.lang.String)
{
java.lang.String[] v, v;
java.util.HashMap v;
org.apache.activemq.broker.jmx.DestinationView v;
int v, v, v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("=");
v = lengthof v;
if v != 2 goto label;
v = v[0];
v = v[1];
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = v + 1;
goto label;
label:
return v;
}
public java.lang.String sendTextMessage(java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.DestinationView v;
java.util.Map v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v = <java.util.Collections: java.util.Map EMPTY_MAP>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.lang.String sendTextMessage(java.util.Map,java.lang.String)>(v, v);
return v;
}
public java.lang.String sendTextMessage(java.util.Map, java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.DestinationView v;
java.util.Map v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.lang.String sendTextMessage(java.util.Map,java.lang.String,java.lang.String,java.lang.String)>(v, v, null, null);
return v;
}
public java.lang.String sendTextMessage(java.lang.String, java.lang.String, java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.DestinationView v;
java.util.Map v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <java.util.Collections: java.util.Map EMPTY_MAP>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.DestinationView: java.lang.String sendTextMessage(java.util.Map,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
}
public java.lang.String sendTextMessage(java.util.Map, java.lang.String, java.lang.String, java.lang.String) throws java.lang.Exception
{
java.lang.Integer v;
javax.jms.Session v;
byte v, v, v;
java.util.Map v;
javax.jms.MessageProducer v;
boolean v;
java.util.Set v;
org.apache.activemq.ActiveMQConnectionFactory v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.region.Destination v;
java.lang.Throwable v;
long v, v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
int v, v;
java.lang.String v, v, v, v, v, v;
javax.jms.Connection v;
java.util.Iterator v;
javax.jms.TextMessage v;
java.lang.Object v, v, v, v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: java.lang.String getBrokerName()>();
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[])>("vm://\u0001");
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
v = new org.apache.activemq.ActiveMQConnectionFactory;
specialinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: void <init>(java.lang.String)>(v);
v = null;
label:
v = virtualinvoke v.<org.apache.activemq.ActiveMQConnectionFactory: javax.jms.Connection createConnection(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<javax.jms.Connection: javax.jms.Session createSession(boolean,int)>(0, 1);
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageProducer createProducer(javax.jms.Destination)>(v);
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TextMessage createTextMessage(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: void setObjectProperty(java.lang.String,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: int getJMSDeliveryMode()>();
interfaceinvoke v.<javax.jms.MessageProducer: void setDeliveryMode(int)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: byte getPriority()>();
interfaceinvoke v.<javax.jms.MessageProducer: void setPriority(int)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: long getExpiration()>();
v = v cmp 0L;
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: long getExpiration()>();
staticinvoke <java.lang.System: long currentTimeMillis()>();
goto label;
label:
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("timeToLive");
if v == null goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = v;
goto label;
label:
v = 0L;
label:
interfaceinvoke v.<javax.jms.MessageProducer: void setTimeToLive(long)>(v);
interfaceinvoke v.<javax.jms.MessageProducer: void send(javax.jms.Message)>(v);
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQTextMessage: java.lang.String getJMSMessageID()>();
label:
interfaceinvoke v.<javax.jms.Connection: void close()>();
return v;
label:
v := @caughtexception;
if v == null goto label;
interfaceinvoke v.<javax.jms.Connection: void close()>();
label:
throw v;
catch java.lang.Throwable from label to label with label;
}
public int getMaxAuditDepth()
{
int v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: int getMaxAuditDepth()>();
return v;
}
public int getMaxProducersToAudit()
{
int v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: int getMaxProducersToAudit()>();
return v;
}
public boolean isEnableAudit()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: boolean isEnableAudit()>();
return v;
}
public void setEnableAudit(boolean)
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: boolean;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setEnableAudit(boolean)>(v);
return;
}
public void setMaxAuditDepth(int)
{
int v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: int;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setMaxAuditDepth(int)>(v);
return;
}
public void setMaxProducersToAudit(int)
{
int v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: int;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setMaxProducersToAudit(int)>(v);
return;
}
public float getMemoryUsagePortion()
{
org.apache.activemq.broker.jmx.DestinationView v;
float v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: float getUsagePortion()>();
return v;
}
public long getProducerCount()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getProducers()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public boolean isProducerFlowControl()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: boolean isProducerFlowControl()>();
return v;
}
public void setMemoryUsagePortion(float)
{
org.apache.activemq.broker.jmx.DestinationView v;
float v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: float;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setUsagePortion(float)>(v);
return;
}
public void setProducerFlowControl(boolean)
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: boolean;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setProducerFlowControl(boolean)>(v);
return;
}
public boolean isAlwaysRetroactive()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: boolean isAlwaysRetroactive()>();
return v;
}
public void setAlwaysRetroactive(boolean)
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: boolean;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setAlwaysRetroactive(boolean)>(v);
return;
}
public void setBlockedProducerWarningInterval(long)
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: long;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setBlockedProducerWarningInterval(long)>(v);
return;
}
public long getBlockedProducerWarningInterval()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: long getBlockedProducerWarningInterval()>();
return v;
}
public int getMaxPageSize()
{
int v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: int getMaxPageSize()>();
return v;
}
public void setMaxPageSize(int)
{
int v;
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: int;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setMaxPageSize(int)>(v);
return;
}
public boolean isUseCache()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: boolean isUseCache()>();
return v;
}
public void setUseCache(boolean)
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: boolean;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
interfaceinvoke v.<org.apache.activemq.broker.region.Destination: void setUseCache(boolean)>(v);
return;
}
public javax.management.ObjectName[] getSubscriptions() throws java.io.IOException, javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.ConnectionContext v;
int v, v, v;
java.lang.String v;
org.apache.activemq.command.ConsumerInfo v;
boolean v;
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
javax.management.ObjectName v, v;
java.util.List v;
java.lang.Object v;
javax.management.ObjectName[] v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: java.util.List getConsumers()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (javax.management.ObjectName)[v];
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: org.apache.activemq.broker.BrokerService getBrokerService()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = 0;
v = interfaceinvoke v.<java.util.List: 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 = interfaceinvoke v.<org.apache.activemq.broker.region.Subscription: org.apache.activemq.broker.ConnectionContext getContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: java.lang.String getClientId()>();
v = v;
v = v + 1;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Subscription: org.apache.activemq.command.ConsumerInfo getConsumerInfo()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createSubscriptionName(javax.management.ObjectName,java.lang.String,org.apache.activemq.command.ConsumerInfo)>(v, v, v);
v[v] = v;
goto label;
label:
return v;
}
public javax.management.ObjectName getSlowConsumerStrategy() throws java.io.IOException, javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.region.policy.SlowConsumerStrategy v;
javax.management.ObjectName v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = null;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.policy.SlowConsumerStrategy getSlowConsumerStrategy()>();
if v == null goto label;
v = v instanceof org.apache.activemq.broker.region.policy.AbortSlowConsumerStrategy;
if v == 0 goto label;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.jmx.ManagedRegionBroker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: javax.management.ObjectName registerSlowConsumerStrategy(org.apache.activemq.broker.region.policy.AbortSlowConsumerStrategy)>(v);
label:
return v;
}
public java.lang.String getOptions()
{
org.apache.activemq.broker.jmx.DestinationView v;
java.net.URISyntaxException v;
java.util.Map v;
java.lang.String v;
org.apache.activemq.broker.region.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: java.util.Map getOptions()>();
v = "";
label:
if v == null goto label;
v = staticinvoke <org.apache.activemq.util.URISupport: java.lang.String createQueryString(java.util.Map)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
return v;
catch java.net.URISyntaxException from label to label with label;
}
public boolean isDLQ()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isDLQ()>();
return v;
}
public void setDLQ(boolean)
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v := @parameter: boolean;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.command.ActiveMQDestination getActiveMQDestination()>();
virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: void setDLQ(boolean)>(v);
return;
}
public long getBlockedSends()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.CountStatisticImpl v;
long v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getBlockedSends()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
return v;
}
public double getAverageBlockedTime()
{
org.apache.activemq.broker.jmx.DestinationView v;
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
double v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.TimeStatisticImpl getBlockedTime()>();
v = virtualinvoke v.<org.apache.activemq.management.TimeStatisticImpl: double getAverageTime()>();
return v;
}
public long getTotalBlockedTime()
{
org.apache.activemq.broker.jmx.DestinationView v;
long v;
org.apache.activemq.management.TimeStatisticImpl v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.TimeStatisticImpl getBlockedTime()>();
v = virtualinvoke v.<org.apache.activemq.management.TimeStatisticImpl: long getTotalTime()>();
return v;
}
public boolean isSendDuplicateFromStoreToDLQ()
{
org.apache.activemq.broker.jmx.DestinationView v;
boolean v;
org.apache.activemq.broker.region.Destination v;
v := @this: org.apache.activemq.broker.jmx.DestinationView;
v = v.<org.apache.activemq.broker.jmx.DestinationView: org.apache.activemq.broker.region.Destination destination>;
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: boolean isSendDuplicateFromStoreToDLQ()>();
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/jmx/DestinationViewMBean;");
<org.apache.activemq.broker.jmx.DestinationView: org.slf4j.Logger LOG> = v;
return;
}
}