Package | Description |
---|---|
io.openmessaging | |
io.openmessaging.interceptor | |
io.openmessaging.message |
Modifier and Type | Method and Description |
---|---|
KeyValue |
MessagingAccessPoint.attributes()
Returns the attributes of this
MessagingAccessPoint instance. |
static KeyValue |
OMS.newKeyValue()
Returns a default and internal
KeyValue implementation instance. |
KeyValue |
KeyValue.put(String key,
boolean value)
Inserts or replaces
boolean value for the specified key. |
KeyValue |
KeyValue.put(String key,
double value)
Inserts or replaces
double value for the specified key. |
KeyValue |
KeyValue.put(String key,
int value)
Inserts or replaces
int value for the specified key. |
KeyValue |
KeyValue.put(String key,
long value)
Inserts or replaces
long value for the specified key. |
KeyValue |
KeyValue.put(String key,
short value)
Inserts or replaces
short value for the specified key. |
KeyValue |
KeyValue.put(String key,
String value)
Inserts or replaces
String value for the specified key. |
Modifier and Type | Method and Description |
---|---|
PullConsumer |
MessagingAccessPoint.createPullConsumer(KeyValue attributes)
Creates a new
PullConsumer for the specified MessagingAccessPoint . |
PushConsumer |
MessagingAccessPoint.createPushConsumer(KeyValue attributes)
Creates a new
PushConsumer for the specified MessagingAccessPoint with some preset attributes. |
static MessagingAccessPoint |
OMS.getMessagingAccessPoint(String url,
KeyValue attributes)
Returns a
MessagingAccessPoint instance from the specified OMS driver url with some preset attributes,
which will be passed to MessagingAccessPoint's implementation class as a unique constructor parameter. |
Modifier and Type | Method and Description |
---|---|
KeyValue |
Context.attributes()
Returns the attributes of this
Context instance. |
Modifier and Type | Method and Description |
---|---|
KeyValue |
Message.properties()
Returns all the customized user header fields of the
Message object as a KeyValue . |
Copyright © 2017–2020 OpenMessaging. All rights reserved.