func NewAmqpConnectionPool()

in sender/ConnectionPool.go [41:47]


func NewAmqpConnectionPool(conn mocks.AmqpConnectionInterface) AmqpConnectionPool {
	return &AmqpConnectionPoolImpl{
		connection:  conn,
		amqpWrapper: nil,
		mutex:       sync.Mutex{},
	}
}