| Package | Description |
|---|---|
| org.cloudi |
| Modifier and Type | Method and Description |
|---|---|
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. |
boolean |
API.poll()
Blocks to process incoming CloudI service requests
|
boolean |
API.poll(int timeout)
Blocks to process incoming CloudI service requests
|
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.
|
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.
|
| Constructor and Description |
|---|
API(int thread_index) |
Copyright © 2020. All rights reserved.