org.apache.qpid.server.virtualhost
Class VirtualHostConfigRecoveryHandler
java.lang.Object
org.apache.qpid.server.virtualhost.VirtualHostConfigRecoveryHandler
- All Implemented Interfaces:
- ConfigurationRecoveryHandler, ConfigurationRecoveryHandler.BindingRecoveryHandler, ConfigurationRecoveryHandler.ExchangeRecoveryHandler, ConfigurationRecoveryHandler.QueueRecoveryHandler, MessageStoreRecoveryHandler, MessageStoreRecoveryHandler.StoredMessageRecoveryHandler, TransactionLogRecoveryHandler, TransactionLogRecoveryHandler.QueueEntryRecoveryHandler
public class VirtualHostConfigRecoveryHandler
- extends Object
- implements ConfigurationRecoveryHandler, ConfigurationRecoveryHandler.QueueRecoveryHandler, ConfigurationRecoveryHandler.ExchangeRecoveryHandler, ConfigurationRecoveryHandler.BindingRecoveryHandler, MessageStoreRecoveryHandler, MessageStoreRecoveryHandler.StoredMessageRecoveryHandler, TransactionLogRecoveryHandler, TransactionLogRecoveryHandler.QueueEntryRecoveryHandler
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
VirtualHostConfigRecoveryHandler
public VirtualHostConfigRecoveryHandler(VirtualHost virtualHost)
begin
public ConfigurationRecoveryHandler.QueueRecoveryHandler begin(MessageStore store)
- Specified by:
begin
in interface ConfigurationRecoveryHandler
queue
public void queue(String queueName,
String owner,
boolean exclusive,
org.apache.qpid.framing.FieldTable arguments)
- Specified by:
queue
in interface ConfigurationRecoveryHandler.QueueRecoveryHandler
completeQueueRecovery
public ConfigurationRecoveryHandler.ExchangeRecoveryHandler completeQueueRecovery()
- Specified by:
completeQueueRecovery
in interface ConfigurationRecoveryHandler.QueueRecoveryHandler
exchange
public void exchange(String exchangeName,
String type,
boolean autoDelete)
- Specified by:
exchange
in interface ConfigurationRecoveryHandler.ExchangeRecoveryHandler
completeExchangeRecovery
public ConfigurationRecoveryHandler.BindingRecoveryHandler completeExchangeRecovery()
- Specified by:
completeExchangeRecovery
in interface ConfigurationRecoveryHandler.ExchangeRecoveryHandler
begin
public MessageStoreRecoveryHandler.StoredMessageRecoveryHandler begin()
- Specified by:
begin
in interface MessageStoreRecoveryHandler
message
public void message(StoredMessage message)
- Specified by:
message
in interface MessageStoreRecoveryHandler.StoredMessageRecoveryHandler
completeMessageRecovery
public void completeMessageRecovery()
- Specified by:
completeMessageRecovery
in interface MessageStoreRecoveryHandler.StoredMessageRecoveryHandler
begin
public TransactionLogRecoveryHandler.QueueEntryRecoveryHandler begin(TransactionLog log)
- Specified by:
begin
in interface TransactionLogRecoveryHandler
binding
public void binding(String exchangeName,
String queueName,
String bindingKey,
ByteBuffer buf)
- Specified by:
binding
in interface ConfigurationRecoveryHandler.BindingRecoveryHandler
completeBindingRecovery
public void completeBindingRecovery()
- Specified by:
completeBindingRecovery
in interface ConfigurationRecoveryHandler.BindingRecoveryHandler
complete
public void complete()
queueEntry
public void queueEntry(String queueName,
long messageId)
- Specified by:
queueEntry
in interface TransactionLogRecoveryHandler.QueueEntryRecoveryHandler
completeQueueEntryRecovery
public void completeQueueEntryRecovery()
- Specified by:
completeQueueEntryRecovery
in interface TransactionLogRecoveryHandler.QueueEntryRecoveryHandler
Licensed to the Apache Software Foundation