File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -90,7 +90,8 @@ struct EventObserver {
90
90
endpoint : String ,
91
91
/// Timeout for sending events to this observer
92
92
timeout : Duration ,
93
- /// force observers to not retry on error
93
+ /// If true, the stacks-node will not retry if event delivery fails for any reason.
94
+ /// WARNING: This should not be set on observers that require successful delivery of all events.
94
95
disable_retries : bool ,
95
96
}
96
97
@@ -1690,6 +1691,10 @@ impl EventDispatcher {
1690
1691
conf. disable_retries ,
1691
1692
) ;
1692
1693
1694
+ if conf. disable_retries {
1695
+ warn ! ( "Observer {} is configured in \" disable_retries\" mode: events are not granted to be delivered" , conf. endpoint) ;
1696
+ }
1697
+
1693
1698
let observer_index = self . registered_observers . len ( ) as u16 ;
1694
1699
1695
1700
for event_key_type in conf. events_keys . iter ( ) {
You can’t perform that action at this time.
0 commit comments