File tree Expand file tree Collapse file tree 7 files changed +27
-20
lines changed
api/src/main/java/org/tron/common/logsfilter/trigger
kafkaplugin/src/main/java/org/tron/eventplugin
mongodbplugin/src/main/java/org/tron/eventplugin Expand file tree Collapse file tree 7 files changed +27
-20
lines changed Original file line number Diff line number Diff line change 1
1
package org .tron .common .logsfilter .trigger ;
2
2
3
- import java .util .ArrayList ;
4
- import java .util .List ;
5
3
import lombok .Getter ;
6
4
import lombok .Setter ;
7
5
6
+ import java .util .ArrayList ;
7
+ import java .util .List ;
8
+
8
9
public class BlockLogTrigger extends Trigger {
9
10
@ Getter
10
11
@ Setter
Original file line number Diff line number Diff line change 1
1
package org .tron .common .logsfilter .trigger ;
2
2
3
- import java .util .Map ;
4
3
import lombok .Getter ;
5
4
import lombok .Setter ;
6
5
6
+ import java .util .Map ;
7
+
7
8
public class ContractEventTrigger extends ContractTrigger {
8
9
9
10
/**
Original file line number Diff line number Diff line change 1
1
package org .tron .common .logsfilter .trigger ;
2
2
3
- import java .util .List ;
4
3
import lombok .Getter ;
5
4
import lombok .Setter ;
6
5
6
+ import java .util .List ;
7
+
7
8
public class ContractLogTrigger extends ContractTrigger {
8
9
/**
9
10
* topic list produced by the smart contract LOG function
Original file line number Diff line number Diff line change 1
1
package org .tron .common .logsfilter .trigger ;
2
2
3
- import java .util .HashMap ;
4
- import java .util .Map ;
5
3
import lombok .Getter ;
6
4
import lombok .Setter ;
7
5
6
+ import java .util .HashMap ;
7
+ import java .util .Map ;
8
+
8
9
public class InternalTransactionPojo {
9
10
10
11
@ Getter
Original file line number Diff line number Diff line change 1
1
package org .tron .common .logsfilter .trigger ;
2
2
3
- import java .util .ArrayList ;
4
- import java .util .List ;
5
3
import lombok .Getter ;
6
4
import lombok .Setter ;
7
5
6
+ import java .util .List ;
7
+
8
8
public class TransactionLogTrigger extends Trigger {
9
9
10
10
@ Override
@@ -97,7 +97,7 @@ public void setTimeStamp(long ts) {
97
97
98
98
@ Getter
99
99
@ Setter
100
- private long removed ;
100
+ private boolean removed ;
101
101
102
102
public TransactionLogTrigger () {
103
103
setTriggerName (Trigger .TRANSACTION_TRIGGER_NAME );
Original file line number Diff line number Diff line change 1
1
package org .tron .eventplugin ;
2
- import org .apache .kafka .clients .producer .*;
2
+
3
+ import org .apache .kafka .clients .producer .Callback ;
4
+ import org .apache .kafka .clients .producer .KafkaProducer ;
5
+ import org .apache .kafka .clients .producer .ProducerRecord ;
6
+ import org .apache .kafka .clients .producer .RecordMetadata ;
3
7
import org .slf4j .Logger ;
4
8
import org .slf4j .LoggerFactory ;
5
9
Original file line number Diff line number Diff line change 1
1
package org .tron .eventplugin ;
2
+
2
3
import com .alibaba .fastjson .JSONObject ;
3
4
import org .pf4j .util .StringUtils ;
4
-
5
- import java .io .IOException ;
6
- import java .io .InputStream ;
7
- import java .util .concurrent .ExecutorService ;
8
- import java .util .concurrent .Executors ;
9
-
10
5
import org .slf4j .Logger ;
11
6
import org .slf4j .LoggerFactory ;
12
- import java .util .*;
13
- import java .util .concurrent .BlockingQueue ;
14
- import java .util .concurrent .LinkedBlockingQueue ;
15
- import java .util .concurrent .TimeUnit ;
16
7
import org .tron .mongodb .MongoConfig ;
17
8
import org .tron .mongodb .MongoManager ;
18
9
import org .tron .mongodb .MongoTemplate ;
19
10
11
+ import java .io .IOException ;
12
+ import java .io .InputStream ;
13
+ import java .util .HashMap ;
14
+ import java .util .Map ;
15
+ import java .util .Objects ;
16
+ import java .util .Properties ;
17
+ import java .util .concurrent .*;
18
+
20
19
public class MongodbSenderImpl {
21
20
private static MongodbSenderImpl instance = null ;
22
21
private static final Logger log = LoggerFactory .getLogger (MongodbSenderImpl .class );
You can’t perform that action at this time.
0 commit comments