getStreamTransaction

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

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

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

@@ -340,6 +340,11 @@ public StreamTransactionEntity abortStreamTransaction(String id) throws ArangoDB
  return executor.execute(abortStreamTransactionRequest(id), streamTransactionResponseDeserializer());
  }
 
+ @Override
+ public StreamTransactionEntity getStreamTransaction(String id) throws ArangoDBException {
+ return executor.execute(getStreamTransactionRequest(id), streamTransactionResponseDeserializer());
+ }
+
  @Override
  public DatabaseEntity getInfo() throws ArangoDBException {
  return executor.execute(getInfoRequest(), getInfoResponseDeserializer());

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

@@ -382,6 +382,10 @@ protected Request abortStreamTransactionRequest(String id) {
  return request(name, RequestType.DELETE, PATH_API_TRANSACTION, id);
  }
 
+ protected Request getStreamTransactionRequest(String id) {
+ return request(name, RequestType.GET, PATH_API_TRANSACTION, id);
+ }
+
  protected ResponseDeserializer<StreamTransactionEntity> streamTransactionResponseDeserializer() {
  return new ResponseDeserializer<StreamTransactionEntity>() {
  @Override

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

@@ -1399,6 +1399,7 @@ public void beginStreamTransaction() {
  StreamTransactionEntity tx = db.beginStreamTransaction(null);
  assertThat(tx.getId(), is(notNullValue()));
  assertThat(tx.getStatus(), is(StreamTransactionEntity.StreamTransactionStatus.running));
+ db.abortStreamTransaction(tx.getId());
  }
 
  @Test(expected = ArangoDBException.class)
@@ -1425,6 +1426,25 @@ public void abortStreamTransactionWithInvalidTransactionIdShouldThrow() {
  db.abortStreamTransaction("invalidTransactionId");
  }
 
+ @Test
+ public void getStreamTransaction() {
+ StreamTransactionEntity createdTx = db.beginStreamTransaction(null);
+ StreamTransactionEntity gotTx = db.getStreamTransaction(createdTx.getId());
+ assertThat(gotTx.getId(), is(notNullValue()));
+ assertThat(gotTx.getStatus(), is(StreamTransactionEntity.StreamTransactionStatus.running));
+ db.abortStreamTransaction(createdTx.getId());
+ }
+
+ @Test(expected = ArangoDBException.class)
+ public void getStreamTransactionWhenTransactionIdDoesNotExistsShouldThrow() {
+ db.getStreamTransaction("000000");
+ }
+
+ @Test(expected = ArangoDBException.class)
+ public void getStreamTransactionWithInvalidTransactionIdShouldThrow() {
+ db.getStreamTransaction("invalidTransactionId");
+ }
+
  @Test
  public void getInfo() {
  final DatabaseEntity info = db.getInfo();