private Object receiveAndRetry(AmqpTemplate template) throws InterruptedException
    {
        Object message = null;
        try
        {
            message = template.receiveAndConvert();
        }
        catch (AmqpException ex)
        {
            // 接続断のタイミングにより、例外が出力される場合があるため、1秒後にリトライする。
            // 再度発生した例外は呼び出し元に返す。
            Thread.sleep(getRetryInterval());
            message = template.receiveAndConvert();
        }
        return message;
    }
private Object receiveAndRetry ( AmqpTemplate template ) throws InterruptedException { Object message = null ; try { message = template . receiveAndConvert ( ) ; } catch ( AmqpException ex ) { Thread . sleep ( getRetryInterval ( ) ) ; message = template . receiveAndConvert ( ) ; } return message ; }
メッセージを受信する。

@param template キューへのコネクション
@return メッセージ
@throws InterruptedException スレッド割り込みが発生した場合