gistfile1.java

public class WriteRequest extends AbstractWriteRequest<Integer> {

	private static final int timeout = 1000;

	private NodeMapDriver driver;
	protected volatile int sequenceNumber;

	public WriteRequest(NodeMapDriver driver, List<? extends WriteItem> items) {
		super(items, timeout);

		this.driver = driver;
	}

	@Override
	public Object getKey() {
		return sequenceNumber;
	}

	@Override
	public boolean sendMessage() {
		sequenceNumber = driver.getTransactionSequence().next();

		driver.getExecutionManager().executeOnce(new Runnable() {
			@Override
			public void run() {
				driver.messageDone(sequenceNumber);
			}
		});

		return true;
	}

	@Override
	public ReceiveAction receiveMessage(Integer message, Object key) {
		for (WriteItem item : items) {
			item.setWriteStatus(StatusCode.BAD_NOT_WRITABLE);
		}

		return ReceiveAction.Done;
	}

}