public class org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry extends org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry
{
public static final int DEFAULT_CACHE_LIMIT;
private static final org.springframework.expression.EvaluationContext messageEvalContext;
private org.springframework.util.PathMatcher pathMatcher;
private volatile int cacheLimit;
private java.lang.String selectorHeaderName;
private volatile boolean selectorHeaderInUse;
private final org.springframework.expression.ExpressionParser expressionParser;
private final org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache;
private final org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry;
public void <init>()
{
org.springframework.expression.spel.standard.SpelExpressionParser v;
org.springframework.util.AntPathMatcher v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
specialinvoke v.<org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry: void <init>()>();
v = new org.springframework.util.AntPathMatcher;
specialinvoke v.<org.springframework.util.AntPathMatcher: void <init>()>();
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.util.PathMatcher pathMatcher> = v;
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: int cacheLimit> = 1024;
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: java.lang.String selectorHeaderName> = "selector";
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: boolean selectorHeaderInUse> = 0;
v = new org.springframework.expression.spel.standard.SpelExpressionParser;
specialinvoke v.<org.springframework.expression.spel.standard.SpelExpressionParser: void <init>()>();
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.expression.ExpressionParser expressionParser> = v;
v = new org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache;
specialinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache: void <init>(org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry)>(v);
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache> = v;
v = new org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry;
specialinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry: void <init>()>();
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry> = v;
return;
}
public void setPathMatcher(org.springframework.util.PathMatcher)
{
org.springframework.util.PathMatcher v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: org.springframework.util.PathMatcher;
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.util.PathMatcher pathMatcher> = v;
return;
}
public org.springframework.util.PathMatcher getPathMatcher()
{
org.springframework.util.PathMatcher v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.util.PathMatcher pathMatcher>;
return v;
}
public void setCacheLimit(int)
{
int v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: int;
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: int cacheLimit> = v;
return;
}
public int getCacheLimit()
{
int v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: int cacheLimit>;
return v;
}
public void setSelectorHeaderName(java.lang.String)
{
java.lang.String v, v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
boolean v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: java.lang.String;
v = staticinvoke <org.springframework.util.StringUtils: boolean hasText(java.lang.String)>(v);
if v == 0 goto label;
v = v;
goto label;
label:
v = null;
label:
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: java.lang.String selectorHeaderName> = v;
return;
}
public java.lang.String getSelectorHeaderName()
{
java.lang.String v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: java.lang.String selectorHeaderName>;
return v;
}
protected void addSubscriptionInternal(java.lang.String, java.lang.String, java.lang.String, org.springframework.messaging.Message)
{
org.springframework.messaging.MessageHeaders v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
org.springframework.expression.Expression v;
org.springframework.messaging.Message v;
java.lang.String v, v, v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.springframework.messaging.Message;
v = interfaceinvoke v.<org.springframework.messaging.Message: org.springframework.messaging.MessageHeaders getHeaders()>();
v = specialinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.expression.Expression getSelectorExpression(org.springframework.messaging.MessageHeaders)>(v);
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry>;
virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo addSubscription(java.lang.String,java.lang.String,java.lang.String,org.springframework.expression.Expression)>(v, v, v, v);
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache>;
virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache: void updateAfterNewSubscription(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return;
}
private org.springframework.expression.Expression getSelectorExpression(org.springframework.messaging.MessageHeaders)
{
java.lang.Throwable v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
java.lang.String v, v, v, v, v;
boolean v, v;
org.springframework.messaging.MessageHeaders v;
org.springframework.expression.ExpressionParser v;
org.springframework.expression.Expression v;
org.apache.commons.logging.Log v, v, v, v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: org.springframework.messaging.MessageHeaders;
v = null;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: java.lang.String getSelectorHeaderName()>();
if v == null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: java.lang.String getSelectorHeaderName()>();
v = staticinvoke <org.springframework.messaging.simp.SimpMessageHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String,java.util.Map)>(v, v);
if v == null goto label;
label:
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.expression.ExpressionParser expressionParser>;
v = interfaceinvoke v.<org.springframework.expression.ExpressionParser: org.springframework.expression.Expression parseExpression(java.lang.String)>(v);
v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: boolean selectorHeaderInUse> = 1;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isTraceEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
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[])>("Subscription selector: [\u]");
interfaceinvoke v.<org.apache.commons.logging.Log: void trace(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
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[])>("Failed to parse selector: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object,java.lang.Throwable)>(v, v);
label:
return v;
catch java.lang.Throwable from label to label with label;
}
protected void removeSubscriptionInternal(java.lang.String, java.lang.String, org.springframework.messaging.Message)
{
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
org.springframework.messaging.Message v;
java.lang.String v, v, v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.springframework.messaging.Message;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry>;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo getSubscriptions(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo: java.lang.String removeSubscription(java.lang.String)>(v);
if v == null goto label;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache>;
virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache: void updateAfterRemovedSubscription(java.lang.String,java.lang.String)>(v, v);
label:
return;
}
public void unregisterAllSubscriptions(java.lang.String)
{
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo v;
java.lang.String v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: java.lang.String;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry>;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo removeSubscriptions(java.lang.String)>(v);
if v == null goto label;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache>;
virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache: void updateAfterRemovedSession(org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo)>(v);
label:
return;
}
protected org.springframework.util.MultiValueMap findSubscriptionsInternal(java.lang.String, org.springframework.messaging.Message)
{
org.springframework.util.MultiValueMap v;
org.springframework.messaging.Message v;
java.lang.String v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
org.springframework.util.LinkedMultiValueMap v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: java.lang.String;
v := @parameter: org.springframework.messaging.Message;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache>;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache: org.springframework.util.LinkedMultiValueMap getSubscriptions(java.lang.String,org.springframework.messaging.Message)>(v, v);
v = specialinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.util.MultiValueMap filterSubscriptions(org.springframework.util.MultiValueMap,org.springframework.messaging.Message)>(v, v);
return v;
}
private org.springframework.util.MultiValueMap filterSubscriptions(org.springframework.util.MultiValueMap, org.springframework.messaging.Message)
{
java.lang.Throwable v;
org.springframework.expression.spel.SpelEvaluationException v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
int v;
java.lang.Boolean v;
org.springframework.messaging.Message v;
java.lang.String v, v;
boolean v, v, v, v, v;
java.util.Iterator v, v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$Subscription v;
java.util.Set v;
org.springframework.util.MultiValueMap v;
org.springframework.expression.EvaluationContext v;
org.springframework.expression.Expression v;
java.lang.Object v, v, v, v;
org.apache.commons.logging.Log v, v, v;
org.springframework.util.LinkedMultiValueMap v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v := @parameter: org.springframework.util.MultiValueMap;
v := @parameter: org.springframework.messaging.Message;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: boolean selectorHeaderInUse>;
if v != 0 goto label;
return v;
label:
v = new org.springframework.util.LinkedMultiValueMap;
v = interfaceinvoke v.<org.springframework.util.MultiValueMap: int size()>();
specialinvoke v.<org.springframework.util.LinkedMultiValueMap: void <init>(int)>(v);
v = interfaceinvoke v.<org.springframework.util.MultiValueMap: java.util.Set keySet()>();
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.<org.springframework.util.MultiValueMap: java.lang.Object get(java.lang.Object)>(v);
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 = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry>;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo getSubscriptions(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionInfo: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$Subscription getSubscription(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$Subscription: org.springframework.expression.Expression getSelectorExpression()>();
if v != null goto label;
interfaceinvoke v.<org.springframework.util.MultiValueMap: void add(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = <org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.expression.EvaluationContext messageEvalContext>;
v = interfaceinvoke v.<org.springframework.expression.Expression: java.lang.Object getValue(org.springframework.expression.EvaluationContext,java.lang.Object,java.lang.Class)>(v, v, class "Ljava/lang/Boolean;");
v = virtualinvoke v.<java.lang.Boolean: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<org.springframework.util.MultiValueMap: void add(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
v = interfaceinvoke v.<org.apache.commons.logging.Log: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
v = virtualinvoke v.<org.springframework.expression.spel.SpelEvaluationException: java.lang.String getMessage()>();
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[])>("Failed to evaluate selector: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object,java.lang.Throwable)>("Failed to evaluate selector", v);
goto label;
label:
return v;
catch org.springframework.expression.spel.SpelEvaluationException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public java.lang.String toString()
{
java.lang.String v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry v;
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry v;
v := @this: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache destinationCache>;
v = v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry subscriptionRegistry>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$DestinationCache,org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SessionSubscriptionRegistry)>(v, 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[])>("DefaultSubscriptionRegistry[\u, \u]");
return v;
}
static void <clinit>()
{
org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SimpMessageHeaderPropertyAccessor v;
org.springframework.expression.PropertyAccessor[] v;
org.springframework.expression.spel.support.SimpleEvaluationContext$Builder v;
org.springframework.expression.spel.support.SimpleEvaluationContext v;
v = newarray (org.springframework.expression.PropertyAccessor)[1];
v = new org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SimpMessageHeaderPropertyAccessor;
specialinvoke v.<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry$SimpMessageHeaderPropertyAccessor: void <init>()>();
v[0] = v;
v = staticinvoke <org.springframework.expression.spel.support.SimpleEvaluationContext: org.springframework.expression.spel.support.SimpleEvaluationContext$Builder forPropertyAccessors(org.springframework.expression.PropertyAccessor[])>(v);
v = virtualinvoke v.<org.springframework.expression.spel.support.SimpleEvaluationContext$Builder: org.springframework.expression.spel.support.SimpleEvaluationContext build()>();
<org.springframework.messaging.simp.broker.DefaultSubscriptionRegistry: org.springframework.expression.EvaluationContext messageEvalContext> = v;
return;
}
}