24
24
import org .pf4j .PluginManager ;
25
25
import org .tron .common .logsfilter .IPluginEventListener ;
26
26
import org .tron .common .logsfilter .trigger .BlockLogTrigger ;
27
- import org .tron .common .logsfilter .trigger .ContractEventTrigger ;
28
27
import org .tron .common .logsfilter .trigger .Trigger ;
29
28
30
29
import java .io .File ;
@@ -35,16 +34,16 @@ public class PluginLauncher {
35
34
private static final Logger logger = LoggerFactory .getLogger (PluginLauncher .class );
36
35
37
36
public static void main (String [] args ) {
38
- String path = "/Users/tron/workplace/java-tronSubmit/java-tronUseSubmit/develop_event_subscribe/ eventplugin/build/plugins/plugin-mongodb-1.0.0.zip" ; // absolute path of plugin
37
+ String path = "/Users/tron/sourcecode/ eventplugin/build/plugins/plugin-mongodb-1.0.0.zip" ;
39
38
40
39
File dir = new File (path );
41
40
// create the plugin manager
42
41
final PluginManager pluginManager = new DefaultPluginManager (dir .toPath ()) {
43
- @ Override
44
- protected CompoundPluginDescriptorFinder createPluginDescriptorFinder () {
45
- return new CompoundPluginDescriptorFinder ()
46
- .add (new ManifestPluginDescriptorFinder ());
47
- }
42
+ @ Override
43
+ protected CompoundPluginDescriptorFinder createPluginDescriptorFinder () {
44
+ return new CompoundPluginDescriptorFinder ()
45
+ .add (new ManifestPluginDescriptorFinder ());
46
+ }
48
47
};
49
48
50
49
File file = new File (path );
@@ -58,7 +57,7 @@ protected CompoundPluginDescriptorFinder createPluginDescriptorFinder() {
58
57
if (Objects .isNull (eventListeners )) return ;
59
58
60
59
eventListeners .forEach (listener -> {
61
- listener .setServerAddress ("47.90.245.68 :27017" );
60
+ listener .setServerAddress ("127.0.0.1 :27017" );
62
61
});
63
62
64
63
eventListeners .forEach (listener -> {
@@ -78,12 +77,15 @@ protected CompoundPluginDescriptorFinder createPluginDescriptorFinder() {
78
77
79
78
ObjectMapper objectMapper = new ObjectMapper ();
80
79
for (int index = 0 ; index < 1000 ; ++index ){
81
- ContractEventTrigger trigger = new ContractEventTrigger ();
82
- trigger .setRemoved (true );
83
- trigger .setTriggerName ();
80
+ BlockLogTrigger trigger = new BlockLogTrigger ();
81
+ trigger .setBlockNumber (index );
82
+ trigger .setBlockHash ("000000000002f5834df6036318999576bfa23ff1a57e0538fa87d5a90319659e" );
83
+ trigger .setTimeStamp (System .currentTimeMillis ());
84
+ trigger .setTransactionSize (100 );
85
+
84
86
eventListeners .forEach (listener -> {
85
87
try {
86
- listener .handleContractEventTrigger (objectMapper .writeValueAsString (trigger ));
88
+ listener .handleBlockEvent (objectMapper .writeValueAsString (trigger ));
87
89
} catch (com .fasterxml .jackson .core .JsonProcessingException e ) {
88
90
e .printStackTrace ();
89
91
}
0 commit comments