public class org.apache.camel.management.mbean.ManagedConsumer extends org.apache.camel.management.mbean.ManagedService implements org.apache.camel.api.management.mbean.ManagedConsumerMBean
{
private final org.apache.camel.Consumer consumer;
public void <init>(org.apache.camel.CamelContext, org.apache.camel.Consumer)
{
org.apache.camel.CamelContext v;
org.apache.camel.management.mbean.ManagedConsumer v;
org.apache.camel.Consumer v;
v := @this: org.apache.camel.management.mbean.ManagedConsumer;
v := @parameter: org.apache.camel.CamelContext;
v := @parameter: org.apache.camel.Consumer;
specialinvoke v.<org.apache.camel.management.mbean.ManagedService: void <init>(org.apache.camel.CamelContext,org.apache.camel.Service)>(v, v);
v.<org.apache.camel.management.mbean.ManagedConsumer: org.apache.camel.Consumer consumer> = v;
return;
}
public org.apache.camel.Consumer getConsumer()
{
org.apache.camel.management.mbean.ManagedConsumer v;
org.apache.camel.Consumer v;
v := @this: org.apache.camel.management.mbean.ManagedConsumer;
v = v.<org.apache.camel.management.mbean.ManagedConsumer: org.apache.camel.Consumer consumer>;
return v;
}
public java.lang.String getEndpointUri()
{
org.apache.camel.management.mbean.ManagedConsumer v;
java.lang.String v;
org.apache.camel.Endpoint v;
org.apache.camel.Consumer v;
v := @this: org.apache.camel.management.mbean.ManagedConsumer;
v = v.<org.apache.camel.management.mbean.ManagedConsumer: org.apache.camel.Consumer consumer>;
v = interfaceinvoke v.<org.apache.camel.Consumer: org.apache.camel.Endpoint getEndpoint()>();
v = interfaceinvoke v.<org.apache.camel.Endpoint: java.lang.String getEndpointUri()>();
return v;
}
public java.lang.Integer getInflightExchanges()
{
org.apache.camel.CamelContext v;
org.apache.camel.spi.InflightRepository v;
org.apache.camel.management.mbean.ManagedConsumer v;
int v;
java.lang.String v, v;
java.lang.Integer v;
v := @this: org.apache.camel.management.mbean.ManagedConsumer;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedConsumer: java.lang.String getRouteId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedConsumer: org.apache.camel.CamelContext getContext()>();
v = interfaceinvoke v.<org.apache.camel.CamelContext: org.apache.camel.spi.InflightRepository getInflightRepository()>();
v = virtualinvoke v.<org.apache.camel.management.mbean.ManagedConsumer: java.lang.String getRouteId()>();
v = interfaceinvoke v.<org.apache.camel.spi.InflightRepository: int size(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
return null;
}
}