Beacon implementation

TIER · Jan 15, 2020 · 8453a69 · 8453a69
1 parent 003b63e
commit 8453a69
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/beacon/core/src/main/java/edu/internet2/tap/beacon/DefaultBeaconPublisher.java b/beacon/core/src/main/java/edu/internet2/tap/beacon/DefaultBeaconPublisher.java
@@ -81,12 +81,12 @@ public void run() {
 
     }
 
-    //Below are package-private getters used in unit tests
-    String getEndpointUri() {
+    //getters used in unit tests and calling components for debugging purposes
+    public String getEndpointUri() {
         return enpointUrl.toString();
     }
 
-    String getJsonPayload() {
+    public String getJsonPayload() {
         return jsonPayload;
     }
 }
diff --git a/...g/src/main/java/edu/internet2/tap/beacon/configuration/BeaconPublishingConfiguration.java b/...g/src/main/java/edu/internet2/tap/beacon/configuration/BeaconPublishingConfiguration.java
@@ -1,6 +1,5 @@
 package edu.internet2.tap.beacon.configuration;
 
-import edu.internet2.tap.beacon.BeaconPublisher;
 import edu.internet2.tap.beacon.DefaultBeaconPublisher;
 import edu.internet2.tap.beacon.configuration.condition.ConditionalOnBeaconEnvironmentVariablesPresent;
 import org.slf4j.Logger;
@@ -43,17 +42,19 @@ public BeaconPublishingTask beaconPublisher(Environment env) {
     }
 
     public static class BeaconPublishingTask {
+        private DefaultBeaconPublisher beaconPublisher;
 
-        private BeaconPublisher beaconPublisher;
-
-        public BeaconPublishingTask(BeaconPublisher beaconPublisher) {
+        public BeaconPublishingTask(DefaultBeaconPublisher beaconPublisher) {
             this.beaconPublisher = beaconPublisher;
         }
 
         //Cron is based on the spec defined here: https://spaces.at.internet2.edu/display/TWGH/TIER+Instrumentation+-+The+TIER+Beacon
         @Scheduled(cron = "0 ${random.int[0,59]} ${random.int[0,3]} ? * *}")
         @Async
         void publish() {
+            logger.debug("Publishing payload: {} to beacon endpoint: {}",
+                    beaconPublisher.getJsonPayload(),
+                    beaconPublisher.getEndpointUri());
             beaconPublisher.run();
         }
     }