diff --git a/src/main/java/org/elasticsearch/alerts/AlertingModule.java b/src/main/java/org/elasticsearch/alerts/AlertingModule.java index 4b4eb3205e2..597b2c21230 100644 --- a/src/main/java/org/elasticsearch/alerts/AlertingModule.java +++ b/src/main/java/org/elasticsearch/alerts/AlertingModule.java @@ -15,6 +15,7 @@ import org.elasticsearch.alerts.rest.RestDeleteAlertAction; import org.elasticsearch.alerts.rest.RestGetAlertAction; import org.elasticsearch.alerts.rest.RestPutAlertAction; import org.elasticsearch.alerts.scheduler.AlertScheduler; +import org.elasticsearch.alerts.transport.actions.ack.TransportAckAlertAction; import org.elasticsearch.alerts.transport.actions.delete.TransportDeleteAlertAction; import org.elasticsearch.alerts.transport.actions.get.TransportGetAlertAction; import org.elasticsearch.alerts.transport.actions.put.TransportPutAlertAction; @@ -41,6 +42,7 @@ public class AlertingModule extends AbstractModule { bind(TransportDeleteAlertAction.class).asEagerSingleton(); bind(TransportGetAlertAction.class).asEagerSingleton(); bind(TransportAlertStatsAction.class).asEagerSingleton(); + bind(TransportAckAlertAction.class).asEagerSingleton(); bind(AlertsClient.class).to(NodeAlertsClient.class).asEagerSingleton(); // Rest layer diff --git a/src/main/java/org/elasticsearch/alerts/transport/actions/ack/AckAlertResponse.java b/src/main/java/org/elasticsearch/alerts/transport/actions/ack/AckAlertResponse.java index 5c917dddee6..e65310cd12f 100644 --- a/src/main/java/org/elasticsearch/alerts/transport/actions/ack/AckAlertResponse.java +++ b/src/main/java/org/elasticsearch/alerts/transport/actions/ack/AckAlertResponse.java @@ -46,7 +46,7 @@ public class AckAlertResponse extends ActionResponse { public void readFrom(StreamInput in) throws IOException { super.readFrom(in); if (in.readBoolean()) { - AlertAckState.fromString(in.readString()); + alertAckState = AlertAckState.fromString(in.readString()); } }