Skip to content
This repository was archived by the owner on Feb 10, 2025. It is now read-only.

Commit 3ba2876

Browse files
add logs
1 parent 9e73faa commit 3ba2876

File tree

3 files changed

+4
-1
lines changed

3 files changed

+4
-1
lines changed

sor-api/src/main/java/com/bazaarvoice/emodb/sor/api/DataStore.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,6 @@ URI getStashRoot()
266266
* This method is a no-op in the default implementation. It is used by the Databus to update the reference
267267
*/
268268
default void updateRefInDatabus(List<String> updateRefs) {
269-
269+
System.out.println("Inside Default updateRefInDatabus");
270270
}
271271
}

sor/src/main/java/com/bazaarvoice/emodb/sor/core/DefaultDataStore.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1047,6 +1047,7 @@ private String getMetricName(String name) {
10471047

10481048
@Override
10491049
public void updateRefInDatabus(List<String> updateRefsModel) {
1050+
_log.info("Started Writing to Databus in DefaultDataStore");
10501051
try {
10511052
List<UpdateRef> updateRefModelList = updateRefsModel.stream()
10521053
.map(string -> {

web/src/main/java/com/bazaarvoice/emodb/web/resources/sor/DataStoreResource1.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -945,8 +945,10 @@ private Response redirectTo(DataCenter dataCenter, URI requestUri) {
945945
)
946946
public SuccessResponse updateRefToDatabus(List<String> updateRefs,
947947
@Authenticated Subject subject) {
948+
_log.info("Inside updateRefToDatabus datastore : {}", _dataStore.getClass().getName());
948949
// Perform the update by writing to Databus
949950
_dataStore.updateRefInDatabus(updateRefs);
951+
_log.info("Finished updateRefToDatabus updateRefs : {}", updateRefs);
950952
return SuccessResponse.instance();
951953
}
952954

0 commit comments

Comments
 (0)