| Modifier and Type | Method | Description |
|---|---|---|
void |
API.forward_(Integer request_type,
String name,
byte[] request_info,
byte[] request,
Integer timeout,
Byte priority,
byte[] trans_id,
com.ericsson.otp.erlang.OtpErlangPid pid) |
Forward a message to another service
subscribed that matches the destination service
name. |
ArrayList<API.TransId> |
API.mcast_async(String name,
byte[] request) |
Asynchronous point-multicast communication to services
subscribed that matches the destination service
name. |
ArrayList<API.TransId> |
API.mcast_async(String name,
byte[] request_info,
byte[] request,
Integer timeout,
Byte priority) |
Asynchronous point-multicast communication to services
subscribed that matches the destination service
name. |
Object |
API.poll() |
|
Object |
API.poll(int timeout) |
|
API.Response |
API.recv_async() |
Asynchronously receive a response.
|
API.Response |
API.recv_async(boolean consume) |
Asynchronously receive a response.
|
API.Response |
API.recv_async(byte[] trans_id) |
Asynchronously receive a response.
|
API.Response |
API.recv_async(byte[] trans_id,
boolean consume) |
Asynchronously receive a response.
|
API.Response |
API.recv_async(Integer timeout) |
Asynchronously receive a response.
|
API.Response |
API.recv_async(Integer timeout,
boolean consume) |
Asynchronously receive a response.
|
API.Response |
API.recv_async(Integer timeout,
byte[] trans_id) |
Asynchronously receive a response.
|
API.Response |
API.recv_async(Integer timeout,
byte[] trans_id,
boolean consume) |
Asynchronously receive a response.
|
void |
API.return_(Integer request_type,
String name,
String pattern,
byte[] response_info,
byte[] response,
Integer timeout,
byte[] trans_id,
com.ericsson.otp.erlang.OtpErlangPid pid) |
Returns a response from a service request.
|
API.TransId |
API.send_async(String name,
byte[] request) |
Asynchronous point-to-point communication to a service
subscribed that matches the destination service
name. |
API.TransId |
API.send_async(String name,
byte[] request_info,
byte[] request,
Integer timeout,
Byte priority) |
Asynchronous point-to-point communication to a service
subscribed that matches the destination service
name. |
API.Response |
API.send_sync(String name,
byte[] request) |
Synchronous point-to-point communication to a service
subscribed that matches the destination service
name. |
API.Response |
API.send_sync(String name,
byte[] request_info,
byte[] request,
Integer timeout,
Byte priority) |
Synchronous point-to-point communication to a service
subscribed that matches the destination service
name. |
int |
API.subscribe_count(String pattern) |
Determine how may service name pattern subscriptions have occurred.
|
static int |
API.thread_count() |
|
void |
API.unsubscribe(String pattern) |
Unsubscribes from a service name pattern.
|
| Constructor | Description |
|---|---|
API(int thread_index) |
Copyright © 2018. All rights reserved.