|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PersistenceService
The Persistent Service.
Field Summary | |
---|---|
static String |
COMPONENT_LOGGER_NAME
|
static String |
DEFAULT_URL_PREFIX
The default URL configuration (File database) |
static String |
DEFAULT_URL_SUFFIX
|
Fields inherited from interface org.ow2.petals.clientserverapi.system.persistence.PersistenceService |
---|
DEFAULT_DURATION, DEFAULT_FETCHSIZE, DEFAULT_PASSWORD, DEFAULT_USER, HSQLDB_DRIVER, MYSQL_DRIVER, ORACLE_DRIVER |
Method Summary | |
---|---|
void |
addMessageExchange(org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl exchange,
boolean storeExchange,
Boolean isSent)
Add a Message Exchange to the persistence service. |
void |
clearExchangeStorage()
Clear the exchange storage. |
void |
deleteMessageExchange(String exchangeId)
Delete the exchange. |
long |
getExchangeStorageDuration()
Get the exchange storage duration. |
org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl |
getMessageExchange(String exchangeId)
Retrieve a Message Exchange from the persistence. |
Map<String,Long> |
getMessageExchangeHistory(String exchangeId)
Get the Message Exchange sent/received history from the persistence. |
List<String> |
getMessageExchangeIds(QName interfaceName,
QName serviceName,
String endpointName,
QName operationName,
long startDate,
long endDate)
Retrieve a list of Message Exchange Ids from the persistence matching the given criteria and the exchange persistence duration |
List<String> |
getMessageExchangeIds(String propertyKey,
String propertyValue)
Retrieve a list of Message Exchange Ids from the persistence matching the given the given exchange property and the exchange persistence duration |
int |
getMessageExchanges(QName interfaceName,
QName serviceName,
String endpointName,
QName operationName,
long startDate,
long endDate)
Count the number of processed exchanges matching the given criteria. |
void |
setExchangeStorageDuration(long duration)
Set the exchange storage duration. |
void |
updateMessageExchange(org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl exchange,
boolean storeExchange,
Boolean isSent)
Update a Message Exchange in the persistence service. |
Field Detail |
---|
static final String COMPONENT_LOGGER_NAME
static final String DEFAULT_URL_PREFIX
static final String DEFAULT_URL_SUFFIX
Method Detail |
---|
void addMessageExchange(org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl exchange, boolean storeExchange, Boolean isSent) throws SQLException, IOException
exchange
- the exchangestoreExchange
- if true
, persist the body of the exchange. If
false
, persist only the exchangeId and the current
timestampisSend
- if true
, it is an exchange sentfalse
, it is an exchange receipt if null
,
it is nor a send or receipt
SQLException
IOException
void clearExchangeStorage()
void deleteMessageExchange(String exchangeId) throws SQLException
exchangeId
-
SQLException
long getExchangeStorageDuration()
duration
- org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl getMessageExchange(String exchangeId) throws SQLException, IOException, ClassNotFoundException
exchangeId
- the Id of the exchange
MessageExchangeImpl
instance
SQLException
IOException
ClassNotFoundException
Map<String,Long> getMessageExchangeHistory(String exchangeId) throws SQLException
exchangeId
- the Id of the exchange
SQLException
List<String> getMessageExchangeIds(QName interfaceName, QName serviceName, String endpointName, QName operationName, long startDate, long endDate) throws SQLException
interfaceName
- The interface name that exchange targets. Can be null
serviceName
- The service name that exchange targets. Can be null
endpointName
- The endpoint name that exchange targets. Can be null
operationName
- The operation name that exchange targets. Can be null
startDate
- the start dateendDate
- the end date
List
of Exchange Ids.
SQLException
List<String> getMessageExchangeIds(String propertyKey, String propertyValue) throws SQLException, IOException
propertyKey
- The name of the propertypropertyValue
- The value of the property as a String
SQLException
IOException
int getMessageExchanges(QName interfaceName, QName serviceName, String endpointName, QName operationName, long startDate, long endDate) throws SQLException
exchangeId
- the Id of the exchange
SQLException
void setExchangeStorageDuration(long duration)
duration
- void updateMessageExchange(org.ow2.petals.jbi.messaging.exchange.MessageExchangeImpl exchange, boolean storeExchange, Boolean isSent) throws SQLException, IOException
exchange
- the exchangestoreExchange
- if true
, persist the body of the exchange. If
false
, persist only the exchangeId and the current
timestampisSend
- if true
, it is an exchange sentfalse
, it is an exchange receipt if null
,
it is nor a send or receipt
SQLException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |