|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cxf.ws.rm.persistence.jdbc.RMTxStore
public class RMTxStore
Field Summary | |
---|---|
static java.lang.String |
DEFAULT_DATABASE_NAME
|
Constructor Summary | |
---|---|
RMTxStore()
|
Method Summary | |
---|---|
protected void |
abort()
|
protected void |
beginTransaction()
|
protected void |
commit()
|
void |
createDestinationSequence(DestinationSequence seq)
Create a destination sequence in the persistent store, with the sequence attributes as specified in the RMSDestinationSequence object. |
void |
createSourceSequence(SourceSequence seq)
Create a source sequence in the persistent store, with the sequence attributes as specified in the RMSourceSequence object. |
protected void |
createTables()
|
static void |
deleteDatabaseFiles()
|
static void |
deleteDatabaseFiles(java.lang.String dbName,
boolean now)
|
java.util.Collection<DestinationSequence> |
getDestinationSequences(java.lang.String endpointIdentifier)
Retrieves all sequences managed by the identified RM destination endpoint from persistent store. |
java.util.Collection<RMMessage> |
getMessages(org.apache.cxf.ws.rm.Identifier sid,
boolean outbound)
Retrieves the outbound/inbound messages stored for the source/destination sequence with the given identifier. |
java.util.Collection<SourceSequence> |
getSourceSequences(java.lang.String endpointIdentifier)
Retrieves all sequences managed by the identified RM source endpoint from persistent store. |
void |
persistIncoming(DestinationSequence seq,
RMMessage msg)
Called by an RM source upon processing an outbound message. |
void |
persistOutgoing(SourceSequence seq,
RMMessage msg)
Called by an RM source upon processing an outbound message. |
void |
removeDestinationSequence(org.apache.cxf.ws.rm.Identifier sid)
Remove the destination sequence with the specified identifier from persistent store. |
void |
removeMessages(org.apache.cxf.ws.rm.Identifier sid,
java.util.Collection<java.math.BigInteger> messageNrs,
boolean outbound)
Removes the messages with the given message numbers and identifiers from the store of outbound/inbound messages. |
void |
removeSourceSequence(org.apache.cxf.ws.rm.Identifier sid)
Remove the source sequence with the specified identifier from persistent store. |
void |
setConnection(java.sql.Connection c)
|
void |
setDriverClassName(java.lang.String dcn)
|
void |
setPassword(java.lang.String p)
|
void |
setUrl(java.lang.String u)
|
void |
setUserName(java.lang.String un)
|
protected void |
storeMessage(org.apache.cxf.ws.rm.Identifier sid,
RMMessage msg,
boolean outbound)
|
protected void |
updateDestinationSequence(DestinationSequence seq)
|
protected void |
updateSourceSequence(SourceSequence seq)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String DEFAULT_DATABASE_NAME
Constructor Detail |
---|
public RMTxStore()
Method Detail |
---|
public void setDriverClassName(java.lang.String dcn)
public void setPassword(java.lang.String p)
public void setUrl(java.lang.String u)
public void setUserName(java.lang.String un)
public void setConnection(java.sql.Connection c)
public void createDestinationSequence(DestinationSequence seq)
RMStore
RMSDestinationSequence
object.
createDestinationSequence
in interface RMStore
seq
- the sequencepublic void createSourceSequence(SourceSequence seq)
RMStore
RMSourceSequence
object.
createSourceSequence
in interface RMStore
seq
- the sequencepublic void removeDestinationSequence(org.apache.cxf.ws.rm.Identifier sid)
RMStore
removeDestinationSequence
in interface RMStore
sid
- the sequencepublic void removeSourceSequence(org.apache.cxf.ws.rm.Identifier sid)
RMStore
removeSourceSequence
in interface RMStore
sid
- the sequencepublic java.util.Collection<DestinationSequence> getDestinationSequences(java.lang.String endpointIdentifier)
RMStore
getDestinationSequences
in interface RMStore
endpointIdentifier
- the identifier for the destination
public java.util.Collection<SourceSequence> getSourceSequences(java.lang.String endpointIdentifier)
RMStore
getSourceSequences
in interface RMStore
endpointIdentifier
- the identifier for the source
public java.util.Collection<RMMessage> getMessages(org.apache.cxf.ws.rm.Identifier sid, boolean outbound)
RMStore
getMessages
in interface RMStore
sid
- the source sequence identifieroutbound
- true if the message is outbound
public void persistIncoming(DestinationSequence seq, RMMessage msg)
RMStore
RMMessage
parameter is null for non application (RM protocol) messages.
persistIncoming
in interface RMStore
seq
- the destination sequencemsg
- the incoming messagepublic void persistOutgoing(SourceSequence seq, RMMessage msg)
RMStore
RMMessage
parameter is null for non application (RM protocol) messages.
persistOutgoing
in interface RMStore
seq
- the source sequencemsg
- the outgoing messagepublic void removeMessages(org.apache.cxf.ws.rm.Identifier sid, java.util.Collection<java.math.BigInteger> messageNrs, boolean outbound)
RMStore
removeMessages
in interface RMStore
sid
- the identifier of the source sequencemessageNrs
- the collection of message numbersoutbound
- true if the message is outboundprotected void beginTransaction()
protected void commit() throws java.sql.SQLException
java.sql.SQLException
protected void abort()
protected void storeMessage(org.apache.cxf.ws.rm.Identifier sid, RMMessage msg, boolean outbound) throws java.io.IOException, java.sql.SQLException
java.io.IOException
java.sql.SQLException
protected void updateSourceSequence(SourceSequence seq) throws java.sql.SQLException
java.sql.SQLException
protected void updateDestinationSequence(DestinationSequence seq) throws java.sql.SQLException, java.io.IOException
java.sql.SQLException
java.io.IOException
protected void createTables() throws java.sql.SQLException
java.sql.SQLException
public static void deleteDatabaseFiles()
public static void deleteDatabaseFiles(java.lang.String dbName, boolean now)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |