Package org.dbos.apiary.client

Class InternalApiaryWorkerClient

java.lang.Object

org.dbos.apiary.client.InternalApiaryWorkerClient

public class InternalApiaryWorkerClient
extends Object

For internal use only. This class is not thread-safe.

Constructor Summary

Constructors

Constructor	Description
InternalApiaryWorkerClient(org.zeromq.ZContext zContext)

Method Summary

Modifier and Type	Method	Description
FunctionOutput	executeFunction(String address, String name, String service, long execID, Object... arguments)
org.zeromq.ZMQ.Socket	getSocket(String address)
static byte[]	serializeExecuteRequest(String name, String service, long execID, long callerID, long functionID, Object... arguments)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InternalApiaryWorkerClient

public InternalApiaryWorkerClient(org.zeromq.ZContext zContext)

Method Details

getSocket

public org.zeromq.ZMQ.Socket getSocket(String address)

serializeExecuteRequest

public static byte[] serializeExecuteRequest(String name,
 String service,
 long execID,
 long callerID,
 long functionID,
 Object... arguments)

executeFunction

public FunctionOutput executeFunction(String address,
 String name,
 String service,
 long execID,
 Object... arguments)
                               throws com.google.protobuf.InvalidProtocolBufferException

Throws:

com.google.protobuf.InvalidProtocolBufferException