| | |
| | | { |
| | | ReplicationMsg msg = broker.receive(); |
| | | if (msg == null) |
| | | { |
| | | break; |
| | | } |
| | | count ++; |
| | | } |
| | | } catch (Exception e) |
| | |
| | | { |
| | | Attribute attr; |
| | | if (reader == null) |
| | | { |
| | | attr = Attributes.create("received-messages", "not yet started"); |
| | | } |
| | | else |
| | | attr = Attributes.create("received-messages", String |
| | | .valueOf(reader.getCurrentCount())); |
| | | { |
| | | attr = Attributes.create("received-messages", String.valueOf(reader.getCurrentCount())); |
| | | } |
| | | List<Attribute> list = new LinkedList<>(); |
| | | list.add(attr); |
| | | attr = Attributes.create("base-dn", "ou=People," + TEST_ROOT_DN_STRING); |