public class org.apache.activemq.broker.jmx.ManagedTopicRegion extends org.apache.activemq.broker.region.TopicRegion
{
private final org.apache.activemq.broker.jmx.ManagedRegionBroker regionBroker;
public void <init>(org.apache.activemq.broker.jmx.ManagedRegionBroker, 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.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.thread.TaskRunnerFactory v;
org.apache.activemq.usage.SystemUsage v;
org.apache.activemq.broker.jmx.ManagedTopicRegion v;
org.apache.activemq.broker.region.DestinationFactory v;
org.apache.activemq.broker.region.DestinationStatistics v;
v := @this: org.apache.activemq.broker.jmx.ManagedTopicRegion;
v := @parameter: org.apache.activemq.broker.jmx.ManagedRegionBroker;
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.TopicRegion: 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);
v.<org.apache.activemq.broker.jmx.ManagedTopicRegion: org.apache.activemq.broker.jmx.ManagedRegionBroker regionBroker> = v;
return;
}
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.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.broker.region.Subscription v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ManagedTopicRegion v;
org.apache.activemq.command.ConsumerInfo v;
v := @this: org.apache.activemq.broker.jmx.ManagedTopicRegion;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ConsumerInfo;
v = specialinvoke v.<org.apache.activemq.broker.region.TopicRegion: org.apache.activemq.broker.region.Subscription createSubscription(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v);
v = v.<org.apache.activemq.broker.jmx.ManagedTopicRegion: org.apache.activemq.broker.jmx.ManagedRegionBroker regionBroker>;
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: javax.management.ObjectName registerSubscription(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.broker.region.Subscription)>(v, v);
interfaceinvoke v.<org.apache.activemq.broker.region.Subscription: void setObjectName(javax.management.ObjectName)>(v);
return v;
}
protected void destroySubscription(org.apache.activemq.broker.region.Subscription)
{
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ManagedTopicRegion v;
org.apache.activemq.broker.region.Subscription v;
v := @this: org.apache.activemq.broker.jmx.ManagedTopicRegion;
v := @parameter: org.apache.activemq.broker.region.Subscription;
v = v.<org.apache.activemq.broker.jmx.ManagedTopicRegion: org.apache.activemq.broker.jmx.ManagedRegionBroker regionBroker>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: void unregisterSubscription(org.apache.activemq.broker.region.Subscription)>(v);
specialinvoke v.<org.apache.activemq.broker.region.TopicRegion: void destroySubscription(org.apache.activemq.broker.region.Subscription)>(v);
return;
}
protected org.apache.activemq.broker.region.Destination createDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.broker.jmx.ManagedTopicRegion v;
org.apache.activemq.broker.region.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.jmx.ManagedTopicRegion;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = specialinvoke v.<org.apache.activemq.broker.region.TopicRegion: org.apache.activemq.broker.region.Destination createDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination)>(v, v);
v = v.<org.apache.activemq.broker.jmx.ManagedTopicRegion: org.apache.activemq.broker.jmx.ManagedRegionBroker regionBroker>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: void register(org.apache.activemq.command.ActiveMQDestination,org.apache.activemq.broker.region.Destination)>(v, v);
return v;
}
public void removeDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, long) throws java.lang.Exception
{
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.ConnectionContext v;
long v;
org.apache.activemq.broker.jmx.ManagedTopicRegion v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.jmx.ManagedTopicRegion;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: long;
specialinvoke v.<org.apache.activemq.broker.region.TopicRegion: void removeDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,long)>(v, v, v);
v = v.<org.apache.activemq.broker.jmx.ManagedTopicRegion: org.apache.activemq.broker.jmx.ManagedRegionBroker regionBroker>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: void unregister(org.apache.activemq.command.ActiveMQDestination)>(v);
return;
}
}