public void processAg31(Ag31 ag31, Afnemersbericht afnemersbericht){
        String aNummer = CategorieUtil.findANummer(ag31.getCategorie());
        String bsn = CategorieUtil.findBsn(ag31.getCategorie());

        digidXClient.setANummer(bsn, aNummer);
        if(ag31.getStatus() != null  && ag31.getDatum() != null){
            digidXClient.setOpschortingsStatus(aNummer, ag31.getStatus());
        }

        // Only possible if original message (Ag01) was not sent
        if(afnemersbericht != null) {
            afnemersberichtRepository.delete(afnemersbericht);
        }

        logger.info("Finished processing Ag31 message");
    }
@Test
    public void testProcessAg31StatusA(){
        String testBsn = "SSSSSSSSS";
        Ag31 testAg31 = TestDglMessagesUtil.createTestAg31(testBsn, "A", "SSSSSSSS");

        classUnderTest.processAg31(testAg31, afnemersbericht);

        verify(digidXClient, times(1)).setANummer(testBsn,"A" + testBsn);
        verify(digidXClient, times(1)).setOpschortingsStatus("A" + testBsn, "A");
    }