adam

Class WireClientEndpoint

java.lang.Object

adam.WireClientEndpoint

Direct Known Subclasses:

WireClientEndpoint.Broadcaster, WireClientEndpoint.PhoneHomeEndpoint, WireClientEndpoint.PollingEndpoint

public class WireClientEndpoint
extends java.lang.Object

This class contains all of the network endpoint code, so that we can swap out XMLRPC for something less bloated and horrible in the future. The main API of my network wires implementation is in Connections; you should not have to call anything here but you may unless noted.

Author:

adk

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	WireClientEndpoint.Broadcaster
static class	WireClientEndpoint.PhoneHomeEndpoint DON'T INSTANIATE ONE OF THESE! This class has to be public to simplify code generation, but it is not part of the API.
protected static class	WireClientEndpoint.PollingEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
static int	API_VERSION

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	WireClientEndpoint()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	call(java.lang.String destID, java.lang.String methodName, java.lang.Object[] args)
protected void	call(java.lang.String sourceID, java.lang.String destID, java.lang.String methodName, java.lang.Object[] args)
protected void	chainedRPCReply(long seq, java.lang.Object res, java.lang.Throwable err)
protected java.lang.Object	execute(java.lang.String method, java.lang.Object[] args)
protected java.lang.Object	execute(java.lang.String method, java.lang.Object[] args, java.lang.Integer timeout)
java.lang.String	getClientId()
static WireClientEndpoint	getInstance()
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	getPortMapping(java.lang.String uid)
protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.reflect.Method>>	getPublished()
java.lang.String[]	getRemoteMethods(java.lang.String uid)
byte[]	getRemoteStub(java.lang.String uid)
java.lang.String	getRemoteStubClassName(java.lang.String uid)
java.net.URL	getServerURL()
protected java.util.Map<java.lang.Thread,java.util.Map<java.lang.String,java.lang.Long>>	getSources()
java.lang.String	getUUID(WiredBox sourceBox)
void	hook(WiredBox sourceBox) this method is not part of the API: DON'T CALL IT! it has to be public so as to disrupt Patrick's wire code minimally.
boolean	initialize(java.net.URL url)
boolean	isConnected(java.lang.String uid)
static boolean	isInitialized()
protected void	pollForIncomingSignals()
void	publish(WiredBox box, java.lang.String uid, java.lang.String apiLanguage)
void	registerErrorHandler(ErrorHandler h)
protected void	replyError(long sequenceNumber, java.lang.Throwable e)
protected void	replyRPCResult(long sequenceNumber, java.lang.Object result)
protected java.lang.Object	rpc(java.lang.String destID, java.lang.String methodName, java.lang.Object[] args) After going to great lengths to obliterate standard RPC semantics with the Wire Pattern we decide that we must have RPC after all.
void	sayHello()
void	sayHello(java.lang.String osName, java.lang.String osVersion, java.lang.String architecture, java.lang.String lang)
void	setAPIType(java.lang.String language)
static void	setInitialized()
protected boolean	setServerURL(java.net.URL url)
void	startPollingThread()
void	subscribe(java.lang.String globalUniqueID, WiredBox stub, java.lang.String apiLanguage)

Methods inherited from class java.lang.Object

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

Field Detail

API_VERSION

public static final int API_VERSION

See Also:

Constant Field Values

Constructor Detail

WireClientEndpoint

protected WireClientEndpoint()

Method Detail

getInstance

public static WireClientEndpoint getInstance()

getSources

protected java.util.Map<java.lang.Thread,java.util.Map<java.lang.String,java.lang.Long>> getSources()

initialize

public boolean initialize(java.net.URL url)

execute

protected java.lang.Object execute(java.lang.String method,
                       java.lang.Object[] args)
                            throws org.apache.xmlrpc.XmlRpcException

Throws:

org.apache.xmlrpc.XmlRpcException

execute

protected java.lang.Object execute(java.lang.String method,
                       java.lang.Object[] args,
                       java.lang.Integer timeout)
                            throws org.apache.xmlrpc.XmlRpcException

Throws:

org.apache.xmlrpc.XmlRpcException

setServerURL

protected boolean setServerURL(java.net.URL url)

getServerURL

public java.net.URL getServerURL()

setInitialized

public static void setInitialized()

isInitialized

public static boolean isInitialized()

call

protected void call(java.lang.String sourceID,
        java.lang.String destID,
        java.lang.String methodName,
        java.lang.Object[] args)

rpc

protected java.lang.Object rpc(java.lang.String destID,
                   java.lang.String methodName,
                   java.lang.Object[] args)

After going to great lengths to obliterate standard RPC semantics with the Wire Pattern we decide that we must have RPC after all. This is where I mashed it on. -ADK

Parameters:

destID -

methodName -

args -

replyError

protected void replyError(long sequenceNumber,
              java.lang.Throwable e)

replyRPCResult

protected void replyRPCResult(long sequenceNumber,
                  java.lang.Object result)

chainedRPCReply

protected void chainedRPCReply(long seq,
                   java.lang.Object res,
                   java.lang.Throwable err)

call

protected void call(java.lang.String destID,
        java.lang.String methodName,
        java.lang.Object[] args)

getRemoteMethods

public java.lang.String[] getRemoteMethods(java.lang.String uid)

isConnected

public boolean isConnected(java.lang.String uid)
                    throws Connections.NetWireException

Throws:

Connections.NetWireException

getPortMapping

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getPortMapping(java.lang.String uid)

getRemoteStubClassName

public java.lang.String getRemoteStubClassName(java.lang.String uid)

getRemoteStub

public byte[] getRemoteStub(java.lang.String uid)

getUUID

public java.lang.String getUUID(WiredBox sourceBox)

getClientId

public java.lang.String getClientId()

hook

public void hook(WiredBox sourceBox)

this method is not part of the API: DON'T CALL IT! it has to be public so as to disrupt Patrick's wire code minimally.

Parameters:

sourceBox - the last source WireBox to transmit in this thread

getPublished

protected java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.reflect.Method>> getPublished()

publish

public void publish(WiredBox box,
           java.lang.String uid,
           java.lang.String apiLanguage)
             throws Connections.NetWireException

Throws:

Connections.NetWireException

registerErrorHandler

public void registerErrorHandler(ErrorHandler h)

setAPIType

public void setAPIType(java.lang.String language)

sayHello

public void sayHello()
              throws Connections.NetWireException

Throws:

Connections.NetWireException

sayHello

public void sayHello(java.lang.String osName,
            java.lang.String osVersion,
            java.lang.String architecture,
            java.lang.String lang)
              throws Connections.NetWireException

Throws:

Connections.NetWireException

startPollingThread

public void startPollingThread()

pollForIncomingSignals

protected void pollForIncomingSignals()

subscribe

public void subscribe(java.lang.String globalUniqueID,
             WiredBox stub,
             java.lang.String apiLanguage)
               throws Connections.NetWireException

Throws:

Connections.NetWireException