public void statusUpdate(final String asgName, final ASGStatus newStatus) {
        long expiryTime = System.currentTimeMillis() + maxProcessingDelayMs;
        nonBatchingDispatcher.process(
                asgName,
                new AsgReplicationTask(targetHost, Action.StatusUpdate, asgName, newStatus) {
                    public EurekaHttpResponse<?> execute() {
                        return replicationClient.statusUpdate(asgName, newStatus);
                    }
                },
                expiryTime
        );
    }
@Test
    public void testAsgStatusUpdate() throws Throwable {
        createPeerEurekaNode().statusUpdate(instanceInfo.getASGName(), ASGStatus.DISABLED);

        Object newAsgStatus = expectRequestType(RequestType.AsgStatusUpdate);
        assertThat(newAsgStatus, is(equalTo((Object) ASGStatus.DISABLED)));
    }