}
if (ex instanceof ConnectException) {
return new AmqpConnectException((ConnectException) ex);
}
if (ex instanceof PossibleAuthenticationFailureException) {
return new AmqpAuthenticationException(ex);
}
if (ex instanceof UnsupportedEncodingException) {
return new AmqpUnsupportedEncodingException(ex);
}
if (ex instanceof IOException) {