net.bluemind.imap.vertx

Class VXStoreClient

java.lang.Object

net.bluemind.imap.vertx.VXStoreClient

All Implemented Interfaces:

IAsyncStoreClient

public class VXStoreClient
extends java.lang.Object
implements IAsyncStoreClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VXStoreClient.Decoder

Constructor Summary

Constructors

Constructor and Description
VXStoreClient(IConnectionSupport conSupport, java.lang.String host, int port, java.lang.String login, java.lang.String password)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<ImapResponseStatus<AppendResponse>>	append(java.lang.String mailbox, java.util.Date receivedDate, java.util.Collection<java.lang.String> flags, int streamSize, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> eml)
java.util.concurrent.CompletableFuture<java.lang.Void>	close()
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long uid, java.lang.String part, VXStoreClient.Decoder dec)
java.util.concurrent.CompletableFuture<java.lang.Void>	fetch(long uid, java.lang.String part, io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> target, VXStoreClient.Decoder dec)
boolean	isClosed()
java.util.concurrent.CompletableFuture<ImapResponseStatus<java.lang.Void>>	login()
java.util.concurrent.CompletableFuture<ImapResponseStatus<SelectResponse>>	select(java.lang.String mailbox)

Methods inherited from class java.lang.Object

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

Constructor Detail

VXStoreClient

public VXStoreClient(IConnectionSupport conSupport,
                     java.lang.String host,
                     int port,
                     java.lang.String login,
                     java.lang.String password)

Method Detail

login

public java.util.concurrent.CompletableFuture<ImapResponseStatus<java.lang.Void>> login()

select

public java.util.concurrent.CompletableFuture<ImapResponseStatus<SelectResponse>> select(java.lang.String mailbox)

Specified by:

select in interface IAsyncStoreClient

fetch

public java.util.concurrent.CompletableFuture<java.lang.Void> fetch(long uid,
                                                                    java.lang.String part,
                                                                    io.vertx.core.streams.WriteStream<io.vertx.core.buffer.Buffer> target,
                                                                    VXStoreClient.Decoder dec)

Specified by:

fetch in interface IAsyncStoreClient

fetch

public io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> fetch(long uid,
                                                                           java.lang.String part,
                                                                           VXStoreClient.Decoder dec)

Specified by:

fetch in interface IAsyncStoreClient

append

public java.util.concurrent.CompletableFuture<ImapResponseStatus<AppendResponse>> append(java.lang.String mailbox,
                                                                                         java.util.Date receivedDate,
                                                                                         java.util.Collection<java.lang.String> flags,
                                                                                         int streamSize,
                                                                                         io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> eml)

Specified by:

append in interface IAsyncStoreClient

close

public java.util.concurrent.CompletableFuture<java.lang.Void> close()

Specified by:

close in interface IAsyncStoreClient

isClosed

public boolean isClosed()

Specified by:

isClosed in interface IAsyncStoreClient