org.apache.qpid.server.virtualhost
Class VirtualHostConfigRecoveryHandler

java.lang.Object
  extended by 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


Nested Class Summary
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.store.ConfigurationRecoveryHandler
ConfigurationRecoveryHandler.BindingRecoveryHandler, ConfigurationRecoveryHandler.ExchangeRecoveryHandler, ConfigurationRecoveryHandler.QueueEntryRecoveryHandler, ConfigurationRecoveryHandler.QueueRecoveryHandler
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.store.MessageStoreRecoveryHandler
MessageStoreRecoveryHandler.StoredMessageRecoveryHandler
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.store.TransactionLogRecoveryHandler
TransactionLogRecoveryHandler.QueueEntryRecoveryHandler
 
Constructor Summary
VirtualHostConfigRecoveryHandler(VirtualHost virtualHost)
           
 
Method Summary
 MessageStoreRecoveryHandler.StoredMessageRecoveryHandler begin()
           
 ConfigurationRecoveryHandler.QueueRecoveryHandler begin(MessageStore store)
           
 TransactionLogRecoveryHandler.QueueEntryRecoveryHandler begin(TransactionLog log)
           
 void binding(String exchangeName, String queueName, String bindingKey, ByteBuffer buf)
           
 void complete()
           
 void completeBindingRecovery()
           
 ConfigurationRecoveryHandler.BindingRecoveryHandler completeExchangeRecovery()
           
 void completeMessageRecovery()
           
 void completeQueueEntryRecovery()
           
 ConfigurationRecoveryHandler.ExchangeRecoveryHandler completeQueueRecovery()
           
 void exchange(String exchangeName, String type, boolean autoDelete)
           
 void message(StoredMessage message)
           
 void queue(String queueName, String owner, boolean exclusive, org.apache.qpid.framing.FieldTable arguments)
           
 void queueEntry(String queueName, long messageId)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

VirtualHostConfigRecoveryHandler

public VirtualHostConfigRecoveryHandler(VirtualHost virtualHost)
Method Detail

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