public class JGroupsTransport extends AbstractRemoteTransport<org.jgroups.Address> implements org.jgroups.MembershipListener
executorService, nodes
Constructor and Description |
---|
JGroupsTransport()
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
addWorkManager(Address logicalAddress,
org.jgroups.Address address)
Delegator
|
void |
block() |
void |
executeDoWork(Address logicalAddress,
ClassBundle classBundle,
byte[] b)
Execute doWork
|
void |
executeScheduleWork(Address logicalAddress,
ClassBundle classBundle,
byte[] b)
Execute scheduleWork
|
long |
executeStartWork(Address logicalAddress,
ClassBundle classBundle,
byte[] b)
Execute startWork
|
org.jgroups.JChannel |
getChannel()
Get the channel.
|
java.lang.String |
getClusterName()
Get the clustername.
|
org.jgroups.Address |
getOwnAddress()
Get the physical address
|
long |
getTimeout()
Get the timeout
|
java.util.Set<Address> |
getWorkManagers()
Get WorkManagers
|
void |
initialize()
Initialize the transport
|
boolean |
isInitialized()
Is the transport initialized
|
void |
join(Address logicalAddress,
org.jgroups.Address address)
Delegator
|
void |
leave(org.jgroups.Address address)
Delegator
|
java.io.Serializable |
sendMessage(org.jgroups.Address destAddress,
ProtocolMessages.Request request,
java.io.Serializable... parameters)
send a messagge using specific protocol.
|
void |
setChannel(org.jgroups.JChannel channel)
Set the channel.
|
void |
setClusterName(java.lang.String clustername)
Set the clustername.
|
void |
setTimeout(long v)
Set the timeout
|
void |
shutdown()
Shutdown the transport
|
void |
startup()
Startup the transport
|
void |
suspect(org.jgroups.Address address) |
java.lang.String |
toString() |
void |
unblock() |
void |
viewAccepted(org.jgroups.View view) |
clearDistributedStatistics, deltaDoWorkAccepted, deltaDoWorkRejected, deltaScheduleWorkAccepted, deltaScheduleWorkRejected, deltaStartWorkAccepted, deltaStartWorkRejected, deltaWorkFailed, deltaWorkSuccessful, doWork, getAddresses, getDistributedStatistics, getExecutorService, getId, getLongRunningFree, getShortRunningFree, 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 join(Address logicalAddress, org.jgroups.Address address)
join
in class AbstractRemoteTransport<org.jgroups.Address>
logicalAddress
- The logical addressaddress
- The addresspublic void leave(org.jgroups.Address address)
leave
in class AbstractRemoteTransport<org.jgroups.Address>
address
- The addresspublic java.util.Set<Address> getWorkManagers()
public void addWorkManager(Address logicalAddress, org.jgroups.Address address)
logicalAddress
- The logical addressaddress
- The addresspublic void executeDoWork(Address logicalAddress, ClassBundle classBundle, byte[] b) throws javax.resource.spi.work.WorkException
logicalAddress
- The logical addressclassBundle
- The class bundleb
- The bytesjavax.resource.spi.work.WorkException
- in case of errorpublic long executeStartWork(Address logicalAddress, ClassBundle classBundle, byte[] b) throws javax.resource.spi.work.WorkException
logicalAddress
- The logical addressclassBundle
- The class bundleb
- The bytesjavax.resource.spi.work.WorkException
- in case of errorpublic void executeScheduleWork(Address logicalAddress, ClassBundle classBundle, byte[] b) throws javax.resource.spi.work.WorkException
logicalAddress
- The logical addressclassBundle
- The class bundleb
- The bytesjavax.resource.spi.work.WorkException
- in case of errorpublic 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
public java.io.Serializable sendMessage(org.jgroups.Address destAddress, ProtocolMessages.Request request, java.io.Serializable... parameters) throws javax.resource.spi.work.WorkException
AbstractRemoteTransport
sendMessage
in class AbstractRemoteTransport<org.jgroups.Address>
destAddress
- the physical addressrequest
- the requestparameters
- the parametersjavax.resource.spi.work.WorkException
- in case of problem with the workpublic org.jgroups.Address getOwnAddress()
getOwnAddress
in class AbstractRemoteTransport<org.jgroups.Address>
public org.jgroups.JChannel getChannel()
public void setChannel(org.jgroups.JChannel channel)
channel
- The channel to set.public java.lang.String getClusterName()
public void setClusterName(java.lang.String clustername)
clustername
- The clustername to set.public long getTimeout()
public void setTimeout(long v)
v
- The valuepublic void viewAccepted(org.jgroups.View view)
viewAccepted
in interface org.jgroups.MembershipListener
public void block()
block
in interface org.jgroups.MembershipListener
public void suspect(org.jgroups.Address address)
suspect
in interface org.jgroups.MembershipListener
public void unblock()
unblock
in interface org.jgroups.MembershipListener
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)