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(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap,
org.jgroups.Address address)
Delegator
|
void |
block() |
void |
clearDistributedStatistics(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
protected org.jgroups.blocks.RpcDispatcher |
createRpcDispatcher()
Creates an rpc dispatcher used by this transport
|
void |
deltaDoWorkAccepted(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaDoWorkRejected(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaScheduleWorkAccepted(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaScheduleWorkRejected(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaStartWorkAccepted(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaStartWorkRejected(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaWorkFailed(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
deltaWorkSuccessful(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
void |
executeDoWork(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap,
java.util.List<java.util.Map<java.lang.String,java.lang.Object>> classBundle,
byte[] b)
Execute doWork
|
void |
executeScheduleWork(java.util.Map<java.lang.String,java.lang.String> logicalAddress,
java.util.List<java.util.Map<java.lang.String,java.lang.Object>> classBundle,
byte[] b)
Execute scheduleWork
|
long |
executeStartWork(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap,
java.util.List<java.util.Map<java.lang.String,java.lang.Object>> classBundle,
byte[] b)
Execute startWork
|
org.jgroups.Channel |
getChannel()
Get the channel.
|
java.lang.String |
getClusterName()
Get the clustername.
|
java.util.Map<java.lang.String,java.lang.Integer> |
getDistributedStatistics(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
long |
getLongRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
org.jgroups.Address |
getOwnAddress()
Get the physical address
|
long |
getShortRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
long |
getTimeout()
Get the timeout
|
java.util.Set<java.util.Map<java.lang.String,java.lang.String>> |
getWorkManagers()
Get WorkManagers
|
void |
initialize()
Initialize the transport
|
boolean |
isInitialized()
Is the transport initialized
|
void |
join(java.util.Map<java.lang.String,java.lang.String> 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.Channel 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 |
updateLongRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap,
java.lang.Long freeCount)
Delegator
|
void |
updateShortRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap,
java.lang.Long freeCount)
Delegator
|
void |
viewAccepted(org.jgroups.View view) |
void |
workManagerRemove(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
Delegator
|
clearDistributedStatistics, deltaDoWorkAccepted, deltaDoWorkRejected, deltaScheduleWorkAccepted, deltaScheduleWorkRejected, deltaStartWorkAccepted, deltaStartWorkRejected, deltaWorkFailed, deltaWorkSuccessful, doWork, getAddresses, getDistributedStatistics, getExecutorService, getId, getLongRunningFree, getShortRunningFree, join, 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(java.util.Map<java.lang.String,java.lang.String> logicalAddress, org.jgroups.Address 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<java.util.Map<java.lang.String,java.lang.String>> getWorkManagers()
public void addWorkManager(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap, org.jgroups.Address address)
logicalAddressMap
- The logical addressaddress
- The addresspublic void workManagerRemove(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic long getShortRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic long getLongRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void updateShortRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap, java.lang.Long freeCount)
logicalAddressMap
- The logical addressfreeCount
- freeCountpublic void updateLongRunningFree(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap, java.lang.Long freeCount)
logicalAddressMap
- The logical addressfreeCount
- freeCountpublic java.util.Map<java.lang.String,java.lang.Integer> getDistributedStatistics(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void clearDistributedStatistics(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaDoWorkAccepted(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaDoWorkRejected(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaStartWorkAccepted(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaStartWorkRejected(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaScheduleWorkAccepted(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaScheduleWorkRejected(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaWorkSuccessful(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void deltaWorkFailed(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap)
logicalAddressMap
- The logical addresspublic void executeDoWork(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap, java.util.List<java.util.Map<java.lang.String,java.lang.Object>> classBundle, byte[] b) throws java.rmi.RemoteException
logicalAddressMap
- The logical addressclassBundle
- The class bundleb
- The bytesjava.rmi.RemoteException
- in case of errorpublic long executeStartWork(java.util.Map<java.lang.String,java.lang.String> logicalAddressMap, java.util.List<java.util.Map<java.lang.String,java.lang.Object>> classBundle, byte[] b) throws java.rmi.RemoteException
logicalAddressMap
- The logical addressclassBundle
- The class bundleb
- The bytesjava.rmi.RemoteException
- in case of errorpublic void executeScheduleWork(java.util.Map<java.lang.String,java.lang.String> logicalAddress, java.util.List<java.util.Map<java.lang.String,java.lang.Object>> classBundle, byte[] b) throws java.rmi.RemoteException
logicalAddress
- The logical addressclassBundle
- The class bundleb
- The bytesjava.rmi.RemoteException
- in case of errorpublic void startup() throws java.lang.Throwable
startup
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
java.lang.Throwable
- In case of an errorprotected org.jgroups.blocks.RpcDispatcher createRpcDispatcher()
public boolean isInitialized()
isInitialized
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
public void initialize() throws java.lang.Throwable
initialize
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
java.lang.Throwable
- In case of an errorpublic void shutdown() throws java.lang.Throwable
shutdown
in interface org.jboss.jca.core.spi.workmanager.transport.Transport
java.lang.Throwable
- In case of an errorpublic 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.Channel getChannel()
public void setChannel(org.jgroups.Channel 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 © 2014 IronJacamar (http://www.ironjacamar.org)