@@ -37,10 +37,14 @@ def generate_feed(newitem)
37
37
end
38
38
39
39
def create_session_item ( session , status )
40
- status = "created" ? select ( nil , nil , nil , 25 ) : ""
40
+ if status == "created"
41
+ select ( nil , nil , nil , 25 )
42
+ end
41
43
title = "#{ session . type } session - #{ session . sid } #{ status } ."
42
44
content = ""
43
- session . workspace ? content << "Workspace:\t #{ session . workspace } \n " : ""
45
+ if session . workspace
46
+ content << "Workspace:\t #{ session . workspace } \n "
47
+ end
44
48
content << "Session Information: #{ session . info } "
45
49
add_event ( { title : title , date : Time . now . to_s , link : "https://metasploit.com" , content : content } )
46
50
end
@@ -65,7 +69,7 @@ def on_plugin_unload
65
69
end
66
70
67
71
def start_event_queue
68
- self . queue_thread = Thread . new do
72
+ self . queue_thread = Rex :: ThreadFactory . spawn ( "rss_plugin" , false ) do
69
73
begin
70
74
while ( true )
71
75
while ( event = self . queue . shift )
@@ -82,7 +86,7 @@ def start_event_queue
82
86
def stop_event_queue
83
87
self . queue_thread . kill if self . queue_thread
84
88
self . queue_thread = nil
85
- self . queue = [ ]
89
+ self . queue . clear
86
90
end
87
91
88
92
@@ -91,7 +95,7 @@ def initialize(framework, opts)
91
95
super
92
96
93
97
@items = [ ]
94
- self . queue = [ ]
98
+ self . queue = Queue . new
95
99
self . framework . events . add_session_subscriber ( self )
96
100
start_event_queue
97
101
0 commit comments