public class org.springframework.messaging.simp.stomp.StompHeaderAccessor extends org.springframework.messaging.simp.SimpMessageHeaderAccessor
{
private static final java.util.concurrent.atomic.AtomicLong messageIdCounter;
private static final long[] DEFAULT_HEARTBEAT;
public static final java.lang.String STOMP_ID_HEADER;
public static final java.lang.String STOMP_HOST_HEADER;
public static final java.lang.String STOMP_ACCEPT_VERSION_HEADER;
public static final java.lang.String STOMP_MESSAGE_ID_HEADER;
public static final java.lang.String STOMP_RECEIPT_HEADER;
public static final java.lang.String STOMP_RECEIPT_ID_HEADER;
public static final java.lang.String STOMP_SUBSCRIPTION_HEADER;
public static final java.lang.String STOMP_VERSION_HEADER;
public static final java.lang.String STOMP_MESSAGE_HEADER;
public static final java.lang.String STOMP_ACK_HEADER;
public static final java.lang.String STOMP_NACK_HEADER;
public static final java.lang.String STOMP_LOGIN_HEADER;
public static final java.lang.String STOMP_PASSCODE_HEADER;
public static final java.lang.String STOMP_DESTINATION_HEADER;
public static final java.lang.String STOMP_CONTENT_TYPE_HEADER;
public static final java.lang.String STOMP_CONTENT_LENGTH_HEADER;
public static final java.lang.String STOMP_HEARTBEAT_HEADER;
private static final java.lang.String COMMAND_HEADER;
private static final java.lang.String CREDENTIALS_HEADER;
void <init>(org.springframework.messaging.simp.stomp.StompCommand, java.util.Map)
{
org.springframework.messaging.simp.SimpMessageType v;
java.util.Map v;
org.springframework.messaging.simp.stomp.StompCommand v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: org.springframework.messaging.simp.stomp.StompCommand;
v := @parameter: java.util.Map;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.SimpMessageType getMessageType()>();
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void <init>(org.springframework.messaging.simp.SimpMessageType,java.util.Map)>(v, v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setHeader(java.lang.String,java.lang.Object)>("stompCommand", v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void updateSimpMessageHeadersFromStompHeaders()>();
return;
}
void <init>(org.springframework.messaging.Message)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.messaging.Message v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: org.springframework.messaging.Message;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void <init>(org.springframework.messaging.Message)>(v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void updateStompHeadersFromSimpMessageHeaders()>();
return;
}
void <init>()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.messaging.simp.SimpMessageType v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = <org.springframework.messaging.simp.SimpMessageType: org.springframework.messaging.simp.SimpMessageType HEARTBEAT>;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void <init>(org.springframework.messaging.simp.SimpMessageType,java.util.Map)>(v, null);
return;
}
void updateSimpMessageHeadersFromStompHeaders()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.util.MimeType v;
java.util.Map v;
org.springframework.messaging.simp.stomp.StompCommand v, v, v, v, v;
java.lang.String v, v, v, v;
boolean v, v, v, v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.util.Map getNativeHeaders()>();
if v != null goto label;
return;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("destination");
if v == null goto label;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setDestination(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("content-type");
if v == null goto label;
v = staticinvoke <org.springframework.util.MimeTypeUtils: org.springframework.util.MimeType parseMimeType(java.lang.String)>(v);
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setContentType(org.springframework.util.MimeType)>(v);
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompCommand getCommand()>();
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand MESSAGE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("subscription");
if v == null goto label;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setSubscriptionId(java.lang.String)>(v);
goto label;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand SUBSCRIBE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand UNSUBSCRIBE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("id");
if v == null goto label;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setSubscriptionId(java.lang.String)>(v);
goto label;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand CONNECT>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void protectPasscode()>();
label:
return;
}
void updateStompHeadersFromSimpMessageHeaders()
{
org.springframework.util.MimeType v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v, v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getDestination()>();
if v == null goto label;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("destination", v);
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.util.MimeType getContentType()>();
if v == null goto label;
v = virtualinvoke v.<org.springframework.util.MimeType: java.lang.String toString()>();
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("content-type", v);
label:
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void trySetStompHeaderForSubscriptionId()>();
return;
}
protected org.springframework.messaging.support.MessageHeaderAccessor createAccessor(org.springframework.messaging.Message)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v, v;
org.springframework.messaging.Message v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: org.springframework.messaging.Message;
v = staticinvoke <org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompHeaderAccessor wrap(org.springframework.messaging.Message)>(v);
return v;
}
java.util.Map getNativeHeaders()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.Object v;
java.util.Map v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.Object getHeader(java.lang.String)>("nativeHeaders");
if v == null goto label;
v = v;
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
label:
return v;
}
public org.springframework.messaging.simp.stomp.StompCommand updateStompCommandAsClientMessage()
{
java.lang.IllegalStateException v, v;
org.springframework.messaging.simp.SimpMessageType v, v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.messaging.simp.stomp.StompCommand v, v;
java.lang.String v, v;
boolean v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.SimpMessageType getMessageType()>();
v = <org.springframework.messaging.simp.SimpMessageType: org.springframework.messaging.simp.SimpMessageType MESSAGE>;
if v == v goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.messaging.simp.SimpMessageType)>(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[])>("Unexpected message type \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompCommand getCommand()>();
if v != null goto label;
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand SEND>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setHeader(java.lang.String,java.lang.Object)>("stompCommand", v);
goto label;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand SEND>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.messaging.simp.stomp.StompCommand)>(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[])>("Unexpected STOMP command \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public void updateStompCommandAsServerMessage()
{
java.lang.IllegalStateException v, v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
long v;
org.springframework.messaging.simp.stomp.StompCommand v, v, v, v;
java.lang.String v, v, v, v, v;
boolean v, v;
org.springframework.messaging.simp.SimpMessageType v, v;
java.util.concurrent.atomic.AtomicLong v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.SimpMessageType getMessageType()>();
v = <org.springframework.messaging.simp.SimpMessageType: org.springframework.messaging.simp.SimpMessageType MESSAGE>;
if v == v goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.messaging.simp.SimpMessageType)>(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[])>("Unexpected message type \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompCommand getCommand()>();
if v == null goto label;
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand SEND>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand MESSAGE>;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setHeader(java.lang.String,java.lang.Object)>("stompCommand", v);
goto label;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand MESSAGE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.springframework.messaging.simp.stomp.StompCommand)>(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[])>("Unexpected STOMP command \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void trySetStompHeaderForSubscriptionId()>();
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getMessageId()>();
if v != null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getSessionId()>();
v = <org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.util.concurrent.atomic.AtomicLong messageIdCounter>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndIncrement()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(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[])>("\u0001-\u0001");
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("message-id", v);
label:
return;
}
public org.springframework.messaging.simp.stomp.StompCommand getCommand()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.Object v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.Object getHeader(java.lang.String)>("stompCommand");
return v;
}
public boolean isHeartbeat()
{
org.springframework.messaging.simp.SimpMessageType v, v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
boolean v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = <org.springframework.messaging.simp.SimpMessageType: org.springframework.messaging.simp.SimpMessageType HEARTBEAT>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.SimpMessageType getMessageType()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long[] getHeartbeat()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String[] v;
long v, v;
long[] v, v, v;
java.lang.Long v, v;
java.lang.String v, v, v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("heart-beat");
v = staticinvoke <org.springframework.util.StringUtils: java.lang.String[] split(java.lang.String,java.lang.String)>(v, ",");
if v != null goto label;
v = <org.springframework.messaging.simp.stomp.StompHeaderAccessor: long[] DEFAULT_HEARTBEAT>;
v = staticinvoke <java.util.Arrays: long[] copyOf(long[],int)>(v, 2);
return v;
label:
v = newarray (long)[2];
v = v[0];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v[0] = v;
v = v[1];
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v[1] = v;
return v;
}
public void setAcceptVersion(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("accept-version", v);
return;
}
public java.util.Set getAcceptVersion()
{
java.util.Set v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("accept-version");
if v == null goto label;
v = staticinvoke <org.springframework.util.StringUtils: java.util.Set commaDelimitedListToSet(java.lang.String)>(v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
label:
return v;
}
public void setHost(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("host", v);
return;
}
public java.lang.String getHost()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("host");
return v;
}
public void setDestination(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setDestination(java.lang.String)>(v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("destination", v);
return;
}
public void setContentType(org.springframework.util.MimeType)
{
org.springframework.util.MimeType v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: org.springframework.util.MimeType;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setContentType(org.springframework.util.MimeType)>(v);
v = virtualinvoke v.<org.springframework.util.MimeType: java.lang.String toString()>();
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("content-type", v);
return;
}
public void setSubscriptionId(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: void setSubscriptionId(java.lang.String)>(v);
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void trySetStompHeaderForSubscriptionId()>();
return;
}
private void trySetStompHeaderForSubscriptionId()
{
org.springframework.messaging.simp.SimpMessageType v, v, v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.messaging.simp.stomp.StompCommand v, v;
java.lang.String v;
boolean v, v, v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getSubscriptionId()>();
if v == null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompCommand getCommand()>();
if v == null goto label;
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand MESSAGE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("subscription", v);
goto label;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.SimpMessageType getMessageType()>();
v = <org.springframework.messaging.simp.SimpMessageType: org.springframework.messaging.simp.SimpMessageType SUBSCRIBE>;
v = virtualinvoke v.<org.springframework.messaging.simp.SimpMessageType: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.springframework.messaging.simp.SimpMessageType: org.springframework.messaging.simp.SimpMessageType UNSUBSCRIBE>;
v = virtualinvoke v.<org.springframework.messaging.simp.SimpMessageType: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("id", v);
label:
return;
}
public java.lang.Integer getContentLength()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
java.lang.Integer v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("content-length");
if v == null goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
goto label;
label:
v = null;
label:
return v;
}
public void setContentLength(int)
{
int v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: int;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("content-length", v);
return;
}
public void setHeartbeat(long, long)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
long v, v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: long;
v := @parameter: long;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(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[])>("\u,\u0001");
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("heart-beat", v);
return;
}
public void setAck(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("ack", v);
return;
}
public java.lang.String getAck()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("ack");
return v;
}
public void setNack(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("nack", v);
return;
}
public java.lang.String getNack()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("nack");
return v;
}
public void setLogin(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("login", v);
return;
}
public java.lang.String getLogin()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("login");
return v;
}
public void setPasscode(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("passcode", v);
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void protectPasscode()>();
return;
}
private void protectPasscode()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor$StompPasscode v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v, v;
boolean v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("passcode");
if v == null goto label;
v = "PROTECTED";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.springframework.messaging.simp.stomp.StompHeaderAccessor$StompPasscode;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor$StompPasscode: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setHeader(java.lang.String,java.lang.Object)>("stompCredentials", v);
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("passcode", "PROTECTED");
label:
return;
}
public java.lang.String getPasscode()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.Object v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.Object getHeader(java.lang.String)>("stompCredentials");
if v == null goto label;
v = v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor$StompPasscode: java.lang.String passcode>;
goto label;
label:
v = null;
label:
return v;
}
public void setReceiptId(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("receipt-id", v);
return;
}
public java.lang.String getReceiptId()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("receipt-id");
return v;
}
public void setReceipt(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("receipt", v);
return;
}
public java.lang.String getReceipt()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("receipt");
return v;
}
public java.lang.String getMessage()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("message");
return v;
}
public void setMessage(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("message", v);
return;
}
public java.lang.String getMessageId()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("message-id");
return v;
}
public void setMessageId(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("message-id", v);
return;
}
public java.lang.String getVersion()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getFirstNativeHeader(java.lang.String)>("version");
return v;
}
public void setVersion(java.lang.String)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.String;
virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void setNativeHeader(java.lang.String,java.lang.String)>("version", v);
return;
}
public java.lang.String getShortLogMessage(java.lang.Object)
{
org.springframework.messaging.simp.stomp.StompCommand v, v, v, v, v, v, v;
boolean v, v, v, v, v, v;
java.security.Principal v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
long[] v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompCommand getCommand()>();
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand SUBSCRIBE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getDestination()>();
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getSubscriptionId()>();
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, 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[])>("SUBSCRIBE \u id=\u0001\u0001");
return v;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand UNSUBSCRIBE>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getSubscriptionId()>();
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("UNSUBSCRIBE id=\u0001\u0001");
return v;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand SEND>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getDestination()>();
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendPayload(java.lang.Object)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, 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[])>("SEND \u0001\u0001\u0001");
return v;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand CONNECT>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.security.Principal getUser()>();
if v == null goto label;
v = interfaceinvoke v.<java.security.Principal: java.lang.String getName()>();
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[])>(" user=\u0001");
goto label;
label:
v = "";
label:
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("CONNECT\u0001\u0001");
return v;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand CONNECTED>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: long[] getHeartbeat()>();
v = staticinvoke <java.util.Arrays: java.lang.String toString(long[])>(v);
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("CONNECTED heart-beat=\u0001\u0001");
return v;
label:
v = <org.springframework.messaging.simp.stomp.StompCommand: org.springframework.messaging.simp.stomp.StompCommand DISCONNECT>;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getReceipt()>();
if v == null goto label;
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[])>(" receipt=\u0001");
goto label;
label:
v = "";
label:
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("DISCONNECT\u0001\u0001");
return v;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getDetailedLogMessage(java.lang.Object)>(v);
return v;
}
public java.lang.String getDetailedLogMessage(java.lang.Object)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.util.Map v;
org.springframework.messaging.simp.stomp.StompCommand v;
java.lang.String v, v, v, v, v, v, v, v, v;
boolean v, v;
java.security.Principal v, v;
java.lang.Object v;
java.lang.StringBuilder v, v, v, v, v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: boolean isHeartbeat()>();
if v == 0 goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getSessionId()>();
if v == null goto label;
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[])>(" in session \u0001");
goto label;
label:
v = "";
label:
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[])>("heart-beat\u0001");
return v;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.messaging.simp.stomp.StompCommand getCommand()>();
if v != null goto label;
v = specialinvoke v.<org.springframework.messaging.simp.SimpMessageHeaderAccessor: java.lang.String getDetailedLogMessage(java.lang.Object)>(v);
return v;
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: java.lang.String name()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" ");
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.util.Map getNativeHeaders()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendSession()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.security.Principal getUser()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", user=");
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.security.Principal getUser()>();
v = interfaceinvoke v.<java.security.Principal: java.lang.String getName()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompCommand: boolean isBodyAllowed()>();
if v == 0 goto label;
v = specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String appendPayload(java.lang.Object)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
private java.lang.String appendSession()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.lang.String v, v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.lang.String getSessionId()>();
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[])>(" session=\u0001");
return v;
}
private java.lang.String appendPayload(java.lang.Object)
{
byte[] v;
java.lang.IllegalStateException v;
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.util.MimeType v;
java.nio.charset.Charset v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v;
java.lang.Class v, v;
java.lang.Object v;
v := @this: org.springframework.messaging.simp.stomp.StompHeaderAccessor;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v == class "[B" goto label;
v = new java.lang.IllegalStateException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.springframework.util.ClassUtils: java.lang.String getQualifiedName(java.lang.Class)>(v);
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[])>("Expected byte array payload but got: \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: org.springframework.util.MimeType getContentType()>();
if v == null goto label;
v = virtualinvoke v.<org.springframework.util.MimeType: java.lang.String toString()>();
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[])>(" \u0001");
goto label;
label:
v = "";
label:
v = v;
v = lengthof v;
if v == 0 goto label;
if v == null goto label;
v = virtualinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: boolean isReadableContentType()>();
if v != 0 goto label;
label:
return v;
label:
v = virtualinvoke v.<org.springframework.util.MimeType: java.nio.charset.Charset getCharset()>();
if v == null goto label;
v = v;
goto label;
label:
v = <org.springframework.messaging.simp.stomp.StompDecoder: java.nio.charset.Charset UTF8_CHARSET>;
label:
v = lengthof v;
if v >= 80 goto label;
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("\u payload=\u0001");
goto label;
label:
v = new java.lang.String;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, 80);
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("\u payload=\u...(truncated)");
label:
return v;
}
public static org.springframework.messaging.simp.stomp.StompHeaderAccessor create(org.springframework.messaging.simp.stomp.StompCommand)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.messaging.simp.stomp.StompCommand v;
v := @parameter: org.springframework.messaging.simp.stomp.StompCommand;
v = new org.springframework.messaging.simp.stomp.StompHeaderAccessor;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void <init>(org.springframework.messaging.simp.stomp.StompCommand,java.util.Map)>(v, null);
return v;
}
public static org.springframework.messaging.simp.stomp.StompHeaderAccessor create(org.springframework.messaging.simp.stomp.StompCommand, java.util.Map)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
java.util.Map v;
org.springframework.messaging.simp.stomp.StompCommand v;
v := @parameter: org.springframework.messaging.simp.stomp.StompCommand;
v := @parameter: java.util.Map;
v = new org.springframework.messaging.simp.stomp.StompHeaderAccessor;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void <init>(org.springframework.messaging.simp.stomp.StompCommand,java.util.Map)>(v, v);
return v;
}
public static org.springframework.messaging.simp.stomp.StompHeaderAccessor createForHeartbeat()
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
v = new org.springframework.messaging.simp.stomp.StompHeaderAccessor;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void <init>()>();
return v;
}
public static org.springframework.messaging.simp.stomp.StompHeaderAccessor wrap(org.springframework.messaging.Message)
{
org.springframework.messaging.simp.stomp.StompHeaderAccessor v;
org.springframework.messaging.Message v;
v := @parameter: org.springframework.messaging.Message;
v = new org.springframework.messaging.simp.stomp.StompHeaderAccessor;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor: void <init>(org.springframework.messaging.Message)>(v);
return v;
}
public static org.springframework.messaging.simp.stomp.StompCommand getCommand(java.util.Map)
{
java.lang.Object v;
java.util.Map v;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("stompCommand");
return v;
}
public static java.lang.String getPasscode(java.util.Map)
{
java.lang.Object v;
java.lang.String v;
java.util.Map v;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("stompCredentials");
if v == null goto label;
v = v.<org.springframework.messaging.simp.stomp.StompHeaderAccessor$StompPasscode: java.lang.String passcode>;
goto label;
label:
v = null;
label:
return v;
}
public static java.lang.Integer getContentLength(java.util.Map)
{
java.util.Map v;
java.lang.Object v, v;
java.lang.Integer v;
boolean v;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("content-length");
v = staticinvoke <org.springframework.util.CollectionUtils: boolean isEmpty(java.util.Collection)>(v);
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
goto label;
label:
v = null;
label:
return v;
}
static void <clinit>()
{
java.util.concurrent.atomic.AtomicLong v;
long[] v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
<org.springframework.messaging.simp.stomp.StompHeaderAccessor: java.util.concurrent.atomic.AtomicLong messageIdCounter> = v;
v = newarray (long)[2];
v[0] = 0L;
v[1] = 0L;
<org.springframework.messaging.simp.stomp.StompHeaderAccessor: long[] DEFAULT_HEARTBEAT> = v;
return;
}
}