Package com.j_spaces.core.server.processor

Class BusPacket<T>

java.lang.Object

com.j_spaces.kernel.pool.Resource

com.j_spaces.core.server.processor.BusPacket<T>

All Implemented Interfaces:

IResource

Direct Known Subclasses:

BlobStoreUnpinMultiplePacket, CheckXtnStatusInTmBusPackect, CommitBusPacket, EntryArrivedPacket, EntryExpiredBusPacket, EntryTakenPacket, EntryUnmatchedPacket, EntryUpdatedPacket, RemoteEventBusPacket, RemoveWaitingForInfoSABusPacket, RollbackBusPacket, UpdateOrWriteBusPacket

public abstract class BusPacket<T>
extends Resource

A Bus Packet is an event that is sent on some MT-Queue in order to be handled by a Worker Thread.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BusPacket()	default constructor
protected	BusPacket(OperationID operationID, IEntryHolder entryHolder, ServerTransaction xtn, long timeout)	Creates a new BusPacket object.

Method Summary

Modifier and Type	Method	Description
void	clear()	Cleans the resource of its contents so it can be returned to the pool.
void	constructBusPacket(OperationID operationID, IEntryHolder entryHolder, ServerTransaction xtn, long timeout)	Constructs a BusPacket.
abstract void	execute(T executor)
long	getCreationTime()
IEntryHolder	getEntryHolder()
OperationID	getOperationID()
long	getTimeout()
ServerTransaction	getTransaction()
protected void	setOperationID(OperationID operationID)

Methods inherited from class com.j_spaces.kernel.pool.Resource

acquire, isAcquired, isFromPool, release, setAcquired, setFromPool

Methods inherited from class java.lang.Object

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

Constructor Details

BusPacket

protected BusPacket()

default constructor

BusPacket

protected BusPacket(OperationID operationID,
 IEntryHolder entryHolder,
 ServerTransaction xtn,
 long timeout)

Creates a new BusPacket object.

Method Details

execute

public abstract void execute(T executor)
                      throws Exception

Throws:

Exception

constructBusPacket

public void constructBusPacket(OperationID operationID,
 IEntryHolder entryHolder,
 ServerTransaction xtn,
 long timeout)

Constructs a BusPacket.

getOperationID

public OperationID getOperationID()

setOperationID

protected void setOperationID(OperationID operationID)

getCreationTime

public long getCreationTime()

clear

public void clear()

Description copied from interface: IResource

Cleans the resource of its contents so it can be returned to the pool.

You may use the IResource.isFromPool() indication to decide of a special action before returning a resource to the pool, or discard any actions on resources not returning to the pool.

Specified by:

clear in interface IResource

Specified by:

clear in class Resource

See Also:

• IResource.release()

getTransaction

public ServerTransaction getTransaction()

getTimeout

public long getTimeout()

getEntryHolder

public IEntryHolder getEntryHolder()