Class QueryHost

java.lang.Object

org.jpos.transaction.participant.QueryHost

All Implemented Interfaces:

Configurable, TransactionConstants, TransactionParticipant

public class QueryHost
extends Object
implements TransactionParticipant, Configurable

Transaction participant that routes the request to a downstream MUX, waits for the response (synchronously or via continuations), and stores the response back into the Context.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TIMEOUT_NAME	Default Context key used to override the per-transaction timeout.

Fields inherited from interface TransactionConstants

ABORTED, FAIL, NO_JOIN, PAUSE, PREPARED, READONLY, RETRY

Modifier and Type	Field	Description
static final int	ABORTED	Transaction has been aborted.
static final int	FAIL	Shortcut for a read-only, non-joining abort (READONLY | NO_JOIN).
static final int	NO_JOIN	This participant does not join the transaction
static final int	PAUSE	Transaction is paused.
static final int	PREPARED	Transaction has been prepared successfully.
static final int	READONLY	Context has not been modified (no need to persist a snapshot)
static final int	RETRY	Transaction should be retried.

Constructor Summary

Constructors

Constructor	Description
QueryHost()	Default constructor.

Method Summary

Modifier and Type	Method	Description
protected boolean	isConnected(MUX mux)	Indicates whether mux is currently connected, honouring the check-connected configuration switch.
int	prepare(long id, Serializable ser)	Called by TransactionManager in preparation for a transaction
protected long	resolveTimeout(Context ctx)	Resolves the per-transaction request timeout, honouring any value the upstream code stashed in the context under TIMEOUT_NAME.
void	setConfiguration(Configuration cfg)	Configures this object with the supplied Configuration.

Methods inherited from class Object

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

Methods inherited from interface TransactionParticipant

abort, commit

Modifier and Type	Method	Description
default void	abort(long id, Serializable context)	Called by TransactionManager upon transaction commit.
default void	commit(long id, Serializable context)	Called by TransactionManager upon transaction commit.

Field Details

TIMEOUT_NAME

public static final String TIMEOUT_NAME

Default Context key used to override the per-transaction timeout.

See Also:

• Constant Field Values

Constructor Details

QueryHost

public QueryHost()

Default constructor.

Method Details

prepare

public int prepare(long id,
 Serializable ser)

Description copied from interface: TransactionParticipant

Called by TransactionManager in preparation for a transaction

Specified by:

prepare in interface TransactionParticipant

Parameters:

id - the Transaction identifier

ser - transaction context

Returns:

PREPARED or ABORTED (| NO_JOIN | READONLY)

setConfiguration

public void setConfiguration(Configuration cfg)
                      throws ConfigurationException

Description copied from interface: Configurable

Configures this object with the supplied Configuration.

Specified by:

setConfiguration in interface Configurable

Parameters:

cfg - Configuration object

Throws:

ConfigurationException - if the configuration is invalid

resolveTimeout

protected long resolveTimeout(Context ctx)

Resolves the per-transaction request timeout, honouring any value the upstream code stashed in the context under TIMEOUT_NAME.

Parameters:

ctx - transaction context

Returns:

effective timeout in milliseconds

isConnected

protected boolean isConnected(MUX mux)

Indicates whether mux is currently connected, honouring the check-connected configuration switch.

Parameters:

mux - MUX selected for this transaction

Returns:

true if connectivity checks are disabled or the MUX reports connected