public void testFlowSampleCollectorSetTableNotSupported () {
// Don't run this test if the table is not supported
assumeTrue(schemaVersion.compareTo(flowSampleCollectorSetFromVersion) < 0);
+
boolean isExceptionRaised = false;
try {
FlowSampleCollectorSet flowSampleCollectorSet = getClient().createTypedRowWrapper(FlowSampleCollectorSet.class);
@Test
public void testFlowSampleCollectorSet () throws ExecutionException, InterruptedException {
+ // Don't run this test if the table is not supported
+ assumeTrue(schemaVersion.compareTo(flowSampleCollectorSetFromVersion) >= 0);
+
testBridgeUuid = bridgeInsert();
testFlowSampleCollectorSetInsert();
testFlowSampleCollectorSetDelete();
public void testFlowTableTableNotSupported () {
// Don't run this test if the table is not supported
assumeTrue(schemaVersion.compareTo(flowTableFromVersion) < 0);
+
boolean isExceptionRaised = false;
try {
FlowTable flowTable = getClient().createTypedRowWrapper(FlowTable.class);
}
public void testFlowTableDelete () throws ExecutionException, InterruptedException {
+ // Don't run this test if the table is not supported
+ assumeTrue(schemaVersion.compareTo(flowTableFromVersion) >= 0);
+
FlowTable flowTable = getClient().getTypedRowWrapper(FlowTable.class, null);
Bridge bridge = getClient().getTypedRowWrapper(Bridge.class, null);
@Test
public void setTestFlowTableSet () throws ExecutionException, InterruptedException {
- schemaVersion = getClient().getDatabaseSchema("Open_vSwitch").getVersion();
+ // Don't run this test if the table is not supported
+ assumeTrue(schemaVersion.compareTo(flowTableFromVersion) >= 0);
+
UUID testBridgeUuid = bridgeInsert();
testFlowTableInsert();
testFlowTableDelete();
public void testIpfixTableNotSupported () {
// Don't run this test if the table is not supported
assumeTrue(schemaVersion.compareTo(ipfixFromVersion) < 0);
+
boolean isExceptionRaised = false;
try {
IPFIX ipfix = getClient().createTypedRowWrapper(IPFIX.class);
}
public void testIpfixInsert () throws ExecutionException, InterruptedException {
-
// Don't run this test if the table is not supported
assumeTrue(schemaVersion.compareTo(ipfixFromVersion) >= 0);
}
public void testIpfixDelete () throws ExecutionException, InterruptedException {
+ // Don't run this test if the table is not supported
+ assumeTrue(schemaVersion.compareTo(ipfixFromVersion) >= 0);
+
FlowTable flowTable = getClient().getTypedRowWrapper(FlowTable.class, null);
Bridge bridge = getClient().getTypedRowWrapper(Bridge.class, null);
@Test
public void testIpfix () throws ExecutionException, InterruptedException {
+ // Don't run this test if the table is not supported
+ assumeTrue(schemaVersion.compareTo(ipfixFromVersion) >= 0);
+
testBridgeUuid = bridgeInsert();
testIpfixInsert();
testIpfixDelete();