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

Class AbstractRemoteTransport<T>

java.lang.Object

org.jboss.jca.core.workmanager.transport.remote.AbstractRemoteTransport<T>

Type Parameters:

T - the type

All Implemented Interfaces:

Transport

Direct Known Subclasses:

JGroupsTransport, SocketTransport

public abstract class AbstractRemoteTransport<T>
extends java.lang.Object
implements Transport

An abstract transport for remote communication

Author:

Stefano Maestri, Jesper Pedersen

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ExecutorService	executorService The kernel executorService
protected java.util.Map<Address,T>	nodes The nodes

Constructor Summary

Constructors

Constructor and Description
AbstractRemoteTransport() Constructor

Method Summary

Modifier and Type	Method and Description
void	clearDistributedStatistics(Address address) Clear distributed statistics
void	deltaDoWorkAccepted(Address address) Delta doWork accepted
void	deltaDoWorkRejected(Address address) Delta doWork rejected
void	deltaScheduleWorkAccepted(Address address) Delta scheduleWork accepted
void	deltaScheduleWorkRejected(Address address) Delta scheduleWork rejected
void	deltaStartWorkAccepted(Address address) Delta startWork accepted
void	deltaStartWorkRejected(Address address) Delta startWork rejected
void	deltaWorkFailed(Address address) Delta work failed
void	deltaWorkSuccessful(Address address) Delta work successful
void	doWork(Address address, javax.resource.spi.work.DistributableWork work) doWork
java.util.Set<Address>	getAddresses(T physicalAddress) Get the addresses
DistributedWorkManagerStatisticsValues	getDistributedStatistics(Address address) Get the distributed statistics
java.util.concurrent.ExecutorService	getExecutorService() Get the executorService.
java.lang.String	getId() Get the identifier of the transport
long	getLongRunningFree(Address address) Get The number of free thread in long running pool from a distributed work manager
protected abstract T	getOwnAddress() Get the own address
long	getShortRunningFree(Address address) Get The number of free thread in short running pool from a distributed work manager
void	join(Address logicalAddress, T physicalAddress) join
void	leave(T physicalAddress) leave
void	localClearDistributedStatistics(Address logicalAddress) localClearDistributedStatistics
void	localDeltaDoWorkAccepted(Address address) Local delta doWork accepted
void	localDeltaDoWorkRejected(Address address) Local delta doWork rejected
void	localDeltaScheduleWorkAccepted(Address address) Local delta scheduleWork accepted
void	localDeltaScheduleWorkRejected(Address address) Local delta scheduleWork rejected
void	localDeltaStartWorkAccepted(Address address) Local delta startWork accepted
void	localDeltaStartWorkRejected(Address address) Local delta startWork rejected
void	localDeltaWorkFailed(Address address) Local delta work failed
void	localDeltaWorkSuccessful(Address address) Local delta work successful
void	localDoWork(Address address, javax.resource.spi.work.DistributableWork work) localDoWork
DistributedWorkManagerStatisticsValues	localGetDistributedStatistics(Address address) localGetDistributedStatistics
long	localGetLongRunningFree(Address address) localGetLongRunningFree
long	localGetShortRunningFree(Address address) localGetShortRunningFree
long	localPing() localPing
void	localScheduleWork(Address address, javax.resource.spi.work.DistributableWork work) localScheduleWork
long	localStartWork(Address address, javax.resource.spi.work.DistributableWork work) localStartWork
void	localUpdateLongRunningFree(Address logicalAddress, java.lang.Long freeCount) localUpdateLongRunningFree
void	localUpdateShortRunningFree(Address logicalAddress, java.lang.Long freeCount) localUpdateShortRunningFree
void	localWorkManagerAdd(Address address, T physicalAddress) localWorkManagerAdd
void	localWorkManagerRemove(Address address) localWorkManagerRemove
long	ping(Address address) Ping time to a distributed work manager
void	register(Address address) Register
void	scheduleWork(Address address, javax.resource.spi.work.DistributableWork work) scheduleWork
protected abstract java.io.Serializable	sendMessage(T physicalAddress, ProtocolMessages.Request request, java.io.Serializable... parameters) send a messagge using specific protocol.
void	setExecutorService(java.util.concurrent.ExecutorService executorService) Set the executorService.
void	setId(java.lang.String id) Set the identifier
long	startWork(Address address, javax.resource.spi.work.DistributableWork work) startWork
void	unregister(Address address) Unregister
void	updateLongRunningFree(Address address, long freeCount) Update The number of free thread in long running pool from a distributed work manager
void	updateShortRunningFree(Address address, long freeCount) Update The number of free thread in short running pool from a distributed work manager

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.jca.core.spi.workmanager.transport.Transport

initialize, isInitialized, shutdown, startup

Field Detail

executorService

protected java.util.concurrent.ExecutorService executorService

The kernel executorService

nodes

protected java.util.Map<Address,T> nodes

The nodes

Constructor Detail

AbstractRemoteTransport

public AbstractRemoteTransport()

Constructor

Method Detail

getId

public java.lang.String getId()

Get the identifier of the transport

Specified by:

getId in interface Transport

Returns:

The value

setId

public void setId(java.lang.String id)

Set the identifier

Parameters:

id - The value

ping

public long ping(Address address)

Ping time to a distributed work manager

Specified by:

ping in interface Transport

Parameters:

address - The address

Returns:

The ping time in milliseconds

getShortRunningFree

public long getShortRunningFree(Address address)

Description copied from interface: Transport

Get The number of free thread in short running pool from a distributed work manager

Specified by:

getShortRunningFree in interface Transport

Parameters:

address - The address

Returns:

The number of free thread in short running pool

getLongRunningFree

public long getLongRunningFree(Address address)

Description copied from interface: Transport

Get The number of free thread in long running pool from a distributed work manager

Specified by:

getLongRunningFree in interface Transport

Parameters:

address - The address

Returns:

The number of free thread in long running pool

updateShortRunningFree

public void updateShortRunningFree(Address address,
                                   long freeCount)

Description copied from interface: Transport

Update The number of free thread in short running pool from a distributed work manager

Specified by:

updateShortRunningFree in interface Transport

Parameters:

address - The address

freeCount - the number of freeThread

updateLongRunningFree

public void updateLongRunningFree(Address address,
                                  long freeCount)

Description copied from interface: Transport

Update The number of free thread in long running pool from a distributed work manager

Specified by:

updateLongRunningFree in interface Transport

Parameters:

address - The address

freeCount - the number of freeThread

getDistributedStatistics

public DistributedWorkManagerStatisticsValues getDistributedStatistics(Address address)

Get the distributed statistics

Specified by:

getDistributedStatistics in interface Transport

Parameters:

address - The address

Returns:

The value

clearDistributedStatistics

public void clearDistributedStatistics(Address address)

Clear distributed statistics

Specified by:

clearDistributedStatistics in interface Transport

Parameters:

address - The address

deltaDoWorkAccepted

public void deltaDoWorkAccepted(Address address)

Delta doWork accepted

Specified by:

deltaDoWorkAccepted in interface Transport

Parameters:

address - The address

deltaDoWorkRejected

public void deltaDoWorkRejected(Address address)

Delta doWork rejected

Specified by:

deltaDoWorkRejected in interface Transport

Parameters:

address - The address

deltaStartWorkAccepted

public void deltaStartWorkAccepted(Address address)

Delta startWork accepted

Specified by:

deltaStartWorkAccepted in interface Transport

Parameters:

address - The address

deltaStartWorkRejected

public void deltaStartWorkRejected(Address address)

Delta startWork rejected

Specified by:

deltaStartWorkRejected in interface Transport

Parameters:

address - The address

deltaScheduleWorkAccepted

public void deltaScheduleWorkAccepted(Address address)

Delta scheduleWork accepted

Specified by:

deltaScheduleWorkAccepted in interface Transport

Parameters:

address - The address

deltaScheduleWorkRejected

public void deltaScheduleWorkRejected(Address address)

Delta scheduleWork rejected

Specified by:

deltaScheduleWorkRejected in interface Transport

Parameters:

address - The address

deltaWorkSuccessful

public void deltaWorkSuccessful(Address address)

Delta work successful

Specified by:

deltaWorkSuccessful in interface Transport

Parameters:

address - The address

deltaWorkFailed

public void deltaWorkFailed(Address address)

Delta work failed

Specified by:

deltaWorkFailed in interface Transport

Parameters:

address - The address

doWork

public void doWork(Address address,
                   javax.resource.spi.work.DistributableWork work)
            throws javax.resource.spi.work.WorkException

doWork

Specified by:

doWork in interface Transport

Parameters:

address - The address

work - The work

Throws:

javax.resource.spi.work.WorkException - Thrown if an error occurs

scheduleWork

public void scheduleWork(Address address,
                         javax.resource.spi.work.DistributableWork work)
                  throws javax.resource.spi.work.WorkException

scheduleWork

Specified by:

scheduleWork in interface Transport

Parameters:

address - The address

work - The work

Throws:

javax.resource.spi.work.WorkException - Thrown if an error occurs

startWork

public long startWork(Address address,
                      javax.resource.spi.work.DistributableWork work)
               throws javax.resource.spi.work.WorkException

startWork

Specified by:

startWork in interface Transport

Parameters:

address - The address

work - The work

Returns:

The delay

Throws:

javax.resource.spi.work.WorkException - Thrown if an error occurs

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

Get the executorService.

Returns:

the executorService.

setExecutorService

public void setExecutorService(java.util.concurrent.ExecutorService executorService)

Set the executorService.

Parameters:

executorService - The executorService to set.

register

public void register(Address address)

Register

Specified by:

register in interface Transport

Parameters:

address - The address

unregister

public void unregister(Address address)

Unregister

Specified by:

unregister in interface Transport

Parameters:

address - The address

getAddresses

public java.util.Set<Address> getAddresses(T physicalAddress)

Get the addresses

Parameters:

physicalAddress - the physical address

Returns:

The logical addresses associated

join

public void join(Address logicalAddress,
                 T physicalAddress)

join

Parameters:

logicalAddress - the logical address

physicalAddress - the physical address

leave

public void leave(T physicalAddress)

leave

Parameters:

physicalAddress - the physical address

localPing

public long localPing()

localPing

Returns:

the ping value

localWorkManagerAdd

public void localWorkManagerAdd(Address address,
                                T physicalAddress)

localWorkManagerAdd

Parameters:

address - the logical address

physicalAddress - the physical address

localWorkManagerRemove

public void localWorkManagerRemove(Address address)

localWorkManagerRemove

Parameters:

address - the logical address

localDoWork

public void localDoWork(Address address,
                        javax.resource.spi.work.DistributableWork work)
                 throws javax.resource.spi.work.WorkException

localDoWork

Parameters:

address - the logical address

work - the work

Throws:

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

localStartWork

public long localStartWork(Address address,
                           javax.resource.spi.work.DistributableWork work)
                    throws javax.resource.spi.work.WorkException

localStartWork

Parameters:

address - the logical address

work - the work

Returns:

the start value

Throws:

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

localScheduleWork

public void localScheduleWork(Address address,
                              javax.resource.spi.work.DistributableWork work)
                       throws javax.resource.spi.work.WorkException

localScheduleWork

Parameters:

address - the logical address

work - the work

Throws:

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

localGetShortRunningFree

public long localGetShortRunningFree(Address address)

localGetShortRunningFree

Parameters:

address - the logical address

Returns:

the free count

localGetLongRunningFree

public long localGetLongRunningFree(Address address)

localGetLongRunningFree

Parameters:

address - the logical address

Returns:

the free count

localUpdateShortRunningFree

public void localUpdateShortRunningFree(Address logicalAddress,
                                        java.lang.Long freeCount)

localUpdateShortRunningFree

Parameters:

logicalAddress - the logical address

freeCount - the free count

localUpdateLongRunningFree

public void localUpdateLongRunningFree(Address logicalAddress,
                                       java.lang.Long freeCount)

localUpdateLongRunningFree

Parameters:

logicalAddress - the logical address

freeCount - the free count

localGetDistributedStatistics

public DistributedWorkManagerStatisticsValues localGetDistributedStatistics(Address address)

localGetDistributedStatistics

Parameters:

address - the logical address

Returns:

The value

localClearDistributedStatistics

public void localClearDistributedStatistics(Address logicalAddress)

localClearDistributedStatistics

Parameters:

logicalAddress - the logical address

localDeltaDoWorkAccepted

public void localDeltaDoWorkAccepted(Address address)

Local delta doWork accepted

Parameters:

address - the logical address

localDeltaDoWorkRejected

public void localDeltaDoWorkRejected(Address address)

Local delta doWork rejected

Parameters:

address - the logical address

localDeltaStartWorkAccepted

public void localDeltaStartWorkAccepted(Address address)

Local delta startWork accepted

Parameters:

address - the logical address

localDeltaStartWorkRejected

public void localDeltaStartWorkRejected(Address address)

Local delta startWork rejected

Parameters:

address - the logical address

localDeltaScheduleWorkAccepted

public void localDeltaScheduleWorkAccepted(Address address)

Local delta scheduleWork accepted

Parameters:

address - the logical address

localDeltaScheduleWorkRejected

public void localDeltaScheduleWorkRejected(Address address)

Local delta scheduleWork rejected

Parameters:

address - the logical address

localDeltaWorkSuccessful

public void localDeltaWorkSuccessful(Address address)

Local delta work successful

Parameters:

address - the logical address

localDeltaWorkFailed

public void localDeltaWorkFailed(Address address)

Local delta work failed

Parameters:

address - the logical address

getOwnAddress

protected abstract T getOwnAddress()

Get the own address

Returns:

The value

sendMessage

protected abstract java.io.Serializable sendMessage(T physicalAddress,
                                                    ProtocolMessages.Request request,
                                                    java.io.Serializable... parameters)
                                             throws javax.resource.spi.work.WorkException

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

Parameters:

physicalAddress - 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