| | |
| | | private String changeLogStringDN; |
| | | |
| | | private BrokerReader reader = null; |
| | | |
| | | |
| | | /** |
| | | * A "person" entry |
| | | */ |
| | |
| | | logError(ErrorLogCategory.SYNCHRONIZATION, |
| | | ErrorLogSeverity.NOTICE, |
| | | "Starting Synchronization StressTest : fromServertoBroker" , 1); |
| | | |
| | | |
| | | final DN baseDn = DN.decode("ou=People,dc=example,dc=com"); |
| | | final int TOTAL_MESSAGES = 1000; |
| | | cleanEntries(); |
| | | |
| | | ChangelogBroker broker = |
| | | openChangelogSession(baseDn, (short) 18, 100, 8989, 5000); |
| | | openChangelogSession(baseDn, (short) 18, 100, 8989, 5000, true); |
| | | Monitor monitor = new Monitor("stress test monitor"); |
| | | DirectoryServer.registerMonitorProvider(monitor); |
| | | |
| | |
| | | |
| | | // Create an internal connection |
| | | connection = new InternalClientConnection(); |
| | | |
| | | |
| | | // Disable schema check |
| | | schemaCheck = DirectoryServer.checkSchema(); |
| | | DirectoryServer.setCheckSchema(false); |
| | |
| | | return count; |
| | | } |
| | | } |
| | | |
| | | |
| | | private class Monitor extends MonitorProvider |
| | | { |
| | | protected Monitor(String threadName) |
| | |
| | | public void updateMonitorData() |
| | | { |
| | | // nothing to do |
| | | |
| | | |
| | | } |
| | | |
| | | @Override |
| | |
| | | throws ConfigException, InitializationException |
| | | { |
| | | // nothing to do |
| | | |
| | | |
| | | } |
| | | |
| | | @Override |
| | |
| | | return 0; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | } |