Skip to content

Commit

Permalink
Implemented uses of assert_tables_verified().
Browse files Browse the repository at this point in the history
  • Loading branch information
guillaumeaubert committed Oct 26, 2012
1 parent eb75aa4 commit 88b68c2
Showing 1 changed file with 12 additions and 0 deletions.
12 changes: 12 additions & 0 deletions lib/Queue/DBI/Admin.pm
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,9 @@ sub create_queue
croak 'The first parameter must be a queue name'
if !defined( $queue_name ) || ( $queue_name eq '' );

# Make sure the tables are correctly set up.
$self->assert_tables_verified();

my $queues_table_name = $database_handle->quote_identifier(
$self->get_queues_table_name()
);
Expand Down Expand Up @@ -203,6 +206,9 @@ sub has_queue
croak 'The first parameter must be a queue name'
if !defined( $queue_name ) || ( $queue_name eq '' );

# Make sure the tables are correctly set up.
$self->assert_tables_verified();

return try
{
my $queue = $self->retrieve_queue( $queue_name );
Expand Down Expand Up @@ -244,6 +250,9 @@ sub retrieve_queue
croak 'The first parameter must be a queue name'
if !defined( $queue_name ) || ( $queue_name eq '' );

# Make sure the tables are correctly set up.
$self->assert_tables_verified();

# Instantiate a Queue::DBI object.
my $queue = Queue::DBI->new(
database_handle => $database_handle,
Expand Down Expand Up @@ -275,6 +284,9 @@ sub delete_queue
croak 'The first parameter must be a queue name'
if !defined( $queue_name ) || ( $queue_name eq '' );

# Make sure the tables are correctly set up.
$self->assert_tables_verified();

# Retrieve the queue object, to get the queue ID.
my $queue = $self->retrieve_queue( $queue_name );

Expand Down

0 comments on commit 88b68c2

Please sign in to comment.