net.bluemind.backend.cyrus.replication.storage.mock

Class MockMessageBodiesPromise

java.lang.Object

net.bluemind.backend.cyrus.replication.storage.mock.MockMessageBodiesPromise

All Implemented Interfaces:

IDbMessageBodiesPromise

public class MockMessageBodiesPromise
extends java.lang.Object
implements IDbMessageBodiesPromise

Constructor Summary

Constructors

Constructor and Description
MockMessageBodiesPromise(java.lang.String partition)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	create(java.lang.String uid, Stream eml)
java.util.concurrent.CompletableFuture<java.lang.Void>	delete(java.lang.String uid)
java.util.concurrent.CompletableFuture<java.lang.Boolean>	exists(java.lang.String uid)
java.util.concurrent.CompletableFuture<MessageBody>	getComplete(java.lang.String uid)
java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>>	missing(java.util.List<java.lang.String> toCheck)
java.util.concurrent.CompletableFuture<java.util.List<MessageBody>>	multiple(java.util.List<java.lang.String> uid)
java.util.concurrent.CompletableFuture<java.lang.Void>	update(MessageBody body)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MockMessageBodiesPromise

public MockMessageBodiesPromise(java.lang.String partition)

Method Detail

multiple

public java.util.concurrent.CompletableFuture<java.util.List<MessageBody>> multiple(java.util.List<java.lang.String> uid)

Specified by:

multiple in interface IDbMessageBodiesPromise

update

public java.util.concurrent.CompletableFuture<java.lang.Void> update(MessageBody body)

Specified by:

update in interface IDbMessageBodiesPromise

delete

public java.util.concurrent.CompletableFuture<java.lang.Void> delete(java.lang.String uid)

Specified by:

delete in interface IDbMessageBodiesPromise

getComplete

public java.util.concurrent.CompletableFuture<MessageBody> getComplete(java.lang.String uid)

Specified by:

getComplete in interface IDbMessageBodiesPromise

missing

public java.util.concurrent.CompletableFuture<java.util.List<java.lang.String>> missing(java.util.List<java.lang.String> toCheck)

Specified by:

missing in interface IDbMessageBodiesPromise

create

public java.util.concurrent.CompletableFuture<java.lang.Void> create(java.lang.String uid,
                                                                     Stream eml)

Specified by:

create in interface IDbMessageBodiesPromise

exists

public java.util.concurrent.CompletableFuture<java.lang.Boolean> exists(java.lang.String uid)

Specified by:

exists in interface IDbMessageBodiesPromise