public boolean sendMsg ( Message msg ) { SendResult sendResult = null ; try { sendResult = producer . send ( msg ) ; } catch ( Exception e ) { logger . error ( "send msg error" , e ) ; } return sendResult != null && sendResult . getSendStatus ( ) == SendStatus . SEND_OK ; }
send msg .