Package org.apache.directory.server.ldap.replication.provider

Examples of org.apache.directory.server.ldap.replication.provider.SyncReplRequestHandler

694
695
696
697
698
699
700
701
702
703
704
    public static void startPeer1() throws Exception
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        peer1Server = ServerAnnotationProcessor.getLdapServer( provDirService );
        peer1Server.setReplicationReqHandler( new SyncReplRequestHandler() );
        peer1Server.startReplicationProducer();
       
        final ReplicationConsumerImpl consumer = ( ReplicationConsumerImpl ) ServerAnnotationProcessor.createConsumer();
        List<ReplicationConsumer> replConsumers = new ArrayList<ReplicationConsumer>();
        replConsumers.add( consumer );
View Full Code Here
785
786
787
788
789
790
791
792
793
794
795
    public static void startPeer2() throws Exception
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        peer2Server = ServerAnnotationProcessor.getLdapServer( provDirService );
        peer2Server.setReplicationReqHandler( new SyncReplRequestHandler() );
        peer2Server.startReplicationProducer();
       
        final ReplicationConsumerImpl consumer = ( ReplicationConsumerImpl ) ServerAnnotationProcessor.createConsumer();
        List<ReplicationConsumer> replConsumers = new ArrayList<ReplicationConsumer>();
        replConsumers.add( consumer );
View Full Code Here
157
158
159
160
161
162
163
164
165
166
167
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        providerServer = ServerAnnotationProcessor.getLdapServer( provDirService );

        providerServer.setReplicationReqHandler( new SyncReplRequestHandler() );
        providerServer.startReplicationProducer();

        Runnable r = new Runnable()
        {
            public void run()
View Full Code Here
559
560
561
562
563
564
565
566
567
568
569
    public static void startProvider( final CountDownLatch counter ) throws Exception
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        providerServer = ServerAnnotationProcessor.getLdapServer( provDirService );
        providerServer.setReplicationReqHandler( new SyncReplRequestHandler() );
        providerServer.startReplicationProducer();

        Runnable r = new Runnable()
        {
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        providerServer = ServerAnnotationProcessor.getLdapServer( provDirService );

        providerServer.setReplicationReqHandler( new SyncReplRequestHandler() );
        providerServer.startReplicationProducer();

        Runnable r = new Runnable()
        {
            public void run()
View Full Code Here
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
        assertTrue( waitForSyncReplClient( consumer, TOTAL_COUNT ) );
        consumer.stop();

        Thread.sleep( 5 * 1000 ); // let the journal be created and put in the map

        SyncReplRequestHandler syncreplHandler = ( SyncReplRequestHandler ) providerServer.getReplicationReqHandler();

        ReplicaEventLog log = syncreplHandler.getReplicaLogMap().values().iterator().next();
        log.setMaxIdlePeriod( 10 ); // in seconds

        syncreplHandler.getLogJanitor().setSleepTime( 1000 ); // every second
        syncreplHandler.getLogJanitor().interrupt();

        File replDir = providerServer.getDirectoryService().getInstanceLayout().getReplDirectory();
        File logFile = new File( replDir, log.getName() + ".db" );

        // there should be only one log file
View Full Code Here
1070
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
                }
            }
            else
            {
                // Try with the default handler
                ReplicationRequestHandler rp = new SyncReplRequestHandler();
                ldapServer.setReplicationReqHandler( rp );
            }
        }

        ldapServer.setReplConsumers( createReplConsumers( ldapServerBean.getReplConsumers() ) );
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        providerServer = ServerAnnotationProcessor.getLdapServer( provDirService );

        providerServer.setReplicationReqHandler( new SyncReplRequestHandler() );
        providerServer.startReplicationProducer();

        Runnable r = new Runnable()
        {
            public void run()
View Full Code Here
550
551
552
553
554
555
556
557
558
559
560
    public static void startProvider( final CountDownLatch counter ) throws Exception
    {
        DirectoryService provDirService = DSAnnotationProcessor.getDirectoryService();

        providerServer = ServerAnnotationProcessor.getLdapServer( provDirService );
        providerServer.setReplicationReqHandler( new SyncReplRequestHandler() );
        providerServer.startReplicationProducer();

        Runnable r = new Runnable()
        {
View Full Code Here
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037
                }
            }
            else
            {
                // Try with the default handler
                ReplicationRequestHandler rp = new SyncReplRequestHandler();
                ldapServer.setReplicationReqHandler( rp );
            }
        }

        ldapServer.setReplConsumers( createReplConsumers( ldapServerBean.getReplConsumers() ) );
View Full Code Here
TOP

Related Classes of org.apache.directory.server.ldap.replication.provider.SyncReplRequestHandler

  • org.apache.directory.api.ldap.extras.controls.SyncDoneValue
  • org.apache.directory.api.ldap.extras.controls.SyncInfoValue
  • org.apache.directory.api.ldap.extras.controls.syncrepl.syncDone.SyncDoneValue
  • org.apache.directory.api.ldap.extras.controls.syncrepl.syncInfoValue.SyncInfoValue
  • org.apache.directory.api.ldap.extras.controls.syncrepl.syncInfoValue.SyncRequestValue
  • org.apache.directory.api.ldap.extras.controls.syncrepl.syncState.SyncStateTypeEnum
  • org.apache.directory.api.ldap.extras.controls.syncrepl.syncState.SyncStateValue
  • org.apache.directory.api.ldap.extras.controls.syncrepl_impl.SyncDoneValueDecorator
  • org.apache.directory.api.ldap.extras.controls.syncrepl_impl.SyncInfoValueDecorator
  • org.apache.directory.api.ldap.extras.controls.syncrepl_impl.SyncStateValueDecorator
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.