killbill-memoizeit

notifications: trivial fixes in PushNotificationListener Signed-off-by:

7/1/2014 7:45:04 PM

Details

diff --git a/profiles/killbill/src/main/java/org/killbill/billing/server/notifications/PushNotificationListener.java b/profiles/killbill/src/main/java/org/killbill/billing/server/notifications/PushNotificationListener.java
index 83b4e78..f7342cd 100644
--- a/profiles/killbill/src/main/java/org/killbill/billing/server/notifications/PushNotificationListener.java
+++ b/profiles/killbill/src/main/java/org/killbill/billing/server/notifications/PushNotificationListener.java
@@ -49,7 +49,7 @@ public class PushNotificationListener {
 
     private static final Logger log = LoggerFactory.getLogger(PushNotificationListener.class);
 
-    private static final int TIMEOUT_NOTIFCATION = 15; // 15 seconds
+    private static final int TIMEOUT_NOTIFICATION = 15; // 15 seconds
 
     private final TenantUserApi tenantApi;
     private final CallContextFactory contextFactory;
@@ -58,7 +58,7 @@ public class PushNotificationListener {
 
     @Inject
     public PushNotificationListener(final ObjectMapper mapper, final TenantUserApi tenantApi, final CallContextFactory contextFactory) {
-        this.httpClient = new AsyncHttpClient(new AsyncHttpClientConfig.Builder().setRequestTimeoutInMs(TIMEOUT_NOTIFCATION * 1000).build());
+        this.httpClient = new AsyncHttpClient(new AsyncHttpClientConfig.Builder().setRequestTimeoutInMs(TIMEOUT_NOTIFICATION * 1000).build());
         this.tenantApi = tenantApi;
         this.contextFactory = contextFactory;
         this.mapper = mapper;
@@ -78,11 +78,11 @@ public class PushNotificationListener {
         }
     }
 
-    private void dispatchCallback(final UUID tenantId, final ExtBusEvent event, final List<String> callbacks) throws IOException {
+    private void dispatchCallback(final UUID tenantId, final ExtBusEvent event, final Iterable<String> callbacks) throws IOException {
         final NotificationJson notification = new NotificationJson(event);
         final String body = mapper.writeValueAsString(notification);
         for (final String cur : callbacks) {
-            doPost(tenantId, cur, body, TIMEOUT_NOTIFCATION);
+            doPost(tenantId, cur, body, TIMEOUT_NOTIFICATION);
         }
     }
 
@@ -102,7 +102,7 @@ public class PushNotificationListener {
                     });
             response = futureStatus.get(timeoutSec, TimeUnit.SECONDS);
         } catch (final Exception e) {
-            log.warn(String.format("Fail to psh notification {} for the tenant {} ", url, tenantId), e);
+            log.warn(String.format("Failed to push notification %s for the tenant %s", url, tenantId), e);
             return false;
         }
         return response.getStatusCode() >= 200 && response.getStatusCode() < 300;