Skip to content

Commit

Permalink
Event generation for Cassandra 3 & 4
Browse files Browse the repository at this point in the history
  • Loading branch information
IshikaDawda committed Jun 19, 2023
1 parent 480d229 commit a3abc13
Showing 1 changed file with 13 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -113,13 +113,20 @@ public void run() {
break;
}
case NOSQL_DB_COMMAND:
NoSQLOperation noSQLOperationalBean = (NoSQLOperation) operation;
try {
eventBean = prepareNoSQLEvent(eventBean, noSQLOperationalBean);
} catch (Throwable e) {
return;
if(operation instanceof SQLOperation) {
eventBean = prepareSQLDbCommandEvent((SQLOperation) operation, eventBean);
break;
} else if (operation instanceof BatchSQLOperation) {
eventBean = prepareSQLDbCommandEvent((BatchSQLOperation) operation, eventBean);
break;
} else if (operation instanceof NoSQLOperation) {
try {
eventBean = prepareNoSQLEvent(eventBean, (NoSQLOperation) operation);
} catch (Throwable e) {
return;
}
break;
}
break;

case DYNAMO_DB_COMMAND:
DynamoDBOperation dynamoDBOperation = (DynamoDBOperation) operation;
Expand Down

0 comments on commit a3abc13

Please sign in to comment.