|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface DurableConfigurationStore
Nested Class Summary | |
---|---|
static interface |
DurableConfigurationStore.Source
|
Method Summary | |
---|---|
void |
bindQueue(Exchange exchange,
org.apache.qpid.framing.AMQShortString routingKey,
AMQQueue queue,
org.apache.qpid.framing.FieldTable args)
Binds the specified queue to an exchange with a routing key. |
void |
configureConfigStore(String name,
ConfigurationRecoveryHandler recoveryHandler,
Configuration config,
LogSubject logSubject)
Called after instantiation in order to configure the message store. |
void |
createExchange(Exchange exchange)
Makes the specified exchange persistent. |
void |
createQueue(AMQQueue queue)
Makes the specified queue persistent. |
void |
createQueue(AMQQueue queue,
org.apache.qpid.framing.FieldTable arguments)
Makes the specified queue persistent. |
void |
removeExchange(Exchange exchange)
Removes the specified persistent exchange. |
void |
removeQueue(AMQQueue queue)
Removes the specified queue from the persistent store. |
void |
unbindQueue(Exchange exchange,
org.apache.qpid.framing.AMQShortString routingKey,
AMQQueue queue,
org.apache.qpid.framing.FieldTable args)
Unbinds the specified from an exchange under a particular routing key. |
void |
updateQueue(AMQQueue queue)
Updates the specified queue in the persistent store, IF it is already present. |
Method Detail |
---|
void configureConfigStore(String name, ConfigurationRecoveryHandler recoveryHandler, Configuration config, LogSubject logSubject) throws Exception
name
- The name to be used by this storemrecoveryHandler
- Handler to be called as the store recovers on start upconfig
- The apache commons configuration object.
Exception
- If any error occurs that means the store is unable to configure itself.void createExchange(Exchange exchange) throws org.apache.qpid.AMQStoreException
exchange
- The exchange to persist.
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.void removeExchange(Exchange exchange) throws org.apache.qpid.AMQStoreException
exchange
- The exchange to remove.
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.void bindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args) throws org.apache.qpid.AMQStoreException
exchange
- The exchange to bind to.routingKey
- The routing key to bind by.queue
- The queue to bind.args
- Additional parameters.
org.apache.qpid.AMQStoreException
- if the operation fails for any reason.void unbindQueue(Exchange exchange, org.apache.qpid.framing.AMQShortString routingKey, AMQQueue queue, org.apache.qpid.framing.FieldTable args) throws org.apache.qpid.AMQStoreException
exchange
- The exchange to unbind from.routingKey
- The routing key to unbind.queue
- The queue to unbind.args
- Additonal parameters.
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.void createQueue(AMQQueue queue) throws org.apache.qpid.AMQStoreException
queue
- The queue to store.
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.void createQueue(AMQQueue queue, org.apache.qpid.framing.FieldTable arguments) throws org.apache.qpid.AMQStoreException
queue
- The queue to store.arguments
- The additional arguments to the binding
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.void removeQueue(AMQQueue queue) throws org.apache.qpid.AMQStoreException
queue
- The queue to remove.
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.void updateQueue(AMQQueue queue) throws org.apache.qpid.AMQStoreException
queue
- The queue to update the entry for.
org.apache.qpid.AMQStoreException
- If the operation fails for any reason.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |