File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed
notifications/reactive/src/main/java/org/trellisldp/reactive Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change 1717
1818import static java .util .Objects .requireNonNull ;
1919import static org .eclipse .microprofile .reactive .messaging .Message .of ;
20+ import static org .slf4j .LoggerFactory .getLogger ;
2021
2122import io .reactivex .BackpressureStrategy ;
2223import io .reactivex .Flowable ;
2728
2829import org .eclipse .microprofile .reactive .messaging .Message ;
2930import org .eclipse .microprofile .reactive .messaging .Outgoing ;
31+ import org .slf4j .Logger ;
3032import org .trellisldp .api .*;
3133
3234/**
3537@ ApplicationScoped
3638public class ReactiveEventService implements EventService {
3739
40+ private static final Logger LOGGER = getLogger (ReactiveEventService .class );
41+
3842 public static final String REACTIVE_DESTINATION = "trellis" ;
3943
4044 private final EventSerializationService serializer ;
@@ -61,6 +65,7 @@ public ReactiveEventService(final EventSerializationService serializer) {
6165
6266 @ Override
6367 public void emit (final Event event ) {
68+ LOGGER .debug ("Sending message to reactive destination: {}" , event .getIdentifier ());
6469 subject .onNext (of (serializer .serialize (event )));
6570 }
6671
You can’t perform that action at this time.
0 commit comments