public class SocketTransport extends AbstractRemoteTransport<java.lang.String> implements java.lang.Runnable
executorService, nodes
Constructor and Description |
---|
SocketTransport()
Constructor
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getOwnAddress()
Get the physical address
|
void |
initialize()
Initialize the transport
|
boolean |
isInitialized()
Is the transport initialized
|
void |
run() |
protected java.io.Serializable |
sendMessage(java.lang.String address,
ProtocolMessages.Request request,
java.io.Serializable... parameters)
send a messagge using specific protocol.
|
void |
setHost(java.lang.String host)
Set the host.
|
void |
setPeers(java.util.Set<java.lang.String> peers)
Set the peers
|
void |
setPort(int port)
Set the port.
|
void |
shutdown()
Shutdown the transport
|
void |
startup()
Startup the transport
|
java.lang.String |
toString() |
clearDistributedStatistics, deltaDoWorkAccepted, deltaDoWorkRejected, deltaScheduleWorkAccepted, deltaScheduleWorkRejected, deltaStartWorkAccepted, deltaStartWorkRejected, deltaWorkFailed, deltaWorkSuccessful, doWork, getAddresses, getDistributedStatistics, getExecutorService, getId, getLongRunningFree, getShortRunningFree, join, leave, localClearDistributedStatistics, localDeltaDoWorkAccepted, localDeltaDoWorkRejected, localDeltaScheduleWorkAccepted, localDeltaScheduleWorkRejected, localDeltaStartWorkAccepted, localDeltaStartWorkRejected, localDeltaWorkFailed, localDeltaWorkSuccessful, localDoWork, localGetDistributedStatistics, localGetLongRunningFree, localGetShortRunningFree, localPing, localScheduleWork, localStartWork, localUpdateLongRunningFree, localUpdateShortRunningFree, localWorkManagerAdd, localWorkManagerRemove, ping, register, scheduleWork, setExecutorService, setId, startWork, unregister, updateLongRunningFree, updateShortRunningFree
public void startup() throws java.lang.Throwable
public boolean isInitialized()
isInitialized
in interface Transport
public void initialize() throws java.lang.Throwable
initialize
in interface Transport
java.lang.Throwable
- In case of an errorpublic void shutdown() throws java.lang.Throwable
protected java.io.Serializable sendMessage(java.lang.String address, ProtocolMessages.Request request, java.io.Serializable... parameters) throws javax.resource.spi.work.WorkException
AbstractRemoteTransport
sendMessage
in class AbstractRemoteTransport<java.lang.String>
address
- the physical addressrequest
- the requestparameters
- the parametersjavax.resource.spi.work.WorkException
- in case of problem with the workpublic void setHost(java.lang.String host)
host
- The host to set.public void setPort(int port)
port
- The port to set.public void setPeers(java.util.Set<java.lang.String> peers)
peers
- The peerspublic java.lang.String getOwnAddress()
getOwnAddress
in class AbstractRemoteTransport<java.lang.String>
public void run()
run
in interface java.lang.Runnable
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)