public class org.springframework.jms.remoting.JmsInvokerClientInterceptor extends java.lang.Object implements org.aopalliance.intercept.MethodInterceptor, org.springframework.beans.factory.InitializingBean
{
private javax.jms.ConnectionFactory connectionFactory;
private java.lang.Object queue;
private org.springframework.jms.support.destination.DestinationResolver destinationResolver;
private org.springframework.remoting.support.RemoteInvocationFactory remoteInvocationFactory;
private org.springframework.jms.support.converter.MessageConverter messageConverter;
private long receiveTimeout;
public void <init>()
{
org.springframework.jms.support.converter.SimpleMessageConverter v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.jms.support.destination.DynamicDestinationResolver v;
org.springframework.remoting.support.DefaultRemoteInvocationFactory v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.springframework.jms.support.destination.DynamicDestinationResolver;
specialinvoke v.<org.springframework.jms.support.destination.DynamicDestinationResolver: void <init>()>();
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.destination.DestinationResolver destinationResolver> = v;
v = new org.springframework.remoting.support.DefaultRemoteInvocationFactory;
specialinvoke v.<org.springframework.remoting.support.DefaultRemoteInvocationFactory: void <init>()>();
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationFactory remoteInvocationFactory> = v;
v = new org.springframework.jms.support.converter.SimpleMessageConverter;
specialinvoke v.<org.springframework.jms.support.converter.SimpleMessageConverter: void <init>()>();
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.converter.MessageConverter messageConverter> = v;
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: long receiveTimeout> = 0L;
return;
}
public void setConnectionFactory(javax.jms.ConnectionFactory)
{
javax.jms.ConnectionFactory v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.ConnectionFactory;
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory connectionFactory> = v;
return;
}
protected javax.jms.ConnectionFactory getConnectionFactory()
{
javax.jms.ConnectionFactory v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory connectionFactory>;
return v;
}
public void setQueue(javax.jms.Queue)
{
javax.jms.Queue v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Queue;
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue> = v;
return;
}
public void setQueueName(java.lang.String)
{
java.lang.String v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: java.lang.String;
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue> = v;
return;
}
public void setDestinationResolver(org.springframework.jms.support.destination.DestinationResolver)
{
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.jms.support.destination.DynamicDestinationResolver v;
org.springframework.jms.support.destination.DestinationResolver v, v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.springframework.jms.support.destination.DestinationResolver;
if v == null goto label;
v = v;
goto label;
label:
v = new org.springframework.jms.support.destination.DynamicDestinationResolver;
v = v;
specialinvoke v.<org.springframework.jms.support.destination.DynamicDestinationResolver: void <init>()>();
label:
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.destination.DestinationResolver destinationResolver> = v;
return;
}
public void setRemoteInvocationFactory(org.springframework.remoting.support.RemoteInvocationFactory)
{
org.springframework.remoting.support.RemoteInvocationFactory v, v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.remoting.support.DefaultRemoteInvocationFactory v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.springframework.remoting.support.RemoteInvocationFactory;
if v == null goto label;
v = v;
goto label;
label:
v = new org.springframework.remoting.support.DefaultRemoteInvocationFactory;
v = v;
specialinvoke v.<org.springframework.remoting.support.DefaultRemoteInvocationFactory: void <init>()>();
label:
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationFactory remoteInvocationFactory> = v;
return;
}
public void setMessageConverter(org.springframework.jms.support.converter.MessageConverter)
{
org.springframework.jms.support.converter.SimpleMessageConverter v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.jms.support.converter.MessageConverter v, v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.springframework.jms.support.converter.MessageConverter;
if v == null goto label;
v = v;
goto label;
label:
v = new org.springframework.jms.support.converter.SimpleMessageConverter;
v = v;
specialinvoke v.<org.springframework.jms.support.converter.SimpleMessageConverter: void <init>()>();
label:
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.converter.MessageConverter messageConverter> = v;
return;
}
public void setReceiveTimeout(long)
{
long v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: long;
v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: long receiveTimeout> = v;
return;
}
protected long getReceiveTimeout()
{
long v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: long receiveTimeout>;
return v;
}
public void afterPropertiesSet()
{
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
java.lang.Object v;
java.lang.IllegalArgumentException v, v;
javax.jms.ConnectionFactory v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory getConnectionFactory()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Property \'connectionFactory\' is required");
throw v;
label:
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("\'queue\' or \'queueName\' is required");
throw v;
label:
return;
}
public java.lang.Object invoke(org.aopalliance.intercept.MethodInvocation) throws java.lang.Throwable
{
java.lang.Throwable v;
org.springframework.remoting.support.RemoteInvocation v;
org.springframework.remoting.RemoteAccessException v;
org.aopalliance.intercept.MethodInvocation v;
org.springframework.remoting.support.RemoteInvocationResult v;
java.lang.String v, v;
java.lang.reflect.Method v, v;
boolean v, v;
org.springframework.remoting.RemoteInvocationFailureException v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
javax.jms.JMSException v;
java.lang.Object v, v, v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.aopalliance.intercept.MethodInvocation;
v = interfaceinvoke v.<org.aopalliance.intercept.MethodInvocation: java.lang.reflect.Method getMethod()>();
v = staticinvoke <org.springframework.aop.support.AopUtils: boolean isToStringMethod(java.lang.reflect.Method)>(v);
if v == 0 goto label;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("JMS invoker proxy for queue [\u]");
return v;
label:
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocation createRemoteInvocation(org.aopalliance.intercept.MethodInvocation)>(v);
label:
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationResult executeRequest(org.springframework.remoting.support.RemoteInvocation)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.RemoteAccessException convertJmsInvokerAccessException(javax.jms.JMSException)>(v);
throw v;
label:
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object recreateRemoteInvocationResult(org.springframework.remoting.support.RemoteInvocationResult)>(v);
label:
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.springframework.remoting.support.RemoteInvocationResult: boolean hasInvocationTargetException()>();
if v == 0 goto label;
throw v;
label:
v = new org.springframework.remoting.RemoteInvocationFailureException;
v = interfaceinvoke v.<org.aopalliance.intercept.MethodInvocation: java.lang.reflect.Method getMethod()>();
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.reflect.Method,java.lang.Object)>(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[])>("Invocation of method [\u] failed in JMS invoker remote service at queue [\u]");
specialinvoke v.<org.springframework.remoting.RemoteInvocationFailureException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected org.springframework.remoting.support.RemoteInvocation createRemoteInvocation(org.aopalliance.intercept.MethodInvocation)
{
org.springframework.remoting.support.RemoteInvocationFactory v;
org.aopalliance.intercept.MethodInvocation v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.remoting.support.RemoteInvocation v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.aopalliance.intercept.MethodInvocation;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationFactory remoteInvocationFactory>;
v = interfaceinvoke v.<org.springframework.remoting.support.RemoteInvocationFactory: org.springframework.remoting.support.RemoteInvocation createRemoteInvocation(org.aopalliance.intercept.MethodInvocation)>(v);
return v;
}
protected org.springframework.remoting.support.RemoteInvocationResult executeRequest(org.springframework.remoting.support.RemoteInvocation) throws javax.jms.JMSException
{
java.lang.Throwable v;
javax.jms.Connection v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.remoting.support.RemoteInvocation v;
javax.jms.Queue v;
javax.jms.Session v;
org.springframework.remoting.support.RemoteInvocationResult v, v;
javax.jms.Message v, v;
javax.jms.ConnectionFactory v, v, v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.springframework.remoting.support.RemoteInvocation;
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.Connection createConnection()>();
v = null;
label:
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.Session createSession(javax.jms.Connection)>(v);
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.Queue resolveQueue(javax.jms.Session)>(v);
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.Message createRequestMessage(javax.jms.Session,org.springframework.remoting.support.RemoteInvocation)>(v, v);
interfaceinvoke v.<javax.jms.Connection: void start()>();
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.Message doExecuteRequest(javax.jms.Session,javax.jms.Queue,javax.jms.Message)>(v, v, v);
if v == null goto label;
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationResult extractInvocationResult(javax.jms.Message)>(v);
label:
staticinvoke <org.springframework.jms.support.JmsUtils: void closeSession(javax.jms.Session)>(v);
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory getConnectionFactory()>();
staticinvoke <org.springframework.jms.connection.ConnectionFactoryUtils: void releaseConnection(javax.jms.Connection,javax.jms.ConnectionFactory,boolean)>(v, v, 1);
return v;
label:
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationResult onReceiveTimeout(org.springframework.remoting.support.RemoteInvocation)>(v);
label:
staticinvoke <org.springframework.jms.support.JmsUtils: void closeSession(javax.jms.Session)>(v);
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory getConnectionFactory()>();
staticinvoke <org.springframework.jms.connection.ConnectionFactoryUtils: void releaseConnection(javax.jms.Connection,javax.jms.ConnectionFactory,boolean)>(v, v, 1);
return v;
label:
v := @caughtexception;
staticinvoke <org.springframework.jms.support.JmsUtils: void closeSession(javax.jms.Session)>(v);
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory getConnectionFactory()>();
staticinvoke <org.springframework.jms.connection.ConnectionFactoryUtils: void releaseConnection(javax.jms.Connection,javax.jms.ConnectionFactory,boolean)>(v, v, 1);
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
{
javax.jms.Connection v;
javax.jms.ConnectionFactory v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.ConnectionFactory getConnectionFactory()>();
v = interfaceinvoke v.<javax.jms.ConnectionFactory: javax.jms.Connection createConnection()>();
return v;
}
protected javax.jms.Session createSession(javax.jms.Connection) throws javax.jms.JMSException
{
javax.jms.Connection v;
javax.jms.Session v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Connection;
v = interfaceinvoke v.<javax.jms.Connection: javax.jms.Session createSession(boolean,int)>(0, 1);
return v;
}
protected javax.jms.Queue resolveQueue(javax.jms.Session) throws javax.jms.JMSException
{
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
javax.jms.IllegalStateException v;
javax.jms.Queue v;
javax.jms.Session v;
java.lang.Object v, v, v, v, v;
java.lang.String v;
boolean v, v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Session;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = v instanceof javax.jms.Queue;
if v == 0 goto label;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
return v;
label:
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = v instanceof java.lang.String;
if v == 0 goto label;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: javax.jms.Queue resolveQueueName(javax.jms.Session,java.lang.String)>(v, v);
return v;
label:
v = new javax.jms.IllegalStateException;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("Queue object [\u] is neither a [javax.jms.Queue] nor a queue name String");
specialinvoke v.<javax.jms.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
}
protected javax.jms.Queue resolveQueueName(javax.jms.Session, java.lang.String) throws javax.jms.JMSException
{
javax.jms.Session v;
javax.jms.Destination v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
java.lang.String v;
org.springframework.jms.support.destination.DestinationResolver v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Session;
v := @parameter: java.lang.String;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.destination.DestinationResolver destinationResolver>;
v = interfaceinvoke v.<org.springframework.jms.support.destination.DestinationResolver: javax.jms.Destination resolveDestinationName(javax.jms.Session,java.lang.String,boolean)>(v, v, 0);
return v;
}
protected javax.jms.Message createRequestMessage(javax.jms.Session, org.springframework.remoting.support.RemoteInvocation) throws javax.jms.JMSException
{
javax.jms.Session v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.jms.support.converter.MessageConverter v;
org.springframework.remoting.support.RemoteInvocation v;
javax.jms.Message v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Session;
v := @parameter: org.springframework.remoting.support.RemoteInvocation;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.converter.MessageConverter messageConverter>;
v = interfaceinvoke v.<org.springframework.jms.support.converter.MessageConverter: javax.jms.Message toMessage(java.lang.Object,javax.jms.Session)>(v, v);
return v;
}
protected javax.jms.Message doExecuteRequest(javax.jms.Session, javax.jms.Queue, javax.jms.Message) throws javax.jms.JMSException
{
java.lang.Throwable v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
long v;
javax.jms.Queue v;
javax.jms.Session v;
javax.jms.MessageConsumer v;
byte v;
javax.jms.MessageProducer v;
javax.jms.Message v, v, v;
javax.jms.TemporaryQueue v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Session;
v := @parameter: javax.jms.Queue;
v := @parameter: javax.jms.Message;
v = null;
v = null;
v = null;
label:
v = interfaceinvoke v.<javax.jms.Session: javax.jms.TemporaryQueue createTemporaryQueue()>();
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageProducer createProducer(javax.jms.Destination)>(v);
v = interfaceinvoke v.<javax.jms.Session: javax.jms.MessageConsumer createConsumer(javax.jms.Destination)>(v);
interfaceinvoke v.<javax.jms.Message: void setJMSReplyTo(javax.jms.Destination)>(v);
interfaceinvoke v.<javax.jms.MessageProducer: void send(javax.jms.Message)>(v);
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: long getReceiveTimeout()>();
v = v cmp 0L;
if v <= 0 goto label;
v = interfaceinvoke v.<javax.jms.MessageConsumer: javax.jms.Message receive(long)>(v);
goto label;
label:
v = interfaceinvoke v.<javax.jms.MessageConsumer: javax.jms.Message receive()>();
label:
v = v;
label:
staticinvoke <org.springframework.jms.support.JmsUtils: void closeMessageConsumer(javax.jms.MessageConsumer)>(v);
staticinvoke <org.springframework.jms.support.JmsUtils: void closeMessageProducer(javax.jms.MessageProducer)>(v);
if v == null goto label;
interfaceinvoke v.<javax.jms.TemporaryQueue: void delete()>();
label:
return v;
label:
v := @caughtexception;
staticinvoke <org.springframework.jms.support.JmsUtils: void closeMessageConsumer(javax.jms.MessageConsumer)>(v);
staticinvoke <org.springframework.jms.support.JmsUtils: void closeMessageProducer(javax.jms.MessageProducer)>(v);
if v == null goto label;
interfaceinvoke v.<javax.jms.TemporaryQueue: void delete()>();
label:
throw v;
catch java.lang.Throwable from label to label with label;
}
protected org.springframework.remoting.support.RemoteInvocationResult extractInvocationResult(javax.jms.Message) throws javax.jms.JMSException
{
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.remoting.support.RemoteInvocationResult v;
org.springframework.jms.support.converter.MessageConverter v;
java.lang.Object v;
javax.jms.Message v;
boolean v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Message;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.jms.support.converter.MessageConverter messageConverter>;
v = interfaceinvoke v.<org.springframework.jms.support.converter.MessageConverter: java.lang.Object fromMessage(javax.jms.Message)>(v);
v = v instanceof org.springframework.remoting.support.RemoteInvocationResult;
if v == 0 goto label;
return v;
label:
v = virtualinvoke v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: org.springframework.remoting.support.RemoteInvocationResult onInvalidResponse(javax.jms.Message)>(v);
return v;
}
protected org.springframework.remoting.support.RemoteInvocationResult onReceiveTimeout(org.springframework.remoting.support.RemoteInvocation)
{
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.remoting.support.RemoteInvocation v;
long v;
java.lang.String v;
org.springframework.remoting.RemoteTimeoutException v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.springframework.remoting.support.RemoteInvocation;
v = new org.springframework.remoting.RemoteTimeoutException;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: long receiveTimeout>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,org.springframework.remoting.support.RemoteInvocation)>(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[])>("Receive timeout after \u ms for \u0001");
specialinvoke v.<org.springframework.remoting.RemoteTimeoutException: void <init>(java.lang.String)>(v);
throw v;
}
protected org.springframework.remoting.support.RemoteInvocationResult onInvalidResponse(javax.jms.Message) throws javax.jms.JMSException
{
javax.jms.MessageFormatException v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
java.lang.String v;
javax.jms.Message v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.Message;
v = new javax.jms.MessageFormatException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.jms.Message)>(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[])>("Invalid response message: \u0001");
specialinvoke v.<javax.jms.MessageFormatException: void <init>(java.lang.String)>(v);
throw v;
}
protected java.lang.Object recreateRemoteInvocationResult(org.springframework.remoting.support.RemoteInvocationResult) throws java.lang.Throwable
{
java.lang.Object v;
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
org.springframework.remoting.support.RemoteInvocationResult v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: org.springframework.remoting.support.RemoteInvocationResult;
v = virtualinvoke v.<org.springframework.remoting.support.RemoteInvocationResult: java.lang.Object recreate()>();
return v;
}
protected org.springframework.remoting.RemoteAccessException convertJmsInvokerAccessException(javax.jms.JMSException)
{
org.springframework.jms.remoting.JmsInvokerClientInterceptor v;
java.lang.Object v;
java.lang.String v;
javax.jms.JMSException v;
org.springframework.remoting.RemoteAccessException v;
v := @this: org.springframework.jms.remoting.JmsInvokerClientInterceptor;
v := @parameter: javax.jms.JMSException;
v = new org.springframework.remoting.RemoteAccessException;
v = v.<org.springframework.jms.remoting.JmsInvokerClientInterceptor: java.lang.Object queue>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Object)>(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[])>("Could not access JMS invoker queue [\u]");
specialinvoke v.<org.springframework.remoting.RemoteAccessException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
return v;
}
}