@Override
    protected boolean removeFromEphemeralStorage(Connection conn,
            IQueueMessage<Long, byte[]> _msg) {
        if (!(_msg instanceof UniversalIdIntQueueMessage)) {
            throw new IllegalArgumentException("This method requires an argument of type ["
                    + UniversalIdIntQueueMessage.class.getName() + "]!");
        }
        UniversalIdIntQueueMessage msg = (UniversalIdIntQueueMessage) _msg;
        int numRows = getJdbcHelper().execute(conn, SQL_REMOVE_FROM_EPHEMERAL, getQueueName(),
                msg.getId());
        return numRows > 0;
    }
@ Override protected boolean removeFromEphemeralStorage ( Connection conn , IQueueMessage < Long , byte [ ] > _msg ) { if ( ! ( _msg instanceof UniversalIdIntQueueMessage ) ) { throw new IllegalArgumentException ( "This method requires an argument of type [" + UniversalIdIntQueueMessage . class . getName ( ) + "]!" ) ; } UniversalIdIntQueueMessage msg = ( UniversalIdIntQueueMessage ) _msg ; int numRows = getJdbcHelper ( ) . execute ( conn , SQL_REMOVE_FROM_EPHEMERAL , getQueueName ( ) , msg . getId ( ) ) ; return numRows > 0 ; }
{@inheritDoc}