default <T> void |
CacheSource.subscribe(Type messageType,
CacheEventListener<T> listener,
String... topics) |
|
default <T> void |
CacheSource.subscribe(Convert convert,
Type messageType,
CacheEventListener<T> listener,
String... topics) |
|
default void |
CacheSource.subscribe(CacheEventListener<byte[]> listener,
String... topics) |
|
CompletableFuture<Void> |
CacheMemorySource.subscribeAsync(CacheEventListener<byte[]> listener,
String... topics) |
|
default <T> CompletableFuture<Void> |
CacheSource.subscribeAsync(Type messageType,
CacheEventListener<T> listener,
String... topics) |
|
default <T> CompletableFuture<Void> |
CacheSource.subscribeAsync(Convert convert,
Type messageType,
CacheEventListener<T> listener,
String... topics) |
|
CompletableFuture<Void> |
CacheSource.subscribeAsync(CacheEventListener<byte[]> listener,
String... topics) |
|
default void |
CacheSource.unsubscribe(CacheEventListener listener,
String... topics) |
|
CompletableFuture<Integer> |
CacheMemorySource.unsubscribeAsync(CacheEventListener listener,
String... topics) |
|
CompletableFuture<Integer> |
CacheSource.unsubscribeAsync(CacheEventListener listener,
String... topics) |
|