Package org.apache.lucene.replicator

Examples of org.apache.lucene.replicator.ReplicationClient.updateNow()

109
110
111
112
113
114
115
116
117
118
119
        getClientConnectionManager());
    ReplicationClient client = new ReplicationClient(replicator, new IndexReplicationHandler(handlerIndexDir, null),
        new PerSessionDirectoryFactory(clientWorkDir));
   
    publishRevision(1);
    client.updateNow();
    reopenReader();
    assertEquals(1, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    publishRevision(2);
    client.updateNow();
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    client.updateNow();
    reopenReader();
    assertEquals(1, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    publishRevision(2);
    client.updateNow();
    reopenReader();
    assertEquals(2, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
  }
 
}
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
        getClientConnectionManager());
    ReplicationClient client = new ReplicationClient(replicator, new IndexReplicationHandler(handlerIndexDir, null),
        new PerSessionDirectoryFactory(clientWorkDir));
   
    publishRevision(1);
    client.updateNow();
    reopenReader();
    assertEquals(1, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    publishRevision(2);
    client.updateNow();
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
    client.updateNow();
    reopenReader();
    assertEquals(1, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    publishRevision(2);
    client.updateNow();
    reopenReader();
    assertEquals(2, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    client.close();
  }
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
    try {
      publishRevision(5);
     
      try {
        replicationServlet.setRespondWithError(true);
        client.updateNow();
        fail("expected exception");
      } catch (Throwable t) {
        // expected
      }
     
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
      } catch (Throwable t) {
        // expected
      }
     
      replicationServlet.setRespondWithError(false);
      client.updateNow(); // now it should work
      reopenReader();
      assertEquals(5, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
     
      client.close();
    } finally {
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
        getClientConnectionManager());
    ReplicationClient client = new ReplicationClient(replicator, new IndexReplicationHandler(handlerIndexDir, null),
        new PerSessionDirectoryFactory(clientWorkDir));
   
    publishRevision(1);
    client.updateNow();
    reopenReader();
    assertEquals(1, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    publishRevision(2);
    client.updateNow();
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
    client.updateNow();
    reopenReader();
    assertEquals(1, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
   
    publishRevision(2);
    client.updateNow();
    reopenReader();
    assertEquals(2, Integer.parseInt(reader.getIndexCommit().getUserData().get("ID"), 16));
  }
 
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.