Skip to content

Commit e15c452

Browse files
authored
use Aerospike Java client logger for alerts (#94)
1 parent 28e541e commit e15c452

File tree

2 files changed

+14
-5
lines changed

2 files changed

+14
-5
lines changed

src/main/java/com/aerospike/mapper/tools/AeroMapper.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import com.aerospike.client.*;
44
import com.aerospike.client.AerospikeException.ScanTerminated;
5-
import com.aerospike.client.Record;
65
import com.aerospike.client.policy.BatchPolicy;
76
import com.aerospike.client.policy.Policy;
87
import com.aerospike.client.policy.QueryPolicy;
@@ -117,7 +116,7 @@ private void loadConfiguration(@NotNull Configuration configuration, boolean all
117116
}
118117
} catch (RuntimeException re) {
119118
if (allowsInvalid) {
120-
System.err.println("Ignoring issue with configuration: " + re.getMessage());
119+
Log.warn("Ignoring issue with configuration: " + re.getMessage());
121120
} else {
122121
throw re;
123122
}

src/main/java/com/aerospike/mapper/tools/ReactiveAeroMapper.java

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,17 @@
11
package com.aerospike.mapper.tools;
22

3-
import com.aerospike.client.*;
4-
import com.aerospike.client.policy.*;
3+
import com.aerospike.client.AerospikeException;
4+
import com.aerospike.client.Bin;
5+
import com.aerospike.client.Key;
6+
import com.aerospike.client.Log;
7+
import com.aerospike.client.Operation;
8+
import com.aerospike.client.Value;
9+
import com.aerospike.client.policy.BatchPolicy;
10+
import com.aerospike.client.policy.Policy;
11+
import com.aerospike.client.policy.QueryPolicy;
12+
import com.aerospike.client.policy.RecordExistsAction;
13+
import com.aerospike.client.policy.ScanPolicy;
14+
import com.aerospike.client.policy.WritePolicy;
515
import com.aerospike.client.query.Filter;
616
import com.aerospike.client.query.KeyRecord;
717
import com.aerospike.client.query.Statement;
@@ -101,7 +111,7 @@ private void loadConfiguration(@NotNull Configuration configuration, boolean all
101111
}
102112
} catch (RuntimeException re) {
103113
if (allowsInvalid) {
104-
System.err.println("Ignoring issue with configuration: " + re.getMessage());
114+
Log.warn("Ignoring issue with configuration: " + re.getMessage());
105115
} else {
106116
throw re;
107117
}

0 commit comments

Comments
 (0)