abortStreamTransaction

Author: michele

src/main/java/com/arangodb/ArangoDatabase.java

@@ -595,6 +595,16 @@ GraphEntity createGraph(String name, Collection<EdgeDefinition> edgeDefinitions,
  */
 StreamTransactionEntity beginStreamTransaction(StreamTransactionOptions options) throws ArangoDBException;
 
+/**
+ * Aborts a Stream Transaction.
+ *
+ * @see <a href="https://docs.arangodb.com/current/HTTP/transaction-stream-transaction.html#abort-transaction">API
+ * Documentation</a>
+ * @return information about the transaction
+ * @throws ArangoDBException
+ */
+StreamTransactionEntity abortStreamTransaction(String id) throws ArangoDBException;
+
 /**
  * Retrieves information about the current database
  * 

src/main/java/com/arangodb/internal/ArangoDatabaseImpl.java

@@ -335,6 +335,11 @@ public StreamTransactionEntity beginStreamTransaction(StreamTransactionOptions o
  return executor.execute(beginStreamTransactionRequest(options), streamTransactionResponseDeserializer());
  }
 
+ @Override
+ public StreamTransactionEntity abortStreamTransaction(String id) throws ArangoDBException {
+ return executor.execute(abortStreamTransactionRequest(id), streamTransactionResponseDeserializer());
+ }
+
  @Override
  public DatabaseEntity getInfo() throws ArangoDBException {
  return executor.execute(getInfoRequest(), getInfoResponseDeserializer());

src/main/java/com/arangodb/internal/InternalArangoDatabase.java

@@ -378,6 +378,10 @@ protected Request beginStreamTransactionRequest(final StreamTransactionOptions o
  util().serialize(options != null ? options : new StreamTransactionOptions()));
  }
 
+ protected Request abortStreamTransactionRequest(String id) {
+ return request(name, RequestType.DELETE, PATH_API_TRANSACTION, id);
+ }
+
  protected ResponseDeserializer<StreamTransactionEntity> streamTransactionResponseDeserializer() {
  return new ResponseDeserializer<StreamTransactionEntity>() {
  @Override

src/test/java/com/arangodb/ArangoDatabaseTest.java

@@ -1406,6 +1406,20 @@ public void beginStreamTransactionWithNonExistingCollectionsShouldThrow() {
  db.beginStreamTransaction(new StreamTransactionOptions().writeCollections("notExistingCollection"));
  }
 
+ @Test
+ public void abortStreamTransaction() {
+ StreamTransactionEntity begunTx = db.beginStreamTransaction(null);
+ StreamTransactionEntity abortedTx = db.abortStreamTransaction(begunTx.getId());
+ assertThat(abortedTx.getId(), is(notNullValue()));
+ assertThat(abortedTx.getId(), is(begunTx.getId()));
+ assertThat(abortedTx.getStatus(), is(StreamTransactionEntity.StreamTransactionStatus.aborted));
+ }
+
+ @Test(expected = ArangoDBException.class)
+ public void abortStreamTransactionWhenTransactionIdDoesNotExistsShouldThrow() {
+ db.abortStreamTransaction("notExistingTransactionId");
+ }
+
  @Test
  public void getInfo() {
  final DatabaseEntity info = db.getInfo();