io.mats3.util

Class MatsFuturizer.Promise<T>

java.lang.Object

io.mats3.util.MatsFuturizer.Promise<T>

All Implemented Interfaces:

java.lang.Comparable<MatsFuturizer.Promise<?>>

Enclosing class:

MatsFuturizer

protected static class MatsFuturizer.Promise<T>
extends java.lang.Object
implements java.lang.Comparable<MatsFuturizer.Promise<?>>

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	_correlationId
java.lang.String	_from
java.util.concurrent.CompletableFuture<MatsFuturizer.Reply<T>>	_future
long	_initiationTimestamp
java.lang.Class<T>	_replyClass
long	_timeoutTimestamp
java.lang.String	_to
java.lang.String	_traceId

Constructor Summary

Constructors

Constructor and Description
Promise(java.lang.String traceId, java.lang.String correlationId, java.lang.String from, java.lang.String to, long initiationTimestamp, long timeoutTimestamp, java.lang.Class<T> replyClass, java.util.concurrent.CompletableFuture<MatsFuturizer.Reply<T>> future)

Method Summary

Modifier and Type	Method and Description
int	compareTo(MatsFuturizer.Promise<?> o)

Methods inherited from class java.lang.Object

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

Field Detail

_traceId

public final java.lang.String _traceId

_correlationId

public final java.lang.String _correlationId

_from

public final java.lang.String _from

_to

public final java.lang.String _to

_initiationTimestamp

public final long _initiationTimestamp

_timeoutTimestamp

public final long _timeoutTimestamp

_replyClass

public final java.lang.Class<T> _replyClass

_future

public final java.util.concurrent.CompletableFuture<MatsFuturizer.Reply<T>> _future

Constructor Detail

Promise

public Promise(java.lang.String traceId,
               java.lang.String correlationId,
               java.lang.String from,
               java.lang.String to,
               long initiationTimestamp,
               long timeoutTimestamp,
               java.lang.Class<T> replyClass,
               java.util.concurrent.CompletableFuture<MatsFuturizer.Reply<T>> future)

Method Detail

compareTo

public int compareTo(MatsFuturizer.Promise<?> o)

Specified by:

compareTo in interface java.lang.Comparable<MatsFuturizer.Promise<?>>