https://twitter.com/dehora/status/193490785763737600
https://twitter.com/dehora/status/193488171068162048
https://twitter.com/dehora/status/193485949383094272
export JAVA_HOME=$(/usr/libexec/java_home -v 1.7) |
diff --git a/build.gradle b/build.gradle | |
index b514ac8..b548f75 100644 | |
--- a/build.gradle | |
+++ b/build.gradle | |
@@ -41,6 +41,7 @@ subprojects { | |
uploadArchives { | |
repositories { | |
signing { | |
+ required = false | |
sign configurations.archives |
@Inject | |
@Context | |
private HttpContext httpContext; | |
@Inject | |
@Context | |
private HttpHeaders headers; | |
@Inject | |
@Context |
public class MetricRegistryModule extends AbstractModule { | |
private MetricRegistry metricsRegistry; | |
public MetricRegistryModule(MetricRegistry metricsRegistry) { | |
this.metricsRegistry = metricsRegistry; | |
} | |
@Override | |
protected void configure() { |
/* | |
before: wrap calls in try/finally | |
*/ | |
@Override | |
public Notification readNotification(String appID, String notificationID) { | |
final Timer.Context time = readTimer.time(); | |
try { | |
return notificationStore.read(appID, notificationID).getNotification(); | |
} finally { |
@POST
@Path("/{id: [0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}}/ping")
public Response pingSubscription(@PathParam("id") String id) throws Exception {
final Optional<Subscription> sub = subscriptionService.loadSubscription(id);
if (sub.isPresent()) {
return Response.ok(eventDeliveryService.sendPingEvent(sub.get())).build();
} else {
@Override | |
public SubscriptionList loadSubscriptions(String id) { | |
final Set<String> keys = jedisProvider.get().smembers(createSubscriptionsKey(id)); | |
final List<Subscription> subs = keys.stream().map(this::getSubscription).collect(Collectors.toList()); | |
return new SubscriptionList(subs); | |
} |
package org.example; | |
import java.util.List; | |
import java.util.ArrayList; | |
public class ErrorListResponse { | |
public static final String TYPE = "error.list"; |