Module org.eclipse.persistence.nosql

Package org.eclipse.persistence.internal.eis.adapters.jms

Class CciJMSInteraction

java.lang.Object

org.eclipse.persistence.internal.eis.adapters.jms.CciJMSInteraction

All Implemented Interfaces:

Interaction

public class CciJMSInteraction
extends Object
implements Interaction

INTERNAL: Interaction to Oracle JMS JCA adapter. Executes the interaction spec to send or receive a message.

Since:

OracleAS TopLink 10g (10.1.3)

Field Summary

Fields

Modifier and Type	Field	Description
protected CciJMSConnection	connection

Constructor Summary

Constructors

Constructor	Description
CciJMSInteraction(CciJMSConnection conn)	This constructor sets the cci connection.

Method Summary

Modifier and Type	Method	Description
void	clearWarnings()	Resource warnings are not supported.
void	close()	Satisfy the Interaction interface.
protected Message	createMessage(Object recordData, QueueSession session)	This helper method will create the appropriate JMS message according to the input record data type.
Record	execute(InteractionSpec spec, Record input)	Execute the interaction spec.
boolean	execute(InteractionSpec spec, Record input, Record output)	Execute the interaction and set the output into the output record.
protected void	executeReceiveInteraction(CciJMSReceiveInteractionSpec spec, CciJMSRecord input, CciJMSRecord output)	Execute the receive message interaction.
protected void	executeSendInteraction(CciJMSSendInteractionSpec spec, CciJMSRecord input, CciJMSRecord output)	Execute the send message interaction.
protected void	executeSendReceiveInteraction(CciJMSSendReceiveInteractionSpec spec, CciJMSRecord input, CciJMSRecord output)	Execute the send/receive message interaction.
Connection	getConnection()	Return the cci connection.
ResourceWarning	getWarnings()	Resource warnings are not supported.
protected void	sendMessageAndCommit(QueueSession qSession, Queue queue, Message msg)	This helper method will send the message to the queue, then commit the transaction so the sent message can be consumed.

Methods inherited from class java.lang.Object

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

Field Details

connection

protected CciJMSConnection connection

Constructor Details

CciJMSInteraction

public CciJMSInteraction(CciJMSConnection conn)

This constructor sets the cci connection.

Method Details

execute

public Record execute(InteractionSpec spec,
 Record input)
               throws EISException

Execute the interaction spec. The spec is either a send, receive, or send/receive interaction.

Specified by:

execute in interface Interaction

Parameters:

spec - - the interaction spec

input - - the input record

Throws:

EISException

execute

public boolean execute(InteractionSpec spec,
 Record input,
 Record output)
                throws EISException

Execute the interaction and set the output into the output record. The spec is a send interaction, a receive interaction, or a send/receive interaction. Only text messages of XML content are supported.

Specified by:

execute in interface Interaction

Parameters:

spec - - the interaction spec

input - - the input record

output - - the output record

Throws:

EISException

executeSendInteraction

protected void executeSendInteraction(CciJMSSendInteractionSpec spec,
 CciJMSRecord input,
 CciJMSRecord output)
                               throws EISException

Execute the send message interaction. Only text messages of XML content are supported.

Parameters:

spec - - the send interaction spec

input - - the input record

output - - the output record

Throws:

EISException

executeReceiveInteraction

protected void executeReceiveInteraction(CciJMSReceiveInteractionSpec spec,
 CciJMSRecord input,
 CciJMSRecord output)
                                  throws EISException

Execute the receive message interaction. Only text messages of XML content are supported.

Parameters:

spec - - the receive interaction spec

input - - the input record

output - - the output record

Throws:

EISException

executeSendReceiveInteraction

protected void executeSendReceiveInteraction(CciJMSSendReceiveInteractionSpec spec,
 CciJMSRecord input,
 CciJMSRecord output)
                                      throws EISException

Execute the send/receive message interaction. Only text messages of XML content are supported.

Parameters:

spec - - the send/receive interaction spec

input - - the input record

output - - the output record

Throws:

EISException

sendMessageAndCommit

protected void sendMessageAndCommit(QueueSession qSession,
 Queue queue,
 Message msg)
                             throws EISException

This helper method will send the message to the queue, then commit the transaction so the sent message can be consumed. The local transaction will be restarted for the response portion of this call.

Parameters:

qSession - - the JMS session

queue - - the destination of the message

msg - - the message to send

Throws:

EISException

createMessage

protected Message createMessage(Object recordData,
 QueueSession session)
                         throws EISException

This helper method will create the appropriate JMS message according to the input record data type. Only text messages of XML content are supported at this time.

Parameters:

recordData - - the input record

session - - the JMS queue session

Returns:

the JMS message

Throws:

EISException - - if an unknown message type is encountered

getConnection

public Connection getConnection()

Return the cci connection.

Specified by:

getConnection in interface Interaction

Returns:

the cci connection

getWarnings

public ResourceWarning getWarnings()

Resource warnings are not supported.

Specified by:

getWarnings in interface Interaction

clearWarnings

public void clearWarnings()

Resource warnings are not supported.

Specified by:

clearWarnings in interface Interaction

close

public void close()

Satisfy the Interaction interface.

Specified by:

close in interface Interaction