public class org.apache.activemq.broker.MapTransportConnectionStateRegister extends java.lang.Object implements org.apache.activemq.broker.TransportConnectionStateRegister
{
private java.util.Map connectionStates;
public void <init>()
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates> = v;
return;
}
public org.apache.activemq.broker.TransportConnectionState registerConnectionState(org.apache.activemq.command.ConnectionId, org.apache.activemq.broker.TransportConnectionState)
{
org.apache.activemq.broker.TransportConnectionState v;
org.apache.activemq.command.ConnectionId v;
java.util.Map v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.lang.Object v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.command.ConnectionId;
v := @parameter: org.apache.activemq.broker.TransportConnectionState;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public org.apache.activemq.broker.TransportConnectionState unregisterConnectionState(org.apache.activemq.command.ConnectionId)
{
java.util.concurrent.atomic.AtomicInteger v;
org.apache.activemq.command.ConnectionId v;
java.util.Map v, v;
int v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.lang.Object v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.command.ConnectionId;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnectionState: java.util.concurrent.atomic.AtomicInteger getReferenceCounter()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
if v <= 1 goto label;
virtualinvoke v.<org.apache.activemq.broker.TransportConnectionState: int decrementReference()>();
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
public java.util.List listConnectionStates()
{
java.util.Collection v;
java.util.Map v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.util.ArrayList v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return v;
}
public org.apache.activemq.broker.TransportConnectionState lookupConnectionState(java.lang.String)
{
org.apache.activemq.command.ConnectionId v;
java.util.Map v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = new org.apache.activemq.command.ConnectionId;
specialinvoke v.<org.apache.activemq.command.ConnectionId: void <init>(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.activemq.broker.TransportConnectionState lookupConnectionState(org.apache.activemq.command.ConsumerId)
{
java.lang.IllegalStateException v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.SessionId v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.broker.TransportConnectionState v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.command.ConsumerId;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: java.lang.String getConnectionId()>();
v = virtualinvoke v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: org.apache.activemq.broker.TransportConnectionState lookupConnectionState(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerId: org.apache.activemq.command.SessionId getParentId()>();
v = virtualinvoke v.<org.apache.activemq.command.SessionId: org.apache.activemq.command.ConnectionId getParentId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ConnectionId)>(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[])>("Cannot lookup a consumer from a connection that had not been registered: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public org.apache.activemq.broker.TransportConnectionState lookupConnectionState(org.apache.activemq.command.ProducerId)
{
java.lang.IllegalStateException v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.SessionId v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
org.apache.activemq.command.ProducerId v;
org.apache.activemq.broker.TransportConnectionState v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.command.ProducerId;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String getConnectionId()>();
v = virtualinvoke v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: org.apache.activemq.broker.TransportConnectionState lookupConnectionState(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: org.apache.activemq.command.SessionId getParentId()>();
v = virtualinvoke v.<org.apache.activemq.command.SessionId: org.apache.activemq.command.ConnectionId getParentId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ConnectionId)>(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[])>("Cannot lookup a producer from a connection that had not been registered: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public org.apache.activemq.broker.TransportConnectionState lookupConnectionState(org.apache.activemq.command.SessionId)
{
java.lang.IllegalStateException v;
org.apache.activemq.broker.TransportConnectionState v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.SessionId v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.command.SessionId;
v = virtualinvoke v.<org.apache.activemq.command.SessionId: java.lang.String getConnectionId()>();
v = virtualinvoke v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: org.apache.activemq.broker.TransportConnectionState lookupConnectionState(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<org.apache.activemq.command.SessionId: org.apache.activemq.command.ConnectionId getParentId()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ConnectionId)>(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[])>("Cannot lookup a session from a connection that had not been registered: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public org.apache.activemq.broker.TransportConnectionState lookupConnectionState(org.apache.activemq.command.ConnectionId)
{
java.lang.IllegalStateException v;
org.apache.activemq.command.ConnectionId v;
java.util.Map v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.command.ConnectionId;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.command.ConnectionId)>(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[])>("Cannot lookup a connection that had not been registered: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean doesHandleMultipleConnectionStates()
{
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
return 1;
}
public boolean isEmpty()
{
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
boolean v;
java.util.Map v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
return v;
}
public void clear()
{
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.util.Map v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
interfaceinvoke v.<java.util.Map: void clear()>();
return;
}
public void intialize(org.apache.activemq.broker.TransportConnectionStateRegister)
{
org.apache.activemq.broker.TransportConnectionStateRegister v;
java.util.Map v, v, v;
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v := @parameter: org.apache.activemq.broker.TransportConnectionStateRegister;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
v = interfaceinvoke v.<org.apache.activemq.broker.TransportConnectionStateRegister: java.util.Map mapStates()>();
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
return;
}
public java.util.Map mapStates()
{
org.apache.activemq.broker.MapTransportConnectionStateRegister v;
java.util.HashMap v;
java.util.Map v;
v := @this: org.apache.activemq.broker.MapTransportConnectionStateRegister;
v = new java.util.HashMap;
v = v.<org.apache.activemq.broker.MapTransportConnectionStateRegister: java.util.Map connectionStates>;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
return v;
}
}