Package | Description |
---|---|
omq.common.message | |
omq.common.util | |
omq.common.util.Serializers |
Modifier and Type | Method and Description |
---|---|
static Request |
Request.newAsyncRequest(java.lang.String id,
java.lang.String method,
java.lang.Object[] params,
boolean multi)
This method creates a new asynchronous request
|
static Request |
Request.newSyncRequest(java.lang.String id,
java.lang.String method,
java.lang.Object[] params)
This method creates a new synchronous request
|
static Request |
Request.newSyncRequest(java.lang.String id,
java.lang.String method,
java.lang.Object[] params,
int retries,
long timeout,
boolean multi,
int wait)
This method creates a new synchronous request
|
Modifier and Type | Method and Description |
---|---|
Request |
Serializer.deserializeRequest(java.lang.String type,
byte[] bytes,
RemoteObject obj) |
Modifier and Type | Method and Description |
---|---|
Request |
JavaImp.deserializeRequest(byte[] bytes,
RemoteObject obj) |
Request |
ISerializer.deserializeRequest(byte[] bytes,
RemoteObject obj)
Deserialize a Request
|
Request |
GsonImp.deserializeRequest(byte[] bytes,
RemoteObject obj) |
Request |
KryoImp.deserializeRequest(byte[] bytes,
RemoteObject obj) |