Module org.eclipse.persistence.nosql

Package org.eclipse.persistence.internal.nosql.adapters.mongo

Class MongoInteraction

java.lang.Object

org.eclipse.persistence.internal.nosql.adapters.mongo.MongoInteraction

All Implemented Interfaces:

Interaction

public class MongoInteraction
extends Object
implements Interaction

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

Since:

EclipseLink 2.4

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MongoInteraction(MongoConnection connection)	Default constructor.

Method Summary

Modifier and Type	Method	Description
com.mongodb.DBObject	buildDBObject(MongoRecord record)	Build the Mongo DBObject from the Map record.
MongoRecord	buildRecordFromDBObject(com.mongodb.DBObject object)	Build the Map record from the Mongo DBObject.
void	clearWarnings()
void	close()
Record	execute(InteractionSpec spec, Record record)	Execute the interaction and return output record.
boolean	execute(InteractionSpec spec, Record input, Record output)	Output records are not supported/required.
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 MongoConnection connection

Store the connection the interaction was created from.

Constructor Details

MongoInteraction

public MongoInteraction(MongoConnection 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 boolean execute(InteractionSpec spec,
 Record input,
 Record output)
                throws ResourceException

Output records are not supported/required.

Specified by:

execute in interface Interaction

Throws:

ResourceException

execute

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

Execute the interaction and return output record. The spec is either GET, PUT or DELETE interaction.

Specified by:

execute in interface Interaction

Throws:

ResourceException

buildDBObject

public com.mongodb.DBObject buildDBObject(MongoRecord record)

Build the Mongo DBObject from the Map record.

buildRecordFromDBObject

public MongoRecord buildRecordFromDBObject(com.mongodb.DBObject object)

Build the Map record from the Mongo DBObject.

getConnection

public Connection getConnection()

Specified by:

getConnection in interface Interaction

getWarnings

public ResourceWarning getWarnings()

Specified by:

getWarnings in interface Interaction