Package | Description |
---|---|
org.nuxeo.lib.stream.pattern |
Here is a producer consumer pattern that relies on Log.
|
Modifier and Type | Field and Description |
---|---|
static KeyValueMessage |
KeyValueMessage.POISON_PILL |
Modifier and Type | Method and Description |
---|---|
static KeyValueMessage |
KeyValueMessage.of(String key) |
static KeyValueMessage |
KeyValueMessage.of(String key,
byte[] value) |
static KeyValueMessage |
KeyValueMessage.ofForceBatch(String key) |
static KeyValueMessage |
KeyValueMessage.ofForceBatch(String key,
byte[] value)
A message that force the batch.
|
Copyright © 2018 Nuxeo. All rights reserved.