diff --git a/audit/messaging/amqp_connection_pool.go b/audit/messaging/amqp_connection_pool.go
index fec9805..b014c91 100644
--- a/audit/messaging/amqp_connection_pool.go
+++ b/audit/messaging/amqp_connection_pool.go
@@ -41,14 +41,14 @@ type ConnectionPoolHandle struct {
 func NewDefaultAmqpConnectionPool(config AmqpConnectionConfig, connectionName string) (ConnectionPool, error) {
 	poolConfig := AmqpConnectionPoolConfig{
 		Parameters: config,
-		PoolSize:   1,
+		PoolSize:   2,
 	}
 	return NewAmqpConnectionPool(poolConfig, connectionName)
 }
 
 func NewAmqpConnectionPool(config AmqpConnectionPoolConfig, connectionName string) (ConnectionPool, error) {
 	if config.PoolSize == 0 {
-		config.PoolSize = 1
+		config.PoolSize = 2
 	}
 	pool := &AmqpConnectionPool{
 		config:             config,