Module org.eclipse.persistence.oracle.nosql

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

Class AQInteraction

java.lang.Object

org.eclipse.persistence.internal.eis.adapters.aq.AQInteraction

All Implemented Interfaces:

Interaction

public class AQInteraction
extends Object
implements Interaction

Interaction to Oracle AQ JCA adapter. Executes the interaction spec to enqueue or dequeue a message.

Since:

OracleAS TopLink 10g (10.0.3)

Field Summary

Fields

Modifier and Type	Field	Description
protected AQConnection	connection	Store the connection the interaction was created from.

Constructor Summary

Constructors

Constructor	Description
AQInteraction(AQConnection connection)	Default constructor.

Method Summary

Modifier and Type	Method	Description
void	clearWarnings()
void	close()
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	executeDequeueInteraction(AQDequeueInteractionSpec spec, AQRecord input, AQRecord output)	Execute the dequeue interaction.
protected void	executeEnqueueInteraction(AQEnqueueInteractionSpec spec, AQRecord input, AQRecord output)	Execute the enqueue interaction.
Connection	getConnection()
ResourceWarning	getWarnings()

Methods inherited from class java.lang.Object

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

Field Details

connection

protected AQConnection connection

Store the connection the interaction was created from.

Constructor Details

AQInteraction

public AQInteraction(AQConnection connection)

Default constructor.

Method Details

clearWarnings

public void clearWarnings()

Specified by:

clearWarnings in interface Interaction

close

public void close()

Specified by:

close in interface Interaction

execute

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

Execute the interaction spec. The spec is either an enqueue or dequeue interaction.

Specified by:

execute in interface Interaction

Throws:

ResourceException

execute

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

Execute the interaction and set the output into the output record. The spec is either an enqueue or dequeue interaction. Only raw messages are supported.

Specified by:

execute in interface Interaction

Throws:

ResourceException

executeEnqueueInteraction

protected void executeEnqueueInteraction(AQEnqueueInteractionSpec spec,
 AQRecord input,
 AQRecord output)
                                  throws ResourceException

Execute the enqueue interaction. Only raw messages are supported.

Throws:

ResourceException

executeDequeueInteraction

protected void executeDequeueInteraction(AQDequeueInteractionSpec spec,
 AQRecord input,
 AQRecord output)
                                  throws ResourceException

Execute the dequeue interaction. Only raw messages are supported.

Throws:

ResourceException

getConnection

public Connection getConnection()

Specified by:

getConnection in interface Interaction

getWarnings

public ResourceWarning getWarnings()

Specified by:

getWarnings in interface Interaction