Package com.pardot.rhombus.helpers

Examples of com.pardot.rhombus.helpers.ConnectionManagerTester.teardown()

156
157
158
159
160
161
162
163
164
165
166
    ObjectMapper rhombusObjectMapper = cm.getRhombusObjectMapper(definition);
    CKeyspaceDefinition createdDefinition = rhombusObjectMapper.hydrateRhombusKeyspaceDefinition(definition.getName());
    assertEquals(definition, createdDefinition);

    // Close down our ConnectionManager, make a new one, and verify that we get the proper keyspace
    cm.teardown();
    cm = getConnectionManager();
    ObjectMapper defObjectMapper = cm.getObjectMapper(definition);
    assertEquals(definition, defObjectMapper.getKeyspaceDefinition_ONLY_FOR_TESTING());

    cm.teardown();
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
    cm.teardown();
    cm = getConnectionManager();
    ObjectMapper defObjectMapper = cm.getObjectMapper(definition);
    assertEquals(definition, defObjectMapper.getKeyspaceDefinition_ONLY_FOR_TESTING());

    cm.teardown();
  }

  @Test
  public void testPreferRhombusStorageDefinition() throws Exception {
    // Set up a connection manager
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
    // Build the keyspace from the base definition
    cm.buildKeyspace(definition, false);

    // Simulate a new process interacting with this Rhombus data by tearing down the cluster
    // and getting a new connection manager
    cm.teardown();
    cm = getConnectionManager();

    // Make a slightly altered new definition
    CKeyspaceDefinition definition2 = JsonUtil.objectFromJsonResource(CKeyspaceDefinition.class
        , this.getClass().getClassLoader(), "CKeyspaceTestData.js");
View Full Code Here
197
198
199
200
201
202
203
204
205
206
207
    ObjectMapper om = cm.getObjectMapper(definition2);
    CKeyspaceDefinition omDef = om.getKeyspaceDefinition_ONLY_FOR_TESTING();
    assertEquals(definition, omDef);

    cm.teardown();
  }

  @Test
  public void testGetKeyspaceFromRhombusStorage() throws Exception {
    // Set up a connection manager
View Full Code Here
218
219
220
221
222
223
224
225
226
227
228
    // Build the keyspace from the base definition
    cm.buildKeyspace(definition, false);

    // Simulate a new process interacting with this Rhombus data by tearing down the cluster
    // and getting a new connection manager
    cm.teardown();
    cm = getConnectionManager();

    ObjectMapper om = cm.getObjectMapper(definition.getName());
    CKeyspaceDefinition rhombusStorageKeyspaceDefinition = om.getKeyspaceDefinition_ONLY_FOR_TESTING();
    assertEquals(definition, rhombusStorageKeyspaceDefinition);
View Full Code Here
225
226
227
228
229
230
231
232
233
234
235
    ObjectMapper om = cm.getObjectMapper(definition.getName());
    CKeyspaceDefinition rhombusStorageKeyspaceDefinition = om.getKeyspaceDefinition_ONLY_FOR_TESTING();
    assertEquals(definition, rhombusStorageKeyspaceDefinition);

    cm.teardown();
  }

  @Test
  public void testKeyspaceDefinitionMigration() throws Exception {
    CKeyspaceDefinition OldKeyspaceDefinition = JsonUtil.objectFromJsonResource(CKeyspaceDefinition.class, this.getClass().getClassLoader(), "CKeyspaceTestData.js");
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
    CKeyspaceDefinition definition = JsonUtil.objectFromJsonResource(CKeyspaceDefinition.class
        , this.getClass().getClassLoader(), "CKeyspaceTestData.js");
    ObjectMapper om = cm.getRhombusObjectMapper(definition);
    assertNotNull(om);

    cm.teardown();
  }

  @Test
  public void testKeyspaceCreatedFromDefinitionIfNotExists() throws Exception {
    // Set up a connection manager
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.