org.jboss.jca.core.workmanager.transport.remote.jgroups

Class JGroupsTransport

java.lang.Object

org.jboss.jca.core.workmanager.transport.remote.AbstractRemoteTransport<org.jgroups.Address>

org.jboss.jca.core.workmanager.transport.remote.jgroups.JGroupsTransport

All Implemented Interfaces:

Transport, org.jgroups.MembershipListener

public class JGroupsTransport
extends AbstractRemoteTransport<org.jgroups.Address>
implements org.jgroups.MembershipListener

The socket transport

Author:

Stefano Maestri, Jesper Pedersen

Field Summary

Fields inherited from class org.jboss.jca.core.workmanager.transport.remote.AbstractRemoteTransport

executorService, nodes

Constructor Summary

Constructors

Constructor and Description
JGroupsTransport() Constructor

Method Summary

Modifier and Type	Method and Description
void	addWorkManager(Address logicalAddress, org.jgroups.Address address) Delegator
void	block()
protected org.jgroups.blocks.RpcDispatcher	createRpcDispatcher() Creates an rpc dispatcher used by this transport
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.Channel	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.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	viewAccepted(org.jgroups.View view)

Methods inherited from class org.jboss.jca.core.workmanager.transport.remote.AbstractRemoteTransport

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

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupsTransport

public JGroupsTransport()

Constructor

Method Detail

join

public void join(Address logicalAddress,
                 org.jgroups.Address address)

Delegator

Overrides:

join in class AbstractRemoteTransport<org.jgroups.Address>

Parameters:

logicalAddress - The logical address

address - The address

leave

public void leave(org.jgroups.Address address)

Delegator

Overrides:

leave in class AbstractRemoteTransport<org.jgroups.Address>

Parameters:

address - The address

getWorkManagers

public java.util.Set<Address> getWorkManagers()

Get WorkManagers

Returns:

The value

addWorkManager

public void addWorkManager(Address logicalAddress,
                           org.jgroups.Address address)

Delegator

Parameters:

logicalAddress - The logical address

address - The address

executeDoWork

public void executeDoWork(Address logicalAddress,
                          ClassBundle classBundle,
                          byte[] b)
                   throws javax.resource.spi.work.WorkException

Execute doWork

Parameters:

logicalAddress - The logical address

classBundle - The class bundle

b - The bytes

Throws:

javax.resource.spi.work.WorkException - in case of error

executeStartWork

public long executeStartWork(Address logicalAddress,
                             ClassBundle classBundle,
                             byte[] b)
                      throws javax.resource.spi.work.WorkException

Execute startWork

Parameters:

logicalAddress - The logical address

classBundle - The class bundle

b - The bytes

Returns:

the start value

Throws:

javax.resource.spi.work.WorkException - in case of error

executeScheduleWork

public void executeScheduleWork(Address logicalAddress,
                                ClassBundle classBundle,
                                byte[] b)
                         throws javax.resource.spi.work.WorkException

Execute scheduleWork

Parameters:

logicalAddress - The logical address

classBundle - The class bundle

b - The bytes

Throws:

javax.resource.spi.work.WorkException - in case of error

startup

public void startup()
             throws java.lang.Throwable

Startup the transport

Specified by:

startup in interface Transport

Throws:

java.lang.Throwable - In case of an error

createRpcDispatcher

protected org.jgroups.blocks.RpcDispatcher createRpcDispatcher()

Creates an rpc dispatcher used by this transport

Returns:

an rpc dispatcher

isInitialized

public boolean isInitialized()

Is the transport initialized

Specified by:

isInitialized in interface Transport

Returns:

The value

initialize

public void initialize()
                throws java.lang.Throwable

Initialize the transport

Specified by:

initialize in interface Transport

Throws:

java.lang.Throwable - In case of an error

shutdown

public void shutdown()
              throws java.lang.Throwable

Shutdown the transport

Specified by:

shutdown in interface Transport

Throws:

java.lang.Throwable - In case of an error

sendMessage

public java.io.Serializable sendMessage(org.jgroups.Address destAddress,
                                        ProtocolMessages.Request request,
                                        java.io.Serializable... parameters)
                                 throws javax.resource.spi.work.WorkException

Description copied from class: AbstractRemoteTransport

send a messagge using specific protocol. Method overridden in specific protocol implementation classes

Specified by:

sendMessage in class AbstractRemoteTransport<org.jgroups.Address>

Parameters:

destAddress - the physical address

request - the request

parameters - the parameters

Returns:

the returned value. Can be null if requested operation return a void

Throws:

javax.resource.spi.work.WorkException - in case of problem with the work

getOwnAddress

public org.jgroups.Address getOwnAddress()

Get the physical address

Specified by:

getOwnAddress in class AbstractRemoteTransport<org.jgroups.Address>

Returns:

The value

getChannel

public org.jgroups.Channel getChannel()

Get the channel.

Returns:

the channel.

setChannel

public void setChannel(org.jgroups.Channel channel)

Set the channel.

Parameters:

channel - The channel to set.

getClusterName

public java.lang.String getClusterName()

Get the clustername.

Returns:

the clustername.

setClusterName

public void setClusterName(java.lang.String clustername)

Set the clustername.

Parameters:

clustername - The clustername to set.

getTimeout

public long getTimeout()

Get the timeout

Returns:

The value

setTimeout

public void setTimeout(long v)

Set the timeout

Parameters:

v - The value

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

suspect

public void suspect(org.jgroups.Address address)

Specified by:

suspect in interface org.jgroups.MembershipListener

unblock

public void unblock()

Specified by:

unblock in interface org.jgroups.MembershipListener

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object