public abstract class org.springframework.jms.support.JmsUtils extends java.lang.Object
{
private static final org.apache.commons.logging.Log logger;
public void <init>()
{
org.springframework.jms.support.JmsUtils v;
v := @this: org.springframework.jms.support.JmsUtils;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static void closeConnection(javax.jms.Connection)
{
javax.jms.Connection v;
v := @parameter: javax.jms.Connection;
staticinvoke <org.springframework.jms.support.JmsUtils: void closeConnection(javax.jms.Connection,boolean)>(v, 0);
return;
}
public static void closeConnection(javax.jms.Connection, boolean)
{
java.lang.Throwable v, v;
javax.jms.Connection v;
javax.jms.IllegalStateException v;
javax.jms.JMSException v;
org.apache.commons.logging.Log v, v, v;
java.lang.String v;
boolean v;
v := @parameter: javax.jms.Connection;
v := @parameter: boolean;
if v == null goto label;
label:
if v == 0 goto label;
label:
interfaceinvoke v.<javax.jms.Connection: void stop()>();
label:
interfaceinvoke v.<javax.jms.Connection: void close()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<javax.jms.Connection: void close()>();
throw v;
label:
interfaceinvoke v.<javax.jms.Connection: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.springframework.jms.support.JmsUtils: org.apache.commons.logging.Log logger>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (javax.jms.IllegalStateException)>(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[])>("Ignoring Connection state exception - assuming already closed: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = <org.springframework.jms.support.JmsUtils: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object,java.lang.Throwable)>("Could not close JMS Connection", v);
goto label;
label:
v := @caughtexception;
v = <org.springframework.jms.support.JmsUtils: org.apache.commons.logging.Log logger>;
interfaceinvoke v.<org.apache.commons.logging.Log: void debug(java.lang.Object,java.lang.Throwable)>("Unexpected exception on closing JMS Connection", v);
label:
return;
catch java.lang.Throwable from label to label with label;
catch javax.jms.IllegalStateException from label to label with label;
catch javax.jms.JMSException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public static void closeSession(javax.jms.Session)
{
javax.jms.Session v;
v := @parameter: javax.jms.Session;
return;
}
public static void closeMessageProducer(javax.jms.MessageProducer)
{
javax.jms.MessageProducer v;
v := @parameter: javax.jms.MessageProducer;
return;
}
public static void closeMessageConsumer(javax.jms.MessageConsumer)
{
javax.jms.MessageConsumer v;
boolean v;
java.lang.Thread v;
v := @parameter: javax.jms.MessageConsumer;
if v == null goto label;
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return;
}
public static void closeQueueBrowser(javax.jms.QueueBrowser)
{
javax.jms.QueueBrowser v;
v := @parameter: javax.jms.QueueBrowser;
return;
}
public static void closeQueueRequestor(javax.jms.QueueRequestor)
{
javax.jms.QueueRequestor v;
v := @parameter: javax.jms.QueueRequestor;
return;
}
public static void commitIfNecessary(javax.jms.Session) throws javax.jms.JMSException
{
javax.jms.TransactionInProgressException v;
javax.jms.Session v;
javax.jms.IllegalStateException v;
v := @parameter: javax.jms.Session;
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "Session must not be null");
label:
interfaceinvoke v.<javax.jms.Session: void commit()>();
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
label:
return;
catch javax.jms.TransactionInProgressException from label to label with label;
catch javax.jms.IllegalStateException from label to label with label;
}
public static void rollbackIfNecessary(javax.jms.Session) throws javax.jms.JMSException
{
javax.jms.TransactionInProgressException v;
javax.jms.Session v;
javax.jms.IllegalStateException v;
v := @parameter: javax.jms.Session;
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "Session must not be null");
label:
interfaceinvoke v.<javax.jms.Session: void rollback()>();
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
label:
return;
catch javax.jms.TransactionInProgressException from label to label with label;
catch javax.jms.IllegalStateException from label to label with label;
}
public static java.lang.String buildExceptionMessage(javax.jms.JMSException)
{
java.lang.String v, v;
javax.jms.JMSException v;
java.lang.Exception v;
boolean v;
v := @parameter: javax.jms.JMSException;
v = virtualinvoke v.<javax.jms.JMSException: java.lang.String getMessage()>();
v = virtualinvoke v.<javax.jms.JMSException: java.lang.Exception getLinkedException()>();
if v == null goto label;
if v != null goto label;
v = virtualinvoke v.<java.lang.Exception: java.lang.String toString()>();
goto label;
label:
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Exception)>(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; nested exception is \u0001");
label:
return v;
}
public static org.springframework.jms.JmsException convertJmsAccessException(javax.jms.JMSException)
{
org.springframework.jms.MessageNotReadableException v;
org.springframework.jms.UncategorizedJmsException v;
org.springframework.jms.IllegalStateException v;
org.springframework.jms.InvalidDestinationException v;
org.springframework.jms.ResourceAllocationException v;
org.springframework.jms.MessageFormatException v;
org.springframework.jms.MessageEOFException v;
org.springframework.jms.InvalidClientIDException v;
boolean v, v, v, v, v, v, v, v, v, v, v, v;
javax.jms.JMSException v;
org.springframework.jms.TransactionInProgressException v;
org.springframework.jms.MessageNotWriteableException v;
org.springframework.jms.TransactionRolledBackException v;
org.springframework.jms.JmsSecurityException v;
org.springframework.jms.InvalidSelectorException v;
v := @parameter: javax.jms.JMSException;
staticinvoke <org.springframework.util.Assert: void notNull(java.lang.Object,java.lang.String)>(v, "JMSException must not be null");
v = v instanceof javax.jms.IllegalStateException;
if v == 0 goto label;
v = new org.springframework.jms.IllegalStateException;
specialinvoke v.<org.springframework.jms.IllegalStateException: void <init>(javax.jms.IllegalStateException)>(v);
return v;
label:
v = v instanceof javax.jms.InvalidClientIDException;
if v == 0 goto label;
v = new org.springframework.jms.InvalidClientIDException;
specialinvoke v.<org.springframework.jms.InvalidClientIDException: void <init>(javax.jms.InvalidClientIDException)>(v);
return v;
label:
v = v instanceof javax.jms.InvalidDestinationException;
if v == 0 goto label;
v = new org.springframework.jms.InvalidDestinationException;
specialinvoke v.<org.springframework.jms.InvalidDestinationException: void <init>(javax.jms.InvalidDestinationException)>(v);
return v;
label:
v = v instanceof javax.jms.InvalidSelectorException;
if v == 0 goto label;
v = new org.springframework.jms.InvalidSelectorException;
specialinvoke v.<org.springframework.jms.InvalidSelectorException: void <init>(javax.jms.InvalidSelectorException)>(v);
return v;
label:
v = v instanceof javax.jms.JMSSecurityException;
if v == 0 goto label;
v = new org.springframework.jms.JmsSecurityException;
specialinvoke v.<org.springframework.jms.JmsSecurityException: void <init>(javax.jms.JMSSecurityException)>(v);
return v;
label:
v = v instanceof javax.jms.MessageEOFException;
if v == 0 goto label;
v = new org.springframework.jms.MessageEOFException;
specialinvoke v.<org.springframework.jms.MessageEOFException: void <init>(javax.jms.MessageEOFException)>(v);
return v;
label:
v = v instanceof javax.jms.MessageFormatException;
if v == 0 goto label;
v = new org.springframework.jms.MessageFormatException;
specialinvoke v.<org.springframework.jms.MessageFormatException: void <init>(javax.jms.MessageFormatException)>(v);
return v;
label:
v = v instanceof javax.jms.MessageNotReadableException;
if v == 0 goto label;
v = new org.springframework.jms.MessageNotReadableException;
specialinvoke v.<org.springframework.jms.MessageNotReadableException: void <init>(javax.jms.MessageNotReadableException)>(v);
return v;
label:
v = v instanceof javax.jms.MessageNotWriteableException;
if v == 0 goto label;
v = new org.springframework.jms.MessageNotWriteableException;
specialinvoke v.<org.springframework.jms.MessageNotWriteableException: void <init>(javax.jms.MessageNotWriteableException)>(v);
return v;
label:
v = v instanceof javax.jms.ResourceAllocationException;
if v == 0 goto label;
v = new org.springframework.jms.ResourceAllocationException;
specialinvoke v.<org.springframework.jms.ResourceAllocationException: void <init>(javax.jms.ResourceAllocationException)>(v);
return v;
label:
v = v instanceof javax.jms.TransactionInProgressException;
if v == 0 goto label;
v = new org.springframework.jms.TransactionInProgressException;
specialinvoke v.<org.springframework.jms.TransactionInProgressException: void <init>(javax.jms.TransactionInProgressException)>(v);
return v;
label:
v = v instanceof javax.jms.TransactionRolledBackException;
if v == 0 goto label;
v = new org.springframework.jms.TransactionRolledBackException;
specialinvoke v.<org.springframework.jms.TransactionRolledBackException: void <init>(javax.jms.TransactionRolledBackException)>(v);
return v;
label:
v = new org.springframework.jms.UncategorizedJmsException;
specialinvoke v.<org.springframework.jms.UncategorizedJmsException: void <init>(java.lang.Throwable)>(v);
return v;
}
static void <clinit>()
{
org.apache.commons.logging.Log v;
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(class "Lorg/springframework/jms/support/JmsUtils;");
<org.springframework.jms.support.JmsUtils: org.apache.commons.logging.Log logger> = v;
return;
}
}